EasyNetQ by Mike Hadlow, Contribtors (see GitHub repo)

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

.NET API 691,712 bytes

 RabbitAdvancedBus

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

public virtual bool IsConnected { get; }

public event Action Connected

public event Action Disconnected

public event Action<byte[], MessageProperties, MessageReturnedInfo> MessageReturned

public RabbitAdvancedBus(IConnectionFactory connectionFactory, IConsumerFactory consumerFactory, IEasyNetQLogger logger, IClientCommandDispatcherFactory clientCommandDispatcherFactory, IPublisher publisher, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IContainer container, IConnectionConfiguration connectionConfiguration, IMessageSerializationStrategy messageSerializationStrategy)

public virtual IBinding Bind(IExchange exchange, IQueue queue, string routingKey)

public virtual IBinding Bind(IExchange source, IExchange destination, string routingKey)

public Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey)

public virtual void BindingDelete(IBinding binding)

public IDisposable Consume<T>(IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage)

public IDisposable Consume<T>(IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)

public virtual IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)

public IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)

public virtual IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers)

public IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers, Action<IConsumerConfiguration> configure)

public IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)

public virtual IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)

public virtual void Dispose()

public virtual IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)

public Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)

public virtual void ExchangeDelete(IExchange exchange, bool ifUnused = false)

public IBasicGetResult<T> Get<T>(IQueue queue)

public IBasicGetResult Get(IQueue queue)

protected void OnConnected()

protected void OnDisconnected()

protected void OnMessageReturned(ReturnedMessageEvent args)

public void Publish(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)

public void Publish<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)

public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)

public virtual Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)

public virtual IQueue QueueDeclare(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int perQueueTtl = 2147483647, int expires = 2147483647, string deadLetterExchange = null)

public virtual IQueue QueueDeclare()

public virtual void QueueDelete(IQueue queue, bool ifUnused = false, bool ifEmpty = false)

public virtual void QueuePurge(IQueue queue)