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

<PackageReference Include="EasyNetQ" Version="7.0.0-alpha3" />

.NET API 491,520 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 Unblocked

public RabbitAdvancedBus(IPersistentConnection connection, IConsumerFactory consumerFactory, IClientCommandDispatcher clientCommandDispatcher, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IServiceResolver container, ConnectionConfiguration configuration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, IPullingConsumerFactory pullingConsumerFactory, AdvancedBusEventHandlers advancedBusEventHandlers)

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 IDisposable Consume(Action<IConsumeConfiguration> configure)

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

public IPullingConsumer<PullResult<T>> CreatePullingConsumer<T>(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 Task<QueueStats> GetQueueStatsAsync(Queue queue, 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 messageProperties, 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(Queue queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)

public virtual Task QueuePurgeAsync(Queue queue, CancellationToken cancellationToken)

public virtual Task UnbindAsync(Binding<Queue> binding, CancellationToken cancellationToken)

public virtual Task UnbindAsync(Binding<Exchange> binding, CancellationToken cancellationToken)