EasyNetQ by Mike Hadlow,Michael Denny,Yury Pliner,Wiebe Tijsma,Contributors (see GitHub repo)

<PackageReference Include="EasyNetQ" Version="7.5.5" />

.NET API 494,080 bytes

 RabbitAdvancedBus

public class RabbitAdvancedBus : IAdvancedBus, IDisposable
public IServiceResolver Container { get; }

public IConventions Conventions { get; }

public bool IsConnected { get; }

public event EventHandler<BlockedEventArgs> Blocked

public event EventHandler<ConnectedEventArgs> Connected

public event EventHandler<DisconnectedEventArgs> Disconnected

public event EventHandler<MessageReturnedEventArgs> MessageReturned

public event EventHandler<UnblockedEventArgs> Unblocked

public RabbitAdvancedBus(ILogger<RabbitAdvancedBus> logger, IProducerConnection producerConnection, IConsumerConnection consumerConnection, IConsumerFactory consumerFactory, IPersistentChannelDispatcher persistentChannelDispatcher, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IServiceResolver container, ConnectionConfiguration configuration, IEnumerable<IProduceConsumeInterceptor> produceConsumeInterceptors, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, IPullingConsumerFactory pullingConsumerFactory, AdvancedBusEventHandlers advancedBusEventHandlers, IConsumeScopeProvider consumeScopeProvider)

Creates RabbitAdvancedBus

public Task<Binding<Queue>> BindAsync(Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)

public Task<Binding<Exchange>> BindAsync(Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)

public Task ConnectAsync(CancellationToken cancellationToken = default)

public IDisposable Consume(Action<IConsumeConfiguration> configure)

public IPullingConsumer<PullResult> CreatePullingConsumer(ref Queue queue, bool autoAck = true)

public IPullingConsumer<PullResult<T>> CreatePullingConsumer<T>(ref Queue queue, bool autoAck = true)

public virtual void Dispose()

public Task<Exchange> ExchangeDeclareAsync(string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)

public Task ExchangeDeclarePassiveAsync(string name, CancellationToken cancellationToken = default)

public virtual Task ExchangeDeleteAsync(Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)

public virtual Task ExchangeUnbindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)

public Task<QueueStats> GetQueueStatsAsync(string name, CancellationToken cancellationToken)

public virtual Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken)

public virtual Task PublishAsync<T>(Exchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken)

public virtual Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, MessageProperties properties, ReadOnlyMemory<byte> body, CancellationToken cancellationToken)

public Task<Queue> QueueDeclareAsync(CancellationToken cancellationToken)

public Task<Queue> QueueDeclareAsync(string name, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)

public Task QueueDeclarePassiveAsync(string name, CancellationToken cancellationToken = default)

public virtual Task QueueDeleteAsync(string name, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)

public virtual Task QueuePurgeAsync(string name, CancellationToken cancellationToken)

public virtual Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)