EasyNetQ by Mike Hadlow, Contributors (see GitHub repo)

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

---

API Diff between 0.57.2.431 and 0.35.0.282

399 Additions 112 Removals

EasyNetQ

• public class AdvancedBusEventHandlers
  • public static readonly AdvancedBusEventHandlers Default
  • public EventHandler<ConnectionBlockedEventArgs> Blocked { get; }
  • public EventHandler Connected { get; }
  • public EventHandler Disconnected { get; }
  • public EventHandler<MessageReturnedEventArgs> MessageReturned { get; }
  • public EventHandler Unblocked { get; }
  • public AdvancedBusEventHandlers(EventHandler connected = null, EventHandler disconnected = null, EventHandler<ConnectionBlockedEventArgs> blocked = null, EventHandler unblocked = null, EventHandler<MessageReturnedEventArgs> messageReturned = null)
• public static class BusExtensions
• public class ConnectionConfiguration
  • public IEnumerable<IHostConfiguration> Hosts { get; set; }
  • public IEnumerable<HostConfiguration> Hosts { get; set; }
  • public bool UseBackgroundThreads { get; set; }
• public class ConnectionFactoryInfo
  • public IHostConfiguration HostConfiguration { get; }
  • public ConnectionFactoryInfo(ConnectionFactory connectionFactory, IHostConfiguration hostConfiguration)
  • public HostConfiguration HostConfiguration { get; }
  • public ConnectionFactoryInfo(ConnectionFactory connectionFactory, HostConfiguration hostConfiguration)
• public class ConnectionFactoryWrapper : IConnectionFactory
  • public virtual IConnectionConfiguration Configuration { get; }
  • public virtual IHostConfiguration CurrentHost { get; }
  • public virtual ConnectionConfiguration Configuration { get; }
  • public virtual HostConfiguration CurrentHost { get; }
  • public ConnectionFactoryWrapper(IConnectionConfiguration connectionConfiguration, IClusterHostSelectionStrategy<ConnectionFactoryInfo> clusterHostSelectionStrategy)
  • public ConnectionFactoryWrapper(ConnectionConfiguration connectionConfiguration, IClusterHostSelectionStrategy<ConnectionFactoryInfo> clusterHostSelectionStrategy)
• public class DefaultClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
• public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
  • public DeserializedMessage DeserializeMessage(MessageProperties properties, byte[] body)
  • public SerializedMessage SerializeMessage<T>(IMessage<T> message)
  • public IMessage<T> DeserializeMessage<T>(MessageProperties properties, byte[] body)
  • public IMessage DeserializeMessage(MessageProperties properties, byte[] body)
  • public SerializedMessage SerializeMessage(IMessage message)
• public class DeserializedMessage
• public class DeliveryModeAttribute : Attribute
  • public bool IsPersistent { get; }
  • public DeliveryModeAttribute(bool isPersistent)
• public static class Extensions
  • public static void Add<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> source, TKey key, TValue value)
  • public static TimeSpan Double(this TimeSpan timeSpan)
  • public static void Remove<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> source, TKey key)
  • public static void SafeDispose(this IDisposable disposable)
• public class HostConfiguration
  • public SslOption Ssl { get; }
• public interface IAdvancedBus : IDisposable
  • IConventions Conventions { get; }
  • event Action Connected
  • event Action Disconnected
  • event Action<byte[], MessageProperties, MessageReturnedInfo> MessageReturned
  • event EventHandler<ConnectionBlockedEventArgs> Blocked
  • event EventHandler Connected
  • event EventHandler Disconnected
  • event EventHandler<MessageReturnedEventArgs> MessageReturned
  • event EventHandler Unblocked
  • Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey)
  • IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)
  • IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
  • IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
  • Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
  • IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null, bool delayed = false)
  • 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)
  • void Publish(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
  • void Publish<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
  • Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
  • Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
  • 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)
  • uint MessageCount(IQueue queue)
  • void Publish(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body)
  • void Publish<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message)
  • Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, IMessage message)
  • Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message)
  • Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body)
  • 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)
  • 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 interface IBus : IDisposable
  • event Action Connected
  • event Action Disconnected
  • IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
  • IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
  • IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
  • IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, Action<IResponderConfiguration> configure)
  • IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
  • IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage)
  • IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
  • IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
  • IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
  • Task SendAsync<T>(string queue, T message)
  • ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage)
  • ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
  • ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
  • ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
• public interface IConnectionConfiguration
• public interface IConnectionFactory
  • IConnectionConfiguration Configuration { get; }
  • IHostConfiguration CurrentHost { get; }
  • ConnectionConfiguration Configuration { get; }
  • HostConfiguration CurrentHost { get; }
• public interface IHostConfiguration
• public interface IMessage
  • Type MessageType { get; }
  • MessageProperties Properties { get; }
  • object GetBody()
• public interface IMessage<T> : IMessage
  • MessageProperties Properties { get; }
• public interface IMessageDeliveryModeStrategy
  • byte GetDeliveryMode(Type messageType)
• public interface IMessageSerializationStrategy
  • DeserializedMessage DeserializeMessage(MessageProperties properties, byte[] body)
  • SerializedMessage SerializeMessage<T>(IMessage<T> message)
  • IMessage<T> DeserializeMessage<T>(MessageProperties properties, byte[] body)
  • IMessage DeserializeMessage(MessageProperties properties, byte[] body)
  • SerializedMessage SerializeMessage(IMessage message)
• public interface IPersistentConnection : IDisposable
  • void Initialize()
• public interface ISaga
• public interface ISubscriptionResult : IDisposable
  • IDisposable ConsumerCancellation { get; }
  • IExchange Exchange { get; }
  • IQueue Queue { get; }
• public interface ITimeoutStrategy
  • ulong GetTimeoutSeconds(Type messageType)
• public static class LinqExtensions
  • public static IEnumerable<T> AtLeastOneWithDefault<T>(this IEnumerable<T> items, T default)
  • public static IEnumerable<KeyValuePair<string, string>> EnumerateDictionary(this IDictionary<string, object> dictionary)
• public static class Message
• public class Message<T> : IMessage<T>, IMessage
  • public Type MessageType { get; }
  • public Message(T body, MessageProperties properties)
  • public object GetBody()
• public static class MessageDeliveryMode
  • public const byte NonPersistent = 1
  • public const byte Persistent = 2
• public class MessageDeliveryModeStrategy : IMessageDeliveryModeStrategy
  • public MessageDeliveryModeStrategy(ConnectionConfiguration connectionConfiguration)
  • public byte GetDeliveryMode(Type messageType)
• public static class MessageFactory
  • public static IMessage CreateInstance(Type messageType, object body)
  • public static IMessage CreateInstance(Type messageType, object body, MessageProperties properties)
• public class MessageProperties : ICloneable
  • public void AppendPropertyDebugStringTo(StringBuilder stringBuilder)
  • public object Clone()
• public class MessageReturnedEventArgs : EventArgs
  • public byte[] MessageBody { get; }
  • public MessageProperties MessageProperties { get; }
  • public MessageReturnedInfo MessageReturnedInfo { get; }
  • public MessageReturnedEventArgs(byte[] messageBody, MessageProperties messageProperties, MessageReturnedInfo messageReturnedInfo)
• public class OrderedClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
  • public virtual bool Succeeded { get; }
  • public OrderedClusterHostSelectionStrategy()
  • public virtual void Add(T item)
  • public virtual T Current()
  • public virtual IEnumerator<T> GetEnumerator()
  • public virtual bool Next()
  • public virtual void Reset()
  • public virtual void Success()
• public class PersistentConnection : IPersistentConnection, IDisposable
  • public void Initialize()
• public class RabbitAdvancedBus : IAdvancedBus, IDisposable
  • public IConventions Conventions { 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 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 Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey)
  • public IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)
  • public IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
  • 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 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 uint MessageCount(IQueue queue)
  • protected void OnBlocked(ConnectionBlockedEvent 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)
  • 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 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 class RabbitBus : IBus, IDisposable
  • public IConventions Conventions { get; }
  • public IEasyNetQLogger Logger { get; }
  • public event Action Connected
  • public event Action Disconnected
  • public RabbitBus(IEasyNetQLogger logger, IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IRpc rpc, ISendReceive sendReceive, IConnectionConfiguration connectionConfiguration)
  • public RabbitBus(IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IRpc rpc, ISendReceive sendReceive, ConnectionConfiguration connectionConfiguration)
  • protected void OnConnected()
  • protected void OnDisconnected()
  • public virtual IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
  • public virtual IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
  • public virtual IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
  • public IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, Action<IResponderConfiguration> configure)
  • public IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
  • public virtual IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage)
  • public virtual IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
  • public virtual IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
  • public virtual IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
  • public virtual Task SendAsync<T>(string queue, T message)
  • public virtual ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage)
  • public virtual ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
  • public virtual ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
  • public virtual ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
• public static class RabbitBusExtensions
• public static class RabbitHutch
  • public static IBus CreateBus()
  • public static IBus CreateBus(Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(AdvancedBusEventHandlers advancedBusEventHandlers, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(AdvancedBusEventHandlers advancedBusEventHandlers)
  • public static IBus CreateBus(string connectionString, AdvancedBusEventHandlers advancedBusEventHandlers)
  • public static IBus CreateBus(string connectionString, AdvancedBusEventHandlers advancedBusEventHandlers, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(IConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus()
  • public static IBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, ushort requestedHeartbeat, AdvancedBusEventHandlers advancedBusEventHandlers, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(ConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(ConnectionConfiguration connectionConfiguration, AdvancedBusEventHandlers advancedBusEventHandlers, Action<IServiceRegister> registerServices)
• public static class ReflectionHelpers
  • public static T CreateInstance<T>()
  • public static object CreateInstance(Type objectType, object arg)
  • public static object CreateInstance(Type objectType, object firstArg, object secondArg)
  • public static TAttribute GetAttribute<TAttribute>(this Type type) where TAttribute : Attribute
  • public static IEnumerable<TAttribute> GetAttributes<TAttribute>(this Type type) where TAttribute : Attribute
• public sealed delegate SubsriberNameFromDelegate : MulticastDelegate
• public static class TaskHelpers
• public sealed class TimeBudget
  • public TimeBudget(TimeSpan budget, TimeSpan precision)
  • public TimeBudget(TimeSpan budget)
  • public TimeSpan GetRemainingTime()
  • public bool IsExpired()
  • public TimeBudget Start()
• public class TimeoutSecondsAttribute : Attribute
  • public ushort Timeout { get; }
  • public TimeoutSecondsAttribute(ushort timeout)
• public class TimeoutStrategy : ITimeoutStrategy
  • public TimeoutStrategy(ConnectionConfiguration connectionConfiguration)
  • public ulong GetTimeoutSeconds(Type messageType)

EasyNetQ.AutoSubscribe

• public class AutoSubscriber
  • protected Action<ISubscriptionConfiguration> ConfigureSubscriptionConfiguration { get; set; }
  • public virtual void Subscribe(Type[] consumerTypes)
  • public virtual void SubscribeAsync(Type[] consumerTypes)
• public class SubscriptionConfigurationAttribute : Attribute
  • public bool AutoDelete { get; set; }
  • public bool CancelOnHaFailover { get; set; }
  • public int Expires { get; set; }
  • public ushort PrefetchCount { get; set; }
  • public int Priority { get; set; }
  • public SubscriptionConfigurationAttribute()

EasyNetQ.ConnectionString

• public static class ConnectionStringGrammar
  • public static Parser<IHostConfiguration> Host
  • public static Parser<IEnumerable<IHostConfiguration>> Hosts
  • public static Parser<HostConfiguration> Host
  • public static Parser<IEnumerable<HostConfiguration>> Hosts
• public class ConnectionStringParser : IConnectionStringParser
  • public IConnectionConfiguration Parse(string connectionString)
  • public ConnectionConfiguration Parse(string connectionString)
• public interface IConnectionStringParser
  • IConnectionConfiguration Parse(string connectionString)
  • ConnectionConfiguration Parse(string connectionString)

EasyNetQ.Consumer

• public class ConsumerConfiguration : IConsumerConfiguration
  • public bool IsExclusive { get; }
  • public IConsumerConfiguration AsExclusive()
• public class ConsumerDispatcher : IConsumerDispatcher, IDisposable
  • public ConsumerDispatcher(IEasyNetQLogger logger)
  • public ConsumerDispatcher(ConnectionConfiguration configuration, IEasyNetQLogger logger)
• public class ConsumerDispatcherFactory : IConsumerDispatcherFactory, IDisposable
  • public ConsumerDispatcherFactory(IEasyNetQLogger logger)
  • public ConsumerDispatcherFactory(ConnectionConfiguration configuration, IEasyNetQLogger logger)
• public class ExclusiveConsumer : IConsumer, IDisposable
  • public ExclusiveConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
  • public void Dispose()
  • public IDisposable StartConsuming()
• public class HandlerCollection : IHandlerCollection, IHandlerRegistration
  • public object GetHandler(Type messageType)
  • public Func<IMessage, MessageReceivedInfo, Task> GetHandler(Type messageType)
• public interface IConsumerConfiguration
  • bool IsExclusive { get; }
  • IConsumerConfiguration AsExclusive()
• public interface IHandlerCollection : IHandlerRegistration
  • object GetHandler(Type messageType)
  • Func<IMessage, MessageReceivedInfo, Task> GetHandler(Type messageType)
• public interface IInternalConsumer : IDisposable
  • void StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
  • StartConsumingStatus StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
• public class InternalConsumer : IBasicConsumer, IInternalConsumer, IDisposable
  • public event ConsumerCancelledEventHandler ConsumerCancelled
  • public InternalConsumer(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConsumerDispatcher consumerDispatcher, IConventions conventions, IConnectionConfiguration connectionConfiguration, IEventBus eventBus)
  • public event EventHandler<ConsumerEventArgs> ConsumerCancelled
  • public InternalConsumer(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConsumerDispatcher consumerDispatcher, IConventions conventions, ConnectionConfiguration connectionConfiguration, IEventBus eventBus)
  • public void HandleModelShutdown(IModel model, ShutdownEventArgs reason)
  • public void StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
  • public void HandleModelShutdown(object model, ShutdownEventArgs reason)
  • public StartConsumingStatus StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
• public class InternalConsumerFactory : IInternalConsumerFactory, IDisposable
  • public InternalConsumerFactory(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConventions conventions, IConnectionConfiguration connectionConfiguration, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
  • public InternalConsumerFactory(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConventions conventions, ConnectionConfiguration connectionConfiguration, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
• public enum StartConsumingStatus
  • Failed = 1
  • Succeed = 0
• public class SubscriptionResult : ISubscriptionResult, IDisposable
  • public IDisposable ConsumerCancellation { get; }
  • public IExchange Exchange { get; }
  • public IQueue Queue { get; }
  • public SubscriptionResult(IExchange exchange, IQueue queue, IDisposable consumerCancellation)
  • public void Dispose()

EasyNetQ.Events

• public class AckEvent
  • public ConsumerExecutionContext ConsumerExecutionContext { get; }
  • public AckEvent(ConsumerExecutionContext consumerExecutionContext, AckResult ackResult)
  • public byte[] Body { get; }
  • public MessageProperties Properties { get; }
  • public MessageReceivedInfo ReceivedInfo { get; }
  • public AckEvent(MessageReceivedInfo info, MessageProperties properties, byte[] body, AckResult ackResult)
• public class ConnectionBlockedEvent
  • public string Reason { get; }
  • public ConnectionBlockedEvent(string reason)
• public class ConnectionUnblockedEvent
  • public ConnectionUnblockedEvent()
• public class DeliveredMessageEvent
  • public byte[] Body { get; }
  • public MessageProperties Properties { get; }
  • public MessageReceivedInfo ReceivedInfo { get; }
  • public DeliveredMessageEvent(MessageReceivedInfo info, MessageProperties properties, byte[] body)
• public class MessageConfirmationEvent
  • public IModel Channel { get; }
  • public ulong DeliveryTag { get; }
  • public bool IsNack { get; }
  • public bool Multiple { get; }
  • public MessageConfirmationEvent()
  • public static MessageConfirmationEvent Ack(IModel channel, ulong deliveryTag, bool multiple)
  • public static MessageConfirmationEvent Nack(IModel channel, ulong deliveryTag, bool multiple)
• public class PublishedMessageEvent
  • public byte[] Body { get; }
  • public string ExchangeName { get; }
  • public MessageProperties Properties { get; }
  • public string RoutingKey { get; }
  • public PublishedMessageEvent(string exchangeName, string routingKey, MessageProperties properties, byte[] body)

EasyNetQ.FluentConfiguration

• public interface ISubscriptionConfiguration
  • ISubscriptionConfiguration AsExclusive()
• public class SubscriptionConfiguration : ISubscriptionConfiguration
  • public int Expires { get; }
  • public int? Expires { get; }
  • public bool IsExclusive { get; }
  • public ISubscriptionConfiguration AsExclusive()

EasyNetQ.Interception

• public class CompositeInterceptor : IProduceConsumeInterceptor
  • public CompositeInterceptor()
  • public void Add(IProduceConsumeInterceptor interceptor)
  • public RawMessage OnConsume(RawMessage rawMessage)
  • public RawMessage OnProduce(RawMessage rawMessage)
• public class DefaultInterceptor : IProduceConsumeInterceptor
  • public DefaultInterceptor()
  • public RawMessage OnConsume(RawMessage rawMessage)
  • public RawMessage OnProduce(RawMessage rawMessage)
• public class GZipInterceptor : IProduceConsumeInterceptor
  • public GZipInterceptor()
  • public RawMessage OnConsume(RawMessage rawMessage)
  • public RawMessage OnProduce(RawMessage rawMessage)
• public interface IInterceptorRegistrator
  • void Add(IProduceConsumeInterceptor interceptor)
• public static class InterceptionExtensions
  • public static IInterceptorRegistrator EnableGZipCompression(this IInterceptorRegistrator interceptorRegistrator)
  • public static IServiceRegister EnableInterception(this IServiceRegister serviceRegister, Action<IInterceptorRegistrator> configure)
  • public static IInterceptorRegistrator EnableTripleDESEncryption(this IInterceptorRegistrator interceptorRegistrator, byte[] key, byte[] iv)
• public class InterceptorRegistrator : IInterceptorRegistrator
  • public InterceptorRegistrator(IServiceRegister serviceRegister)
  • public void Add(IProduceConsumeInterceptor interceptor)
  • public IServiceRegister Register()
• public interface IProduceConsumeInterceptor
  • RawMessage OnConsume(RawMessage rawMessage)
  • RawMessage OnProduce(RawMessage rawMessage)
• public class RawMessage
  • public byte[] Body { get; }
  • public MessageProperties Properties { get; }
  • public RawMessage(MessageProperties properties, byte[] body)
• public class TripleDESInterceptor : IProduceConsumeInterceptor
  • public TripleDESInterceptor(byte[] key, byte[] iv)
  • public RawMessage OnConsume(RawMessage rawMessage)
  • public RawMessage OnProduce(RawMessage rawMessage)

EasyNetQ.Internals

• public class AsyncSemaphore
  • public int Available { get; }
  • public AsyncSemaphore(int initial)
  • public void Release()
  • public void Wait()
  • public Task WaitAsync()
• public static class TaskHelpers
  • public static readonly Task Completed
  • public static Task Delay(TimeSpan delay, CancellationToken cancellation)
  • public static Task ExecuteSynchronously(Action action)
  • public static Task FromException(Exception ex)
  • public static Task<T> FromResult<T>(T result)
  • public static void TrySetCanceledSafe<T>(this TaskCompletionSource<T> source)
  • public static void TrySetExceptionSafe<T>(this TaskCompletionSource<T> source, Exception exception)
  • public static void TrySetResultSafe<T>(this TaskCompletionSource<T> source, T result)
  • public static Task<Task> WhenAny(Task[] tasks)

EasyNetQ.MessageVersioning

• public class VersionedMessageSerializationStrategy : IMessageSerializationStrategy
  • public DeserializedMessage DeserializeMessage(MessageProperties properties, byte[] body)
  • public SerializedMessage SerializeMessage<T>(IMessage<T> message)
  • public IMessage<T> DeserializeMessage<T>(MessageProperties properties, byte[] body)
  • public IMessage DeserializeMessage(MessageProperties properties, byte[] body)
  • public SerializedMessage SerializeMessage(IMessage message)

EasyNetQ.NonGeneric

• public static class NonGenericExtensions
  • public static IDisposable Subscribe(this IBus bus, Type messageType, string subscriptionId, Action<object> onMessage)
  • public static IDisposable Subscribe(this IBus bus, Type messageType, string subscriptionId, Action<object> onMessage, Action<ISubscriptionConfiguration> configure)
  • public static IDisposable SubscribeAsync(this IBus bus, Type messageType, string subscriptionId, Func<object, Task> onMessage)
  • public static IDisposable SubscribeAsync(this IBus bus, Type messageType, string subscriptionId, Func<object, Task> onMessage, Action<ISubscriptionConfiguration> configure)
  • public static ISubscriptionResult Subscribe(this IBus bus, Type messageType, string subscriptionId, Action<object> onMessage)
  • public static ISubscriptionResult Subscribe(this IBus bus, Type messageType, string subscriptionId, Action<object> onMessage, Action<ISubscriptionConfiguration> configure)
  • public static ISubscriptionResult SubscribeAsync(this IBus bus, Type messageType, string subscriptionId, Func<object, Task> onMessage)
  • public static ISubscriptionResult SubscribeAsync(this IBus bus, Type messageType, string subscriptionId, Func<object, Task> onMessage, Action<ISubscriptionConfiguration> configure)

EasyNetQ.Producer

• public class ClientCommandDispatcher : IClientCommandDispatcher, IDisposable
  • public ClientCommandDispatcher(IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
  • public ClientCommandDispatcher(ConnectionConfiguration configuration, IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
  • public Task<T> Invoke<T>(Func<IModel, T> channelAction)
  • public Task Invoke(Action<IModel> channelAction)
  • public T Invoke<T>(Func<IModel, T> channelAction)
  • public void Invoke(Action<IModel> channelAction)
  • public Task<T> InvokeAsync<T>(Func<IModel, T> channelAction)
  • public Task InvokeAsync(Action<IModel> channelAction)
• public class ClientCommandDispatcherFactory : IClientCommandDispatcherFactory
  • public ClientCommandDispatcherFactory(IPersistentChannelFactory persistentChannelFactory)
  • public ClientCommandDispatcherFactory(ConnectionConfiguration configuration, IPersistentChannelFactory persistentChannelFactory)
• public class ClientCommandDispatcherSingleton : IClientCommandDispatcher, IDisposable
  • public ClientCommandDispatcherSingleton(IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
  • public ClientCommandDispatcherSingleton(ConnectionConfiguration configuration, IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
  • public Task<T> Invoke<T>(Func<IModel, T> channelAction)
  • public Task Invoke(Action<IModel> channelAction)
  • public T Invoke<T>(Func<IModel, T> channelAction)
  • public void Invoke(Action<IModel> channelAction)
  • public Task<T> InvokeAsync<T>(Func<IModel, T> channelAction)
  • public Task InvokeAsync(Action<IModel> channelAction)
• public interface IClientCommandDispatcher : IDisposable
  • Task<T> Invoke<T>(Func<IModel, T> channelAction)
  • Task Invoke(Action<IModel> channelAction)
  • T Invoke<T>(Func<IModel, T> channelAction)
  • void Invoke(Action<IModel> channelAction)
  • Task<T> InvokeAsync<T>(Func<IModel, T> channelAction)
  • Task InvokeAsync(Action<IModel> channelAction)
• public interface IPublisher
• public interface IPublishConfirmationListener : IDisposable
  • IPublishConfirmationWaiter GetWaiter(IModel model)
• public interface IPublishConfirmationWaiter
  • void Cancel()
  • void Wait(TimeSpan timeout)
  • Task WaitAsync(TimeSpan timeout)
• public interface IResponderConfiguration
  • IResponderConfiguration WithPrefetchCount(ushort prefetchCount)
• public interface IRpc
  • IDisposable Respond<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
• public interface ISendReceive
  • IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
  • IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
  • IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
  • Task SendAsync<T>(string queue, T message)
• public class PersistentChannel : IPersistentChannel, IDisposable
  • public IModel Channel { get; }
  • public PersistentChannel(IPersistentConnection connection, IEasyNetQLogger logger, IConnectionConfiguration configuration, IEventBus eventBus)
  • public PersistentChannel(IPersistentConnection connection, IEasyNetQLogger logger, ConnectionConfiguration configuration, IEventBus eventBus)
• public class PersistentChannelFactory : IPersistentChannelFactory
  • public PersistentChannelFactory(IEasyNetQLogger logger, IConnectionConfiguration configuration, IEventBus eventBus)
  • public PersistentChannelFactory(IEasyNetQLogger logger, ConnectionConfiguration configuration, IEventBus eventBus)
• public abstract class PublisherBase : IPublisher
• public class PublisherBasic : PublisherBase
• public class PublisherConfirms : PublisherBase
• public static class PublisherFactory
• public class PublishConfirmationListener : IPublishConfirmationListener, IDisposable
  • public PublishConfirmationListener(IEventBus eventBus)
  • public void Dispose()
  • public IPublishConfirmationWaiter GetWaiter(IModel model)
• public class PublishConfirmationWaiter : IPublishConfirmationWaiter
  • public PublishConfirmationWaiter(ulong deliveryTag, Task confirmation, CancellationToken cancellation, Action action)
  • public void Cancel()
  • public void Wait(TimeSpan timeout)
  • public Task WaitAsync(TimeSpan timeout)
• public class PublishInterruptedException : Exception
  • public PublishInterruptedException()
  • public PublishInterruptedException(string message)
  • public PublishInterruptedException(string message, Exception inner)
  • protected PublishInterruptedException(SerializationInfo info, StreamingContext context)
• public class ResponderConfiguration : IResponderConfiguration
  • public ushort PrefetchCount { get; }
  • public ResponderConfiguration(ushort defaultPrefetchCount)
  • public IResponderConfiguration WithPrefetchCount(ushort prefetchCount)
• public class Rpc : IRpc
  • protected const string ExceptionMessageKey = "ExceptionMessage"
  • protected const string IsFaultedKey = "IsFaulted"
  • protected const string exceptionMessageKey = "ExceptionMessage"
  • protected const string isFaultedKey = "IsFaulted"
  • protected readonly IConnectionConfiguration configuration
  • protected readonly IMessageDeliveryModeStrategy messageDeliveryModeStrategy
  • public Rpc(IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IConnectionConfiguration configuration)
  • public Rpc(ConnectionConfiguration connectionConfiguration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITimeoutStrategy timeoutStrategy, ITypeNameSerializer typeNameSerializer)
  • protected virtual void OnResponderFailure<TRequest, TResponse>(IMessage<TRequest> requestMessage, string exceptionMessage, Exception exception)
  • protected virtual void OnResponderSuccess<TRequest, TResponse>(IMessage<TRequest> requestMessage, TResponse response)
  • public virtual IDisposable Respond<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
• public class SendReceive : ISendReceive
  • public SendReceive(IAdvancedBus advancedBus, IConnectionConfiguration connectionConfiguration)
  • public SendReceive(IAdvancedBus advancedBus, IMessageDeliveryModeStrategy messageDeliveryModeStrategy)
  • public IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
  • public IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
  • public IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
  • public Task SendAsync<T>(string queue, T message)

EasyNetQ.Scheduling

• public static class BusExtensions
  • public static void CancelFuturePublish(this IBus bus, string cancellationKey)
  • public static Task CancelFuturePublishAsync(this IBus bus, string cancellationKey)
  • public static void FuturePublish<T>(this IBus bus, DateTime futurePublishDate, T message)
  • public static void FuturePublish<T>(this IBus bus, DateTime futurePublishDate, string cancellationKey, T message)
  • public static void FuturePublish<T>(this IBus bus, TimeSpan messageDelay, T message)
  • public static Task FuturePublishAsync<T>(this IBus bus, DateTime futurePublishDate, T message)
  • public static Task FuturePublishAsync<T>(this IBus bus, DateTime futurePublishDate, string cancellationKey, T message)
  • public static Task FuturePublishAsync<T>(this IBus bus, TimeSpan messageDelay, T message)
• public class DeadLetterExchangeAndMessageTtlScheduler : IScheduler
  • public DeadLetterExchangeAndMessageTtlScheduler(IAdvancedBus advancedBus, IConventions conventions, IMessageDeliveryModeStrategy messageDeliveryModeStrategy)
  • public void CancelFuturePublish(string cancellationKey)
  • public Task CancelFuturePublishAsync(string cancellationKey)
  • public void FuturePublish<T>(DateTime futurePublishDate, T message, string cancellationKey = null)
  • public void FuturePublish<T>(TimeSpan messageDelay, T message, string cancellationKey = null)
  • public Task FuturePublishAsync<T>(DateTime futurePublishDate, T message, string cancellationKey = null)
  • public Task FuturePublishAsync<T>(TimeSpan messageDelay, T message, string cancellationKey = null)
• public class DelayedExchangeScheduler : IScheduler
  • public DelayedExchangeScheduler(IAdvancedBus advancedBus, IConventions conventions, IMessageDeliveryModeStrategy messageDeliveryModeStrategy)
  • public void CancelFuturePublish(string cancellationKey)
  • public Task CancelFuturePublishAsync(string cancellationKey)
  • public void FuturePublish<T>(DateTime futurePublishDate, T message, string cancellationKey = null)
  • public void FuturePublish<T>(TimeSpan messageDelay, T message, string cancellationKey = null)
  • public Task FuturePublishAsync<T>(DateTime futurePublishDate, T message, string cancellationKey = null)
  • public Task FuturePublishAsync<T>(TimeSpan messageDelay, T message, string cancellationKey = null)
• public class ExternalScheduler : IScheduler
  • public ExternalScheduler(IAdvancedBus advancedBus, IConventions conventions, ITypeNameSerializer typeNameSerializer, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IMessageSerializationStrategy messageSerializationStrategy)
  • public void CancelFuturePublish(string cancellationKey)
  • public Task CancelFuturePublishAsync(string cancellationKey)
  • public void FuturePublish<T>(DateTime futurePublishDate, T message, string cancellationKey = null)
  • public void FuturePublish<T>(TimeSpan messageDelay, T message, string cancellationKey = null)
  • public Task FuturePublishAsync<T>(DateTime futurePublishDate, T message, string cancellationKey = null)
  • public Task FuturePublishAsync<T>(TimeSpan messageDelay, T message, string cancellationKey = null)
• public interface IScheduler
  • void CancelFuturePublish(string cancellationKey)
  • Task CancelFuturePublishAsync(string cancellationKey)
  • void FuturePublish<T>(DateTime futurePublishDate, T message, string cancellationKey = null)
  • void FuturePublish<T>(TimeSpan messageDelay, T message, string cancellationKey = null)
  • Task FuturePublishAsync<T>(DateTime futurePublishDate, T message, string cancellationKey = null)
  • Task FuturePublishAsync<T>(TimeSpan messageDelay, T message, string cancellationKey = null)
• public static class SchedulingExtensions
  • public static IServiceRegister EnableDeadLetterExchangeAndMessageTtlScheduler(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableDelayedExchangeScheduler(this IServiceRegister serviceRegister)

EasyNetQ.SystemMessages

• public class ScheduleMe
  • public string Exchange { get; set; }
  • public string ExchangeType { get; set; }
  • public MessageProperties MessageProperties { get; set; }
  • public string RoutingKey { get; set; }

EasyNetQ.Topology

• public static class ExchangeType
  • public ExchangeType()