RabbitAdvancedBus

public class RabbitAdvancedBus : IAdvancedBus, IDisposable

public IContainer Container { get; }

public IConventions Conventions { get; }

public virtual bool IsConnected { get; }

public event EventHandler<ConnectionBlockedEventArgs> Blocked

public event EventHandler Connected

public event EventHandler Disconnected

public event EventHandler<MessageReturnedEventArgs> MessageReturned

public event EventHandler Unblocked

public RabbitAdvancedBus(IConnectionFactory connectionFactory, IConsumerFactory consumerFactory, IEasyNetQLogger logger, IClientCommandDispatcherFactory clientCommandDispatcherFactory, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IContainer container, ConnectionConfiguration connectionConfiguration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, AdvancedBusEventHandlers advancedBusEventHandlers)

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 exchange, IQueue queue, 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, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)

public IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage, 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, bool delayed = false)

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

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

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

public IBasicGetResult Get(IQueue queue)

public uint MessageCount(IQueue queue)

protected void OnBlocked(ConnectionBlockedEvent args)

protected void OnConnected()

protected void OnDisconnected()

protected void OnMessageReturned(ReturnedMessageEvent args)

protected void OnUnblocked()

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

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

public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, IMessage message)

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

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

public virtual IQueue QueueDeclare(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default)

public virtual IQueue QueueDeclare()

public Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default)

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

public virtual void QueuePurge(IQueue queue)

EasyNetQ by Mike Hadlow, Contributors (see GitHub repo)

.NET API 821,760 bytes

RabbitAdvancedBus