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

<PackageReference Include="EasyNetQ" Version="8.0.0-beta10" />

---

API Diff between 8.0.0-beta10 and 0.7.0.26

1328 Additions 170 Removals

EasyNetQ

• public class BinarySerializer : ISerializer
• public static class BusExtensions
• public class ComponentRegistration
• public class ConcurrentHashSet<T> : ISet<T>, ICollection<T>, IEnumerable<T>, IEnumerable
• public class AdvancedBusEventHandlers
  • public EventHandler<BlockedEventArgs> Blocked { get; }
  • public EventHandler<ConnectedEventArgs> Connected { get; }
  • public EventHandler<DisconnectedEventArgs> Disconnected { get; }
  • public EventHandler<MessageReturnedEventArgs> MessageReturned { get; }
  • public EventHandler<UnblockedEventArgs> Unblocked { get; }
  • public AdvancedBusEventHandlers(EventHandler<ConnectedEventArgs> connected = null, EventHandler<DisconnectedEventArgs> disconnected = null, EventHandler<BlockedEventArgs> blocked = null, EventHandler<UnblockedEventArgs> unblocked = null, EventHandler<MessageReturnedEventArgs> messageReturned = null)
• public static class AdvancedBusExtensions
  • public static Binding<Exchange> Bind(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, CancellationToken cancellationToken = default)
  • public static Binding<Exchange> Bind(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
  • public static Binding<Queue> Bind(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, CancellationToken cancellationToken = default)
  • public static Binding<Queue> Bind(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
  • public static Task<Binding<Queue>> BindAsync(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
  • public static Task<Binding<Exchange>> BindAsync(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
  • public static Task<Binding<Queue>> BindAsync(this IAdvancedBus bus, Exchange source, Queue queue, string routingKey, CancellationToken cancellationToken = default)
  • public static Task<Binding<Exchange>> BindAsync(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, CancellationToken cancellationToken = default)
  • public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler)
  • public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler, Action<ISimpleConsumeConfiguration> configure)
  • public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, Task> handler)
  • public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, Task> handler, Action<ISimpleConsumeConfiguration> configure)
  • public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> handler, Action<ISimpleConsumeConfiguration> configure)
  • public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, IMessageHandler<T> handler, Action<ISimpleConsumeConfiguration> configure)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<IHandlerRegistration> addHandlers)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<IHandlerRegistration> addHandlers, Action<ISimpleConsumeConfiguration> configure)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo> handler)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo> handler, Action<ISimpleConsumeConfiguration> configure)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task> handler)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task<AckStrategy>> handler)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task> handler, Action<ISimpleConsumeConfiguration> configure)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task<AckStrategy>> handler, Action<ISimpleConsumeConfiguration> configure)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, MessageHandler handler)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler, Action<ISimpleConsumeConfiguration> configure)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler)
  • public static IDisposable Consume(this IAdvancedBus bus, Queue queue, MessageHandler handler, Action<ISimpleConsumeConfiguration> configure)
  • public static Exchange ExchangeDeclare(this IAdvancedBus bus, string exchange, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
  • public static Exchange ExchangeDeclare(this IAdvancedBus bus, string exchange, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • public static Task<Exchange> ExchangeDeclareAsync(this IAdvancedBus bus, string exchange, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
  • public static void ExchangeDeclarePassive(this IAdvancedBus bus, string exchange, CancellationToken cancellationToken = default)
  • public static void ExchangeDelete(this IAdvancedBus bus, Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
  • public static Task ExchangeDeleteAsync(this IAdvancedBus bus, Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
  • public static void ExchangeUnbindAsync(this IAdvancedBus bus, string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
  • public static QueueStats GetQueueStats(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
  • public static void Publish(this IAdvancedBus bus, ref Exchange exchange, string routingKey, bool mandatory, ref MessageProperties messageProperties, ref ReadOnlyMemory body, CancellationToken cancellationToken = default)
  • public static void Publish(this IAdvancedBus bus, string exchange, string routingKey, bool mandatory, ref MessageProperties messageProperties, ref ReadOnlyMemory body, CancellationToken cancellationToken = default)
  • public static Task PublishAsync(this IAdvancedBus bus, ref Exchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken = default)
  • public static Task PublishAsync(this IAdvancedBus bus, ref Exchange exchange, string routingKey, bool mandatory, ref MessageProperties properties, ref ReadOnlyMemory body, CancellationToken cancellationToken = default)
  • public static Queue QueueDeclare(this IAdvancedBus bus, CancellationToken cancellationToken = default)
  • public static Queue QueueDeclare(this IAdvancedBus bus, string queue, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • public static Queue QueueDeclare(this IAdvancedBus bus, string queue, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
  • public static Queue QueueDeclare(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
  • public static Task<Queue> QueueDeclareAsync(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
  • public static Task<Queue> QueueDeclareAsync(this IAdvancedBus bus, string queue, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
  • public static void QueueDeclarePassive(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
  • public static void QueueDelete(this IAdvancedBus bus, string queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
  • public static void QueuePurge(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
  • public static void QueueUnbindAsync(this IAdvancedBus bus, string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
  • public static void Unbind(this IAdvancedBus bus, Binding<Queue> binding, CancellationToken cancellationToken = default)
  • public static void Unbind(this IAdvancedBus bus, Binding<Exchange> binding, CancellationToken cancellationToken = default)
  • public static Task UnbindAsync(this IAdvancedBus bus, Binding<Queue> binding, CancellationToken cancellationToken = default)
  • public static Task UnbindAsync(this IAdvancedBus bus, Binding<Exchange> binding, CancellationToken cancellationToken = default)
• public class BlockedEventArgs : EventArgs
  • public string Reason { get; }
  • public PersistentConnectionType Type { get; }
  • public BlockedEventArgs(PersistentConnectionType type, string reason)
• public class ConnectedEventArgs : EventArgs
  • public string Hostname { get; }
  • public int Port { get; }
  • public PersistentConnectionType Type { get; }
  • public ConnectedEventArgs(PersistentConnectionType type, string hostname, int port)
• public class ConnectionConfiguration
  • public string Host { get; set; }
  • public const int DefaultAmqpsPort = 5671
  • public const int DefaultPort = 5672
  • public IList<IAuthMechanismFactory> AuthMechanisms { get; set; }
  • public IDictionary<string, object> ClientProperties { get; }
  • public TimeSpan ConnectIntervalAttempt { get; set; }
  • public int? ConsumerDispatcherConcurrency { get; set; }
  • public IList<HostConfiguration> Hosts { get; set; }
  • public bool MandatoryPublish { get; set; }
  • public string Name { get; set; }
  • public bool PersistentMessages { get; set; }
  • public string Platform { get; set; }
  • public ushort RequestedHeartbeat { get; set; }
  • public ushort PrefetchCount { get; set; }
  • public string Product { get; set; }
  • public bool PublisherConfirms { get; set; }
  • public ushort RequestedChannelMax { get; set; }
  • public TimeSpan RequestedHeartbeat { get; set; }
  • public SslOption Ssl { get; }
  • public TimeSpan Timeout { get; set; }
• public class ConnectionFactoryWrapper : IConnectionFactory
• public class ConnectionString : IConnectionConfiguration
• public static class ConsumeConfigurationExtensions
  • public static IConsumeConfiguration ForQueue(this IConsumeConfiguration configuration, ref Queue queue, MessageHandler handler)
  • public static IConsumeConfiguration ForQueue(this IConsumeConfiguration configuration, ref Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler)
  • public static IConsumeConfiguration ForQueue(this IConsumeConfiguration configuration, ref Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler, Action<IPerQueueConsumeConfiguration> configure)
  • public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, IMessageHandler<T> handler)
  • public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, IMessageHandler<T> handler, Action<IPerQueueConsumeConfiguration> configure)
  • public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> handler)
  • public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> handler, Action<IPerQueueConsumeConfiguration> configure)
  • public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler)
  • public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler, Action<IPerQueueConsumeConfiguration> configure)
• public struct ConsumedMessage : IEquatable<ConsumedMessage>
  • public ReadOnlyMemory<byte> Body { get; set; }
  • public MessageProperties Properties { get; set; }
  • public MessageReceivedInfo ReceivedInfo { get; set; }
  • public ConsumedMessage(ref MessageReceivedInfo ReceivedInfo, ref MessageProperties Properties, ref ReadOnlyMemory Body)
  • public static bool op_Equality(ConsumedMessage left, ConsumedMessage right)
  • public static bool op_Inequality(ConsumedMessage left, ConsumedMessage right)
  • public void Deconstruct(out MessageReceivedInfo ReceivedInfo, out MessageProperties Properties, out ReadOnlyMemory Body)
  • public bool Equals(ConsumedMessage other)
• public sealed delegate ConsumerTagConvention : MulticastDelegate
  • public ConsumerTagConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke()
• public class Conventions : IConventions
  • public ConsumerTagConvention ConsumerTagConvention { get; set; }
  • public ErrorExchangeNameConvention ErrorExchangeNamingConvention { get; set; }
  • public ErrorExchangeRoutingKeyConvention ErrorExchangeRoutingKeyConvention { get; set; }
  • public ErrorExchangeTypeConvention ErrorExchangeTypeConvention { get; set; }
  • public ErrorQueueNameConvention ErrorQueueNamingConvention { get; set; }
  • public ErrorQueueTypeConvention ErrorQueueTypeConvention { get; set; }
  • public QueueTypeConvention QueueTypeConvention { get; set; }
  • public RpcExchangeNameConvention RpcRequestExchangeNamingConvention { get; set; }
  • public RpcExchangeNameConvention RpcResponseExchangeNamingConvention { get; set; }
  • public RpcReturnQueueNamingConvention RpcReturnQueueNamingConvention { get; set; }
  • public RpcRoutingKeyNamingConvention RpcRoutingKeyNamingConvention { get; set; }
  • public Conventions()
  • public Conventions(ITypeNameSerializer typeNameSerializer)
• public class CorrelationIdGenerator
• public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
• public class DefaultServiceProvider : IServiceProvider, IServiceRegister
• public class EasyNetQConsumer : DefaultBasicConsumer
• public class DeadLetterExchangeAndMessageTtlScheduler : IScheduler
  • public DeadLetterExchangeAndMessageTtlScheduler(ConnectionConfiguration configuration, IAdvancedBus advancedBus, IConventions conventions, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IExchangeDeclareStrategy exchangeDeclareStrategy)
  • public Task FuturePublishAsync<T>(T message, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
• public static class DeadLetterStrategy
  • public const string AtLeastOnce = "at-least-once"
  • public const string AtMostOnce = "at-most-once"
• public class DefaultCorrelationIdGenerationStrategy : ICorrelationIdGenerationStrategy
  • public DefaultCorrelationIdGenerationStrategy()
  • public string GetCorrelationId()
• public class DefaultExchangeDeclareStrategy : IExchangeDeclareStrategy
  • public DefaultExchangeDeclareStrategy(IConventions conventions, IAdvancedBus advancedBus)
  • public Task<Exchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)
  • public Task<Exchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
• public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
  • public DefaultMessageSerializationStrategy(ITypeNameSerializer typeNameSerializer, ISerializer serializer, ICorrelationIdGenerationStrategy correlationIdGenerator)
  • public IMessage DeserializeMessage(ref MessageProperties properties, ref ReadOnlyMemory body)
  • public SerializedMessage SerializeMessage(IMessage message)
• public class DefaultPubSub : IPubSub
  • public DefaultPubSub(ConnectionConfiguration configuration, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IAdvancedBus advancedBus)
  • public virtual Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure, CancellationToken cancellationToken)
  • public virtual AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken)
• public class DefaultRpc : IRpc, IDisposable
  • protected struct ResponseAction
  • protected struct ResponseSubscription
  • protected struct RpcKey : IEquatable<RpcKey>
  • protected const string ExceptionMessageKey = "ExceptionMessage"
  • protected const string IsFaultedKey = "IsFaulted"
  • protected readonly IAdvancedBus advancedBus
  • protected readonly IConventions conventions
  • protected readonly IExchangeDeclareStrategy exchangeDeclareStrategy
  • protected readonly IMessageDeliveryModeStrategy messageDeliveryModeStrategy
  • public DefaultRpc(ILogger<DefaultRpc> logger, ConnectionConfiguration configuration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITypeNameSerializer typeNameSerializer, ICorrelationIdGenerationStrategy correlationIdGenerationStrategy)
  • protected void DeRegisterResponseActions(string correlationId)
  • public void Dispose()
  • protected void RegisterResponseActions<TResponse>(string correlationId, TaskCompletionSource<TResponse> tcs)
  • public virtual Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure, CancellationToken cancellationToken = default)
  • protected virtual Task RequestPublishAsync<TRequest>(TRequest request, string routingKey, string returnQueueName, string correlationId, TimeSpan expiration, byte? priority, bool mandatory, IDictionary<string, object> headers, CancellationToken cancellationToken)
  • public virtual AwaitableDisposable<IDisposable> RespondAsync<TRequest, TResponse>(Func<TRequest, CancellationToken, Task<TResponse>> responder, Action<IResponderConfiguration> configure, CancellationToken cancellationToken = default)
  • protected virtual Task<string> SubscribeToResponseAsync<TRequest, TResponse>(CancellationToken cancellationToken)
• public class DefaultSendReceive : ISendReceive
  • public DefaultSendReceive(ConnectionConfiguration configuration, IConventions conventions, IAdvancedBus advancedBus, IMessageDeliveryModeStrategy messageDeliveryModeStrategy)
  • public AwaitableDisposable<IDisposable> ReceiveAsync(string queue, Action<IReceiveRegistration> addHandlers, Action<IReceiveConfiguration> configure, CancellationToken cancellationToken)
  • public Task SendAsync<T>(string queue, T message, Action<ISendConfiguration> configure, CancellationToken cancellationToken)
• public class DefaultTypeNameSerializer : ITypeNameSerializer
  • public DefaultTypeNameSerializer()
  • public Type Deserialize(string typeName)
  • public string Serialize(Type type)
• public static class DelayedExchangeExtensions
  • public static IExchangeDeclareConfiguration AsDelayedExchange(this IExchangeDeclareConfiguration configuration, string exchangeType = "fanout")
  • public static MessageProperties WithDelay(this ref MessageProperties messageProperties, TimeSpan delay)
• public class DelayedExchangeScheduler : IScheduler
  • public DelayedExchangeScheduler(ConnectionConfiguration configuration, IAdvancedBus advancedBus, IConventions conventions, IMessageDeliveryModeStrategy messageDeliveryModeStrategy)
  • public Task FuturePublishAsync<T>(T message, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
• public class DeliveryModeAttribute : Attribute
  • public bool IsPersistent { get; }
  • public DeliveryModeAttribute(bool isPersistent)
• public class DisconnectedEventArgs : EventArgs
  • public string Hostname { get; }
  • public int Port { get; }
  • public string Reason { get; }
  • public PersistentConnectionType Type { get; }
  • public DisconnectedEventArgs(PersistentConnectionType type, string hostname, int port, string reason)
• public class EasyNetQException : Exception
  • public EasyNetQException(string format, string[] args)
  • public EasyNetQException(string format, object[] args)
• public class EasyNetQInvalidMessageTypeException : EasyNetQException
• public class EasyNetQResponderException : EasyNetQException
  • public EasyNetQResponderException()
  • public EasyNetQResponderException(string message)
  • public EasyNetQResponderException(string format, object[] args)
  • public EasyNetQResponderException(string message, Exception inner)
  • protected EasyNetQResponderException(SerializationInfo info, StreamingContext context)
• public sealed delegate ErrorExchangeNameConvention : MulticastDelegate
  • public ErrorExchangeNameConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(MessageReceivedInfo receivedInfo, AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke(MessageReceivedInfo receivedInfo)
• public sealed delegate ErrorExchangeRoutingKeyConvention : MulticastDelegate
  • public ErrorExchangeRoutingKeyConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(MessageReceivedInfo receivedInfo, AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke(MessageReceivedInfo receivedInfo)
• public sealed delegate ErrorExchangeTypeConvention : MulticastDelegate
  • public ErrorExchangeTypeConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke()
• public sealed delegate ErrorQueueNameConvention : MulticastDelegate
  • public ErrorQueueNameConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(MessageReceivedInfo receivedInfo, AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke(MessageReceivedInfo receivedInfo)
• public sealed delegate ErrorQueueTypeConvention : MulticastDelegate
  • public ErrorQueueTypeConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke()
• public sealed class EventBus : IEventBus
  • public EventBus(ILogger<EventBus> logger)
  • public void Publish<TEvent>(ref TEvent event) where TEvent : struct
  • public IDisposable Subscribe<TEvent>(TEventHandler<TEvent> eventHandler) where TEvent : struct
• public sealed class ExchangeAttribute : Attribute
  • public string Name { get; set; }
  • public ExchangeAttribute()
• public static class ExchangeDeclareConfigurationExtensions
  • public static IExchangeDeclareConfiguration WithAlternateExchange(this IExchangeDeclareConfiguration configuration, ref Exchange alternateExchange)
• public static class ExchangeType
  • public const string Direct = "direct"
  • public const string Fanout = "fanout"
  • public const string Header = "headers"
  • public const string Topic = "topic"
• public class HostConfiguration
  • public string Host { get; }
  • public ushort Port { get; set; }
  • public SslOption Ssl { get; }
  • public HostConfiguration(string host, ushort port)
• public interface IAdvancedBus
  • ISerializer Serializer { get; }
  • SerializeType SerializeType { get; }
  • event Action Connected
  • event Action Disconnected
  • IAdvancedPublishChannel OpenPublishChannel()
  • void Subscribe<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
  • void Subscribe(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
  • event EventHandler<BlockedEventArgs> Blocked
  • event EventHandler<ConnectedEventArgs> Connected
  • event EventHandler<DisconnectedEventArgs> Disconnected
  • event EventHandler<MessageReturnedEventArgs> MessageReturned
  • event EventHandler<UnblockedEventArgs> Unblocked
  • Task ConnectAsync(CancellationToken cancellationToken = default)
  • IDisposable Consume(Action<IConsumeConfiguration> configure)
  • IPullingConsumer<PullResult> CreatePullingConsumer(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, bool autoAck = true)
  • IPullingConsumer<PullResult<T>> CreatePullingConsumer<T>(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, bool autoAck = true)
  • Task ExchangeBindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
  • Task<Exchange> ExchangeDeclareAsync(string exchange, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • Task ExchangeDeclarePassiveAsync(string exchange, CancellationToken cancellationToken = default)
  • Task ExchangeDeleteAsync(string exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
  • Task ExchangeUnbindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
  • Task<QueueStats> GetQueueStatsAsync(string queue, CancellationToken cancellationToken = default)
  • Task PublishAsync(string exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken = default)
  • Task PublishAsync(string exchange, string routingKey, bool mandatory, MessageProperties properties, ReadOnlyMemory<byte> body, CancellationToken cancellationToken = default)
  • Task QueueBindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
  • Task<Queue> QueueDeclareAsync(string queue, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • Task<Queue> QueueDeclareAsync(CancellationToken cancellationToken = default)
  • Task QueueDeclarePassiveAsync(string queue, CancellationToken cancellationToken = default)
  • Task QueueDeleteAsync(string queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
  • Task QueuePurgeAsync(string queue, CancellationToken cancellationToken = default)
  • Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
• public interface IAdvancedPublishChannel : IDisposable
• public interface IBus
  • bool IsConnected { get; }
  • event Action Connected
  • event Action Disconnected
  • IPublishChannel OpenPublishChannel()
  • void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder)
  • void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, IDictionary<string, object> arguments)
  • void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder)
  • void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, IDictionary<string, object> arguments)
  • void Subscribe<T>(string subscriptionId, Action<T> onMessage)
  • void Subscribe<T>(string subscriptionId, Action<T> onMessage, IDictionary<string, object> arguments)
  • void Subscribe<T>(string subscriptionId, string topic, Action<T> onMessage)
  • void Subscribe<T>(string subscriptionId, string topic, Action<T> onMessage, IDictionary<string, object> arguments)
  • void Subscribe<T>(string subscriptionId, IEnumerable<string> topics, Action<T> onMessage)
  • void Subscribe<T>(string subscriptionId, IEnumerable<string> topics, Action<T> onMessage, IDictionary<string, object> arguments)
  • void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
  • void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, IDictionary<string, object> arguments)
  • void SubscribeAsync<T>(string subscriptionId, string topic, Func<T, Task> onMessage)
  • void SubscribeAsync<T>(string subscriptionId, string topic, Func<T, Task> onMessage, IDictionary<string, object> arguments)
  • void SubscribeAsync<T>(string subscriptionId, IEnumerable<string> topics, Func<T, Task> onMessage)
  • void SubscribeAsync<T>(string subscriptionId, IEnumerable<string> topics, Func<T, Task> onMessage, IDictionary<string, object> arguments)
  • IPubSub PubSub { get; }
  • IRpc Rpc { get; }
  • IScheduler Scheduler { get; }
  • ISendReceive SendReceive { get; }
• public interface IConnectionConfiguration
• public interface IConnectionFactory
• public interface IConsumerErrorStrategy : IDisposable
• public interface IConsumerFactory : IDisposable
• public interface IConsumeConfiguration
  • IConsumeConfiguration ForQueue(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, MessageHandler handler, Action<IPerQueueConsumeConfiguration> configure)
  • IConsumeConfiguration ForQueue(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, Action<IHandlerRegistration> register, Action<IPerQueueConsumeConfiguration> configure)
  • IConsumeConfiguration WithPrefetchCount(ushort prefetchCount)
• public interface IConventions
  • ConsumerTagConvention ConsumerTagConvention { get; }
  • ErrorExchangeNameConvention ErrorExchangeNamingConvention { get; }
  • ErrorExchangeRoutingKeyConvention ErrorExchangeRoutingKeyConvention { get; }
  • ErrorExchangeTypeConvention ErrorExchangeTypeConvention { get; }
  • ErrorQueueNameConvention ErrorQueueNamingConvention { get; }
  • ErrorQueueTypeConvention ErrorQueueTypeConvention { get; }
  • QueueTypeConvention QueueTypeConvention { get; }
  • RpcExchangeNameConvention RpcRequestExchangeNamingConvention { get; }
  • RpcExchangeNameConvention RpcResponseExchangeNamingConvention { get; }
  • RpcReturnQueueNamingConvention RpcReturnQueueNamingConvention { get; }
  • RpcRoutingKeyNamingConvention RpcRoutingKeyNamingConvention { get; }
• public interface IEasyNetQLogger
• public interface ICorrelationIdGenerationStrategy
  • string GetCorrelationId()
• public interface IEventBus
  • void Publish<TEvent>(TEvent& modreq(System.Runtime.InteropServices.InAttribute) event) where TEvent : struct
  • IDisposable Subscribe<TEvent>(TEventHandler<TEvent> eventHandler) where TEvent : struct
• public interface IExchangeDeclareConfiguration
  • IExchangeDeclareConfiguration AsAutoDelete(bool isAutoDelete)
  • IExchangeDeclareConfiguration AsDurable(bool isDurable)
  • IExchangeDeclareConfiguration WithArgument(string name, object value)
  • IExchangeDeclareConfiguration WithType(string type)
• public interface IExchangeDeclareStrategy
  • Task<Exchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken = default)
  • Task<Exchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken = default)
• public interface IFuturePublishConfiguration
  • IFuturePublishConfiguration WithHeaders(IDictionary<string, object> headers)
  • IFuturePublishConfiguration WithPriority(byte priority)
  • IFuturePublishConfiguration WithTopic(string topic)
• public interface IMessage
  • Type MessageType { get; }
  • MessageProperties Properties { get; }
  • object GetBody()
• public interface IMessage<T> : IMessage
  • MessageProperties Properties { get; }
• public interface IPersistentConnection : IDisposable
• public interface IPublishChannel : IDisposable
• public interface ISaga
• public interface IMessageDeliveryModeStrategy
  • byte GetDeliveryMode(Type messageType)
• public interface IMessageSerializationStrategy
  • IMessage DeserializeMessage(MessageProperties& modreq(System.Runtime.InteropServices.InAttribute) properties, ReadOnlyMemory body)
  • SerializedMessage SerializeMessage(IMessage message)
• public interface IPerQueueConsumeConfiguration
  • IPerQueueConsumeConfiguration WithArgument(string name, object value)
  • IPerQueueConsumeConfiguration WithAutoAck()
  • IPerQueueConsumeConfiguration WithConsumerTag(string consumerTag)
  • IPerQueueConsumeConfiguration WithExclusive(bool isExclusive = true)
• public interface IPublishConfiguration
  • IPublishConfiguration WithExpires(TimeSpan expires)
  • IPublishConfiguration WithHeaders(IDictionary<string, object> headers)
  • IPublishConfiguration WithPriority(byte priority)
  • IPublishConfiguration WithTopic(string topic)
• public interface IPubSub
  • Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure, CancellationToken cancellationToken = default)
  • AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
• public interface IPullingConsumer<TPullResult> : IDisposable where TPullResult : IPullResult
  • Task AckAsync(ulong deliveryTag, bool multiple, CancellationToken cancellationToken = default)
  • Task<TPullResult> PullAsync(CancellationToken cancellationToken = default)
  • Task RejectAsync(ulong deliveryTag, bool multiple, bool requeue, CancellationToken cancellationToken = default)
• public interface IPullingConsumerFactory
  • IPullingConsumer<PullResult> CreateConsumer(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, PullingConsumerOptions& modreq(System.Runtime.InteropServices.InAttribute) options)
  • IPullingConsumer<PullResult<T>> CreateConsumer<T>(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, PullingConsumerOptions& modreq(System.Runtime.InteropServices.InAttribute) options)
• public interface IPullResult : IDisposable
  • bool IsAvailable { get; }
  • ulong MessagesCount { get; }
  • MessageReceivedInfo ReceivedInfo { get; }
• public interface IQueueDeclareConfiguration
  • IQueueDeclareConfiguration AsAutoDelete(bool isAutoDelete)
  • IQueueDeclareConfiguration AsDurable(bool isDurable)
  • IQueueDeclareConfiguration AsExclusive(bool isExclusive)
  • IQueueDeclareConfiguration WithArgument(string name, object value)
• public interface IReceiveConfiguration
  • IReceiveConfiguration AsExclusive(bool isExclusive = true)
  • IReceiveConfiguration WithAutoDelete(bool autoDelete = true)
  • IReceiveConfiguration WithDurable(bool durable = true)
  • IReceiveConfiguration WithExpires(int expires)
  • IReceiveConfiguration WithMaxLength(int maxLength)
  • IReceiveConfiguration WithMaxLengthBytes(int maxLengthBytes)
  • IReceiveConfiguration WithMaxPriority(byte priority)
  • IReceiveConfiguration WithPrefetchCount(ushort prefetchCount)
  • IReceiveConfiguration WithPriority(int priority)
  • IReceiveConfiguration WithQueueMode(string queueMode = "default")
  • IReceiveConfiguration WithQueueType(string queueType = "classic")
  • IReceiveConfiguration WithSingleActiveConsumer(bool singleActiveConsumer = true)
• public interface IReceiveRegistration
  • IReceiveRegistration Add<T>(Func<T, CancellationToken, Task> onMessage)
• public interface IRequestConfiguration
  • IRequestConfiguration WithExpiration(TimeSpan expiration)
  • IRequestConfiguration WithHeaders(IDictionary<string, object> headers)
  • IRequestConfiguration WithPriority(byte priority)
  • IRequestConfiguration WithQueueName(string queueName)
• public interface IResponderConfiguration
  • IResponderConfiguration WithDurable(bool durable = true)
  • IResponderConfiguration WithExpires(TimeSpan expires)
  • IResponderConfiguration WithMaxPriority(byte priority)
  • IResponderConfiguration WithPrefetchCount(ushort prefetchCount)
  • IResponderConfiguration WithQueueName(string queueName)
• public interface IRpc
  • Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure, CancellationToken cancellationToken = default)
  • AwaitableDisposable<IDisposable> RespondAsync<TRequest, TResponse>(Func<TRequest, CancellationToken, Task<TResponse>> responder, Action<IResponderConfiguration> configure, CancellationToken cancellationToken = default)
• public interface IScheduler
  • Task FuturePublishAsync<T>(T message, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
• public interface ISendConfiguration
  • ISendConfiguration WithHeaders(IDictionary<string, object> headers)
  • ISendConfiguration WithPriority(byte priority)
• public interface ISendReceive
  • AwaitableDisposable<IDisposable> ReceiveAsync(string queue, Action<IReceiveRegistration> addHandlers, Action<IReceiveConfiguration> configure, CancellationToken cancellationToken = default)
  • Task SendAsync<T>(string queue, T message, Action<ISendConfiguration> configure, CancellationToken cancellationToken = default)
• public interface ISerializer
  • T BytesToMessage<T>(byte[] bytes)
  • byte[] MessageToBytes<T>(T message)
  • object BytesToMessage(Type messageType, ReadOnlyMemory bytes)
  • IMemoryOwner<byte> MessageToBytes(Type messageType, object message)
• public interface IServiceProvider
• public interface IServiceRegister
• public interface ISimpleConsumeConfiguration
  • ISimpleConsumeConfiguration WithArgument(string name, object value)
  • ISimpleConsumeConfiguration WithAutoAck()
  • ISimpleConsumeConfiguration WithConsumerTag(string consumerTag)
  • ISimpleConsumeConfiguration WithExclusive(bool isExclusive = true)
  • ISimpleConsumeConfiguration WithPrefetchCount(ushort prefetchCount)
• public interface ISubscriptionConfiguration
  • ISubscriptionConfiguration AsExclusive(bool isExclusive = true)
  • ISubscriptionConfiguration WithAlternateExchange(string alternateExchange)
  • ISubscriptionConfiguration WithAutoDelete(bool autoDelete = true)
  • ISubscriptionConfiguration WithDurable(bool durable = true)
  • ISubscriptionConfiguration WithExchangeType(string exchangeType)
  • ISubscriptionConfiguration WithExpires(int expires)
  • ISubscriptionConfiguration WithMaxLength(int maxLength)
  • ISubscriptionConfiguration WithMaxLengthBytes(int maxLengthBytes)
  • ISubscriptionConfiguration WithMaxPriority(byte priority)
  • ISubscriptionConfiguration WithPrefetchCount(ushort prefetchCount)
  • ISubscriptionConfiguration WithPriority(int priority)
  • ISubscriptionConfiguration WithQueueMode(string queueMode = "default")
  • ISubscriptionConfiguration WithQueueName(string queueName)
  • ISubscriptionConfiguration WithQueueType(string queueType = "classic")
  • ISubscriptionConfiguration WithSingleActiveConsumer(bool singleActiveConsumer = true)
  • ISubscriptionConfiguration WithTopic(string topic)
• public interface ITypeNameSerializer
  • Type Deserialize(string typeName)
  • string Serialize(Type type)
• public class JsonSerializer : ISerializer
  • public JsonSerializer()
  • public T BytesToMessage<T>(byte[] bytes)
  • public byte[] MessageToBytes<T>(T message)
  • public JsonSerializer(object serializerSettings = null)
  • public object BytesToMessage(Type messageType, ref ReadOnlyMemory bytes)
  • public IMemoryOwner<byte> MessageToBytes(Type messageType, object message)
• public class LegacyRpcConventions : Conventions
  • public LegacyRpcConventions(ITypeNameSerializer typeNameSerializer)
• public class LegacyTypeNameSerializer : ITypeNameSerializer
  • public LegacyTypeNameSerializer()
  • public Type Deserialize(string typeName)
  • public string Serialize(Type type)
• public class Message<T> : IMessage<T>, IMessage
  • public Type MessageType { get; }
  • public void SetProperties(MessageProperties properties)
  • public Message()
  • public Message(T body, ref MessageProperties properties)
  • public object GetBody()
• public sealed delegate MessageCallback : MulticastDelegate
• 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, ref MessageProperties properties)
• public struct MessageProperties : IEquatable<MessageProperties>
  • public static MessageProperties Empty { get; }
  • public bool AppIdPresent { get; }
  • public bool ClusterIdPresent { get; }
  • public bool ContentEncodingPresent { get; }
  • public bool ContentTypePresent { get; }
  • public bool CorrelationIdPresent { get; }
  • public string Expiration { get; set; }
  • public IDictionary Headers { get; set; }
  • public bool DeliveryModePresent { get; }
  • public TimeSpan? Expiration { get; set; }
  • public bool ExpirationPresent { get; }
  • public IDictionary<string, object> Headers { get; set; }
  • public bool HeadersPresent { get; }
  • public bool MessageIdPresent { get; }
  • public bool PriorityPresent { get; }
  • public bool ReplyToPresent { get; }
  • public bool TimestampPresent { get; }
  • public bool TypePresent { get; }
  • public MessageProperties()
  • public MessageProperties(IBasicProperties basicProperties)
  • public void CopyFrom(IBasicProperties basicProperties)
  • public void CopyTo(IBasicProperties basicProperties)
  • public bool UserIdPresent { get; }
  • public static bool op_Equality(MessageProperties left, MessageProperties right)
  • public static bool op_Inequality(MessageProperties left, MessageProperties right)
  • public bool Equals(MessageProperties other)
• public static class MessagePropertiesExtensions
  • public static void CopyTo(this ref MessageProperties source, IBasicProperties basicProperties)
  • public static MessageProperties SetHeader(this ref MessageProperties source, string key, object value)
• public struct MessageReceivedInfo : IEquatable<MessageReceivedInfo>
  • public ulong DeliverTag { get; set; }
  • public ulong DeliveryTag { get; set; }
  • public string Queue { get; set; }
  • public MessageReceivedInfo()
  • public MessageReceivedInfo(string ConsumerTag, ulong DeliveryTag, bool Redelivered, string Exchange, string RoutingKey, string Queue)
  • public static bool op_Equality(MessageReceivedInfo left, MessageReceivedInfo right)
  • public static bool op_Inequality(MessageReceivedInfo left, MessageReceivedInfo right)
  • public void Deconstruct(out string ConsumerTag, out ulong DeliveryTag, out bool Redelivered, out string Exchange, out string RoutingKey, out string Queue)
  • public bool Equals(MessageReceivedInfo other)
• public class PersistentConnection : IPersistentConnection, IDisposable
• public class QueueingConsumerFactory : IConsumerFactory, IDisposable
• public class MessageReturnedEventArgs : EventArgs
  • public ReadOnlyMemory<byte> MessageBody { get; }
  • public MessageProperties MessageProperties { get; }
  • public MessageReturnedInfo MessageReturnedInfo { get; }
  • public MessageReturnedEventArgs(ref ReadOnlyMemory messageBody, ref MessageProperties messageProperties, ref MessageReturnedInfo messageReturnedInfo)
• public struct MessageReturnedInfo
  • public string Exchange { get; }
  • public string ReturnReason { get; }
  • public string RoutingKey { get; }
  • public MessageReturnedInfo(string exchange, string routingKey, string returnReason)
• public static class NonGenericPubSubExtensions
  • public static void Publish(this IPubSub pubSub, object message, Type messageType, CancellationToken cancellationToken = default)
  • public static void Publish(this IPubSub pubSub, object message, Type messageType, Action<IPublishConfiguration> configure, CancellationToken cancellationToken = default)
  • public static void Publish(this IPubSub pubSub, object message, Type messageType, string topic, CancellationToken cancellationToken = default)
  • public static Task PublishAsync(this IPubSub pubSub, object message, Type messageType, CancellationToken cancellationToken = default)
  • public static Task PublishAsync(this IPubSub pubSub, object message, Type messageType, string topic, CancellationToken cancellationToken = default)
  • public static Task PublishAsync(this IPubSub pubSub, object message, Type messageType, Action<IPublishConfiguration> configure, CancellationToken cancellationToken = default)
  • public static SubscriptionResult Subscribe(this IPubSub pubSub, string subscriptionId, Type messageType, Func<object, Type, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<SubscriptionResult> SubscribeAsync(this IPubSub pubSub, string subscriptionId, Type messageType, Func<object, Type, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
• public static class NonGenericRpcExtensions
  • public static object Request(this IRpc rpc, object request, Type requestType, Type responseType, CancellationToken cancellationToken = default)
  • public static object Request(this IRpc rpc, object request, Type requestType, Type responseType, Action<IRequestConfiguration> configure, CancellationToken cancellationToken = default)
  • public static Task<object> RequestAsync(this IRpc rpc, object request, Type requestType, Type responseType, CancellationToken cancellationToken = default)
  • public static Task<object> RequestAsync(this IRpc rpc, object request, Type requestType, Type responseType, Action<IRequestConfiguration> configure, CancellationToken cancellationToken = default)
• public static class NonGenericSchedulerExtensions
  • public static void FuturePublish(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, string topic, CancellationToken cancellationToken = default)
  • public static void FuturePublish(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, CancellationToken cancellationToken = default)
  • public static void FuturePublish(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
  • public static Task FuturePublishAsync(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, CancellationToken cancellationToken = default)
  • public static Task FuturePublishAsync(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
• public static class NonGenericSendReceiveExtensions
  • public static void Send(this ISendReceive sendReceive, string queue, object message, Type messageType, CancellationToken cancellationToken = default)
  • public static void Send(this ISendReceive sendReceive, string queue, object message, Type messageType, Action<ISendConfiguration> configure, CancellationToken cancellationToken = default)
  • public static Task SendAsync(this ISendReceive sendReceive, string queue, object message, Type messageType, CancellationToken cancellationToken = default)
  • public static Task SendAsync(this ISendReceive sendReceive, string queue, object message, Type messageType, Action<ISendConfiguration> configure, CancellationToken cancellationToken = default)
• public static class OverflowType
  • public const string DropHead = "drop-head"
  • public const string RejectPublish = "reject-publish"
  • public const string RejectPublishDlx = "reject-publish-dlx"
• public static class PerQueueConsumeConfigurationExtensions
  • public static IPerQueueConsumeConfiguration WithArguments(this IPerQueueConsumeConfiguration configuration, IDictionary<string, object> arguments)
  • public static IPerQueueConsumeConfiguration WithPriority(this IPerQueueConsumeConfiguration configuration, int priority)
• public struct ProducedMessage : IEquatable<ProducedMessage>
  • public ReadOnlyMemory<byte> Body { get; set; }
  • public MessageProperties Properties { get; set; }
  • public ProducedMessage(ref MessageProperties Properties, ref ReadOnlyMemory Body)
  • public static bool op_Equality(ProducedMessage left, ProducedMessage right)
  • public static bool op_Inequality(ProducedMessage left, ProducedMessage right)
  • public void Deconstruct(out MessageProperties Properties, out ReadOnlyMemory Body)
  • public bool Equals(ProducedMessage other)
• public static class PubSubExtensions
  • public static void Publish<T>(this IPubSub pubSub, T message, CancellationToken cancellationToken = default)
  • public static void Publish<T>(this IPubSub pubSub, T message, Action<IPublishConfiguration> configure, CancellationToken cancellationToken = default)
  • public static void Publish<T>(this IPubSub pubSub, T message, string topic, CancellationToken cancellationToken = default)
  • public static Task PublishAsync<T>(this IPubSub pubSub, T message, CancellationToken cancellationToken = default)
  • public static Task PublishAsync<T>(this IPubSub pubSub, T message, string topic, CancellationToken cancellationToken = default)
  • public static SubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, CancellationToken cancellationToken = default)
  • public static SubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
  • public static SubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
  • public static SubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
• public struct PullBatchResult<TPullResult> : IDisposable where TPullResult : IPullResult
  • public ulong DeliveryTag { get; }
  • public IReadOnlyList<TPullResult> Messages { get; }
  • public PullBatchResult(IReadOnlyList<TPullResult> messages)
  • public void Dispose()
• public class PullingConsumer : IPullingConsumer<PullResult>, IDisposable
  • public PullingConsumer(ref PullingConsumerOptions options, ref Queue queue, IPersistentChannel channel, IProduceConsumeInterceptor[] produceConsumeInterceptors)
  • public Task AckAsync(ulong deliveryTag, bool multiple, CancellationToken cancellationToken = default)
  • public void Dispose()
  • public Task<PullResult> PullAsync(CancellationToken cancellationToken = default)
  • public Task RejectAsync(ulong deliveryTag, bool multiple, bool requeue, CancellationToken cancellationToken = default)
• public class PullingConsumer<T> : IPullingConsumer<PullResult<T>>, IDisposable
  • public PullingConsumer(IPullingConsumer<PullResult> consumer, IMessageSerializationStrategy messageSerializationStrategy)
  • public Task AckAsync(ulong deliveryTag, bool multiple, CancellationToken cancellationToken = default)
  • public void Dispose()
  • public Task<PullResult<T>> PullAsync(CancellationToken cancellationToken = default)
  • public Task RejectAsync(ulong deliveryTag, bool multiple, bool requeue, CancellationToken cancellationToken = default)
• public static class PullingConsumerExtensions
  • public static Task AckAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, ulong deliveryTag, CancellationToken cancellationToken = default) where TPullResult : IPullResult
  • public static Task AckBatchAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, ulong deliveryTag, CancellationToken cancellationToken = default) where TPullResult : IPullResult
  • public static Task<PullBatchResult<TPullResult>> PullBatchAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, int batchSize, CancellationToken cancellationToken = default) where TPullResult : IPullResult
  • public static Task RejectAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, ulong deliveryTag, bool requeue = false, CancellationToken cancellationToken = default) where TPullResult : IPullResult
  • public static Task RejectBatchAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, ulong deliveryTag, bool requeue = false, CancellationToken cancellationToken = default) where TPullResult : IPullResult
• public class PullingConsumerFactory : IPullingConsumerFactory
  • public PullingConsumerFactory(IConsumerConnection connection, IPersistentChannelFactory channelFactory, IEnumerable<IProduceConsumeInterceptor> produceConsumeInterceptors, IMessageSerializationStrategy messageSerializationStrategy)
  • public IPullingConsumer<PullResult> CreateConsumer(ref Queue queue, ref PullingConsumerOptions options)
  • public IPullingConsumer<PullResult<T>> CreateConsumer<T>(ref Queue queue, ref PullingConsumerOptions options)
• public struct PullingConsumerOptions
  • public bool AutoAck { get; }
  • public TimeSpan Timeout { get; }
  • public PullingConsumerOptions(bool autoAck, TimeSpan timeout)
• public struct PullResult : IPullResult, IDisposable
  • public static PullResult NotAvailable { get; }
  • public ReadOnlyMemory<byte> Body { get; }
  • public bool IsAvailable { get; }
  • public ulong MessagesCount { get; }
  • public MessageProperties Properties { get; }
  • public MessageReceivedInfo ReceivedInfo { get; }
  • public static PullResult Available(ulong messagesCount, ref MessageReceivedInfo receivedInfo, ref MessageProperties properties, ref ReadOnlyMemory body, IDisposable disposable)
  • public void Dispose()
• public struct PullResult<T> : IPullResult, IDisposable
  • public static PullResult<T> NotAvailable { get; }
  • public bool IsAvailable { get; }
  • public IMessage<T> Message { get; }
  • public ulong MessagesCount { get; }
  • public MessageReceivedInfo ReceivedInfo { get; }
  • public static PullResult<T> Available(ulong messagesCount, MessageReceivedInfo receivedInfo, IMessage<T> message)
  • public void Dispose()
• public sealed class QueueAttribute : Attribute
  • public string Name { get; set; }
  • public string Type { get; set; }
  • public QueueAttribute()
• public static class QueueDeclareConfigurationExtensions
  • public static IQueueDeclareConfiguration WithDeadLetterExchange(this IQueueDeclareConfiguration configuration, Exchange deadLetterExchange)
  • public static IQueueDeclareConfiguration WithDeadLetterRoutingKey(this IQueueDeclareConfiguration configuration, string deadLetterRoutingKey)
  • public static IQueueDeclareConfiguration WithDeadLetterStrategy(this IQueueDeclareConfiguration configuration, string deadLetterStrategy = "at-most-once")
  • public static IQueueDeclareConfiguration WithExpires(this IQueueDeclareConfiguration configuration, TimeSpan expires)
  • public static IQueueDeclareConfiguration WithMaxLength(this IQueueDeclareConfiguration configuration, int maxLength)
  • public static IQueueDeclareConfiguration WithMaxLengthBytes(this IQueueDeclareConfiguration configuration, int maxLengthBytes)
  • public static IQueueDeclareConfiguration WithMaxPriority(this IQueueDeclareConfiguration configuration, int maxPriority)
  • public static IQueueDeclareConfiguration WithMessageTtl(this IQueueDeclareConfiguration configuration, TimeSpan messageTtl)
  • public static IQueueDeclareConfiguration WithOverflowType(this IQueueDeclareConfiguration configuration, string overflowType = "drop-head")
  • public static IQueueDeclareConfiguration WithQueueMasterLocator(this IQueueDeclareConfiguration configuration, string queueMasterLocator = "min-masters")
  • public static IQueueDeclareConfiguration WithQueueMode(this IQueueDeclareConfiguration configuration, string queueMode = "default")
  • public static IQueueDeclareConfiguration WithQueueType(this IQueueDeclareConfiguration configuration, string queueType = "classic")
  • public static IQueueDeclareConfiguration WithSingleActiveConsumer(this IQueueDeclareConfiguration configuration, bool singleActiveConsumer = true)
• public static class QueueMasterLocator
  • public const string ClientLocal = "client-local"
  • public const string MinMasters = "min-masters"
  • public const string Random = "random"
• public static class QueueMode
  • public const string Default = "default"
  • public const string Lazy = "lazy"
• public struct QueueStats
  • public ulong ConsumersCount { get; }
  • public ulong MessagesCount { get; }
  • public QueueStats(ulong messagesCount, ulong consumersCount)
• public static class QueueType
  • public const string Classic = "classic"
  • public const string Quorum = "quorum"
  • public const string Stream = "stream"
• public sealed delegate QueueTypeConvention : MulticastDelegate
  • public QueueTypeConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke(Type messageType)
• public class RabbitAdvancedBus : IAdvancedBus, IDisposable
  • public const bool NoAck = false
  • public IPersistentConnection Connection { get; }
  • public IConsumerFactory ConsumerFactory { get; }
  • public IConventions Conventions { get; }
  • public Func<string> GetCorrelationId { get; }
  • public IEasyNetQLogger Logger { get; }
  • public ISerializer Serializer { get; }
  • public SerializeType SerializeType { get; }
  • public event Action Connected
  • public event Action Disconnected
  • public RabbitAdvancedBus(IConnectionFactory connectionFactory, SerializeType serializeType, ISerializer serializer, IConsumerFactory consumerFactory, IEasyNetQLogger logger, Func<string> getCorrelationId, IConventions conventions)
  • 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, ConnectionConfiguration configuration, ProducePipelineBuilder producePipelineBuilder, ConsumePipelineBuilder consumePipelineBuilder, IServiceResolver serviceResolver, IMessageSerializationStrategy messageSerializationStrategy, IPullingConsumerFactory pullingConsumerFactory, AdvancedBusEventHandlers advancedBusEventHandlers)
  • 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)
  • protected void OnConnected()
  • protected void OnDisconnected()
  • public IAdvancedPublishChannel OpenPublishChannel()
  • public void Subscribe<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
  • public void Subscribe(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
  • public virtual Task ExchangeBindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
  • public Task<Exchange> ExchangeDeclareAsync(string exchange, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • public Task ExchangeDeclarePassiveAsync(string exchange, CancellationToken cancellationToken = default)
  • public virtual Task ExchangeDeleteAsync(string 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 queue, CancellationToken cancellationToken)
  • public virtual Task PublishAsync(string exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken)
  • public virtual Task PublishAsync(string exchange, string routingKey, bool mandatory, MessageProperties properties, ReadOnlyMemory<byte> body, CancellationToken cancellationToken)
  • public virtual Task QueueBindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
  • public Task<Queue> QueueDeclareAsync(CancellationToken cancellationToken)
  • public Task<Queue> QueueDeclareAsync(string queue, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • public Task QueueDeclarePassiveAsync(string queue, CancellationToken cancellationToken = default)
  • public virtual Task QueueDeleteAsync(string queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
  • public virtual Task QueuePurgeAsync(string queue, CancellationToken cancellationToken)
  • public virtual Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
• public class RabbitAdvancedPublishChannel : IAdvancedPublishChannel, IDisposable
• public class RabbitBus : IBus
  • public const string RpcExchange = "easy_net_q_rpc"
  • public IConventions Conventions { get; }
  • public bool IsConnected { get; }
  • public IEasyNetQLogger Logger { get; }
  • public SerializeType SerializeType { get; }
  • public event Action Connected
  • public event Action Disconnected
  • public RabbitBus(SerializeType serializeType, IEasyNetQLogger logger, IConventions conventions, IAdvancedBus advancedBus)
  • public void Dispose()
  • protected void OnConnected()
  • protected void OnDisconnected()
  • public IPublishChannel OpenPublishChannel()
  • public void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder)
  • public void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, IDictionary<string, object> arguments)
  • public void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder)
  • public void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, IDictionary<string, object> arguments)
  • public void Subscribe<T>(string subscriptionId, Action<T> onMessage)
  • public void Subscribe<T>(string subscriptionId, Action<T> onMessage, IDictionary<string, object> arguments)
  • public void Subscribe<T>(string subscriptionId, string topic, Action<T> onMessage)
  • public void Subscribe<T>(string subscriptionId, string topic, Action<T> onMessage, IDictionary<string, object> arguments)
  • public void Subscribe<T>(string subscriptionId, IEnumerable<string> topics, Action<T> onMessage)
  • public void Subscribe<T>(string subscriptionId, IEnumerable<string> topics, Action<T> onMessage, IDictionary<string, object> arguments)
  • public void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
  • public void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, IDictionary<string, object> arguments)
  • public void SubscribeAsync<T>(string subscriptionId, string topic, Func<T, Task> onMessage)
  • public void SubscribeAsync<T>(string subscriptionId, string topic, Func<T, Task> onMessage, IDictionary<string, object> arguments)
  • public void SubscribeAsync<T>(string subscriptionId, IEnumerable<string> topics, Func<T, Task> onMessage)
  • public void SubscribeAsync<T>(string subscriptionId, IEnumerable<string> topics, Func<T, Task> onMessage, IDictionary<string, object> arguments)
  • public IPubSub PubSub { get; }
  • public IRpc Rpc { get; }
  • public IScheduler Scheduler { get; }
  • public ISendReceive SendReceive { get; }
  • public RabbitBus(IAdvancedBus advanced, IPubSub pubSub, IRpc rpc, ISendReceive sendReceive, IScheduler scheduler)
• public static class RabbitHutch
  • public static IBus CreateBus(string connectionString)
  • public static IBus CreateBus(string connectionString, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, ushort requestedHeartbeat, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(IConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus()
  • public static SelfHostedBus CreateBus(string connectionString)
  • public static SelfHostedBus CreateBus(string connectionString, Action<IServiceRegister> registerServices)
  • public static SelfHostedBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, TimeSpan requestedHeartbeat, Action<IServiceRegister> registerServices)
  • public static SelfHostedBus CreateBus(ConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
  • public static SelfHostedBus CreateBus(Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory, Action<IServiceRegister> registerServices)
  • public static void RegisterBus(IServiceRegister serviceRegister, Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory, Action<IServiceRegister> registerServices)
• public class RabbitPublishChannel : IPublishChannel, IDisposable
• public sealed delegate SerializeType : MulticastDelegate
• public class SubscriptionAction
• public class SubscriptionInfo
• public sealed delegate SubsriberNameFromDelegate : MulticastDelegate
• public static class ReceiveRegistrationExtensions
  • public static IReceiveRegistration Add<T>(this IReceiveRegistration receiveRegistration, Func<T, Task> onMessage)
  • public static IReceiveRegistration Add<T>(this IReceiveRegistration receiveRegistration, Action<T> onMessage)
• public sealed delegate RpcExchangeNameConvention : MulticastDelegate
  • public RpcExchangeNameConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke(Type messageType)
• public static class RpcExtensions
  • public static TResponse Request<TRequest, TResponse>(this IRpc rpc, TRequest request, CancellationToken cancellationToken = default)
  • public static TResponse Request<TRequest, TResponse>(this IRpc rpc, TRequest request, Action<IRequestConfiguration> configure, CancellationToken cancellationToken = default)
  • public static Task<TResponse> RequestAsync<TRequest, TResponse>(this IRpc rpc, TRequest request, CancellationToken cancellationToken = default)
  • public static IDisposable Respond<TRequest, TResponse>(this IRpc rpc, Func<TRequest, Task<TResponse>> responder, CancellationToken cancellationToken = default)
  • public static IDisposable Respond<TRequest, TResponse>(this IRpc rpc, Func<TRequest, TResponse> responder, CancellationToken cancellationToken = default)
  • public static IDisposable Respond<TRequest, TResponse>(this IRpc rpc, Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure, CancellationToken cancellationToken = default)
  • public static IDisposable Respond<TRequest, TResponse>(this IRpc rpc, Func<TRequest, CancellationToken, Task<TResponse>> responder, Action<IResponderConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> RespondAsync<TRequest, TResponse>(this IRpc rpc, Func<TRequest, TResponse> responder, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> RespondAsync<TRequest, TResponse>(this IRpc rpc, Func<TRequest, Task<TResponse>> responder, CancellationToken cancellationToken = default)
• public sealed delegate RpcReturnQueueNamingConvention : MulticastDelegate
  • public RpcReturnQueueNamingConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke(Type messageType)
• public sealed delegate RpcRoutingKeyNamingConvention : MulticastDelegate
  • public RpcRoutingKeyNamingConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke(Type messageType)
• public static class SchedulerExtensions
  • public static void FuturePublish<T>(this IScheduler scheduler, T message, TimeSpan delay, string topic, CancellationToken cancellationToken = default)
  • public static void FuturePublish<T>(this IScheduler scheduler, T message, TimeSpan delay, CancellationToken cancellationToken = default)
  • public static Task FuturePublishAsync<T>(this IScheduler scheduler, T message, TimeSpan delay, CancellationToken cancellationToken = default)
• public sealed class SelfHostedBus : IBus, IDisposable
  • public IAdvancedBus Advanced { get; }
  • public IPubSub PubSub { get; }
  • public IRpc Rpc { get; }
  • public IScheduler Scheduler { get; }
  • public ISendReceive SendReceive { get; }
  • public void Dispose()
• public static class SendReceiveExtensions
  • public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, CancellationToken cancellationToken = default)
  • public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, Action<IReceiveConfiguration> configure, CancellationToken cancellationToken = default)
  • public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
  • public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Func<T, CancellationToken, Task> onMessage, Action<IReceiveConfiguration> configure, CancellationToken cancellationToken = default)
  • public static IDisposable Receive(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, CancellationToken cancellationToken = default)
  • public static IDisposable Receive(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, Action<IReceiveConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Func<T, CancellationToken, Task> onMessage, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Func<T, CancellationToken, Task> onMessage, Action<IReceiveConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, Action<IReceiveConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Func<T, Task> onMessage, Action<IReceiveConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, CancellationToken cancellationToken = default)
  • public static void Send<T>(this ISendReceive sendReceive, string queue, T message, CancellationToken cancellationToken = default)
  • public static void Send<T>(this ISendReceive sendReceive, string queue, T message, Action<ISendConfiguration> configure, CancellationToken cancellationToken = default)
  • public static Task SendAsync<T>(this ISendReceive sendReceive, string queue, T message, CancellationToken cancellationToken = default)
• public struct SerializedMessage : IDisposable
  • public ReadOnlyMemory<byte> Body { get; }
  • public MessageProperties Properties { get; }
  • public SerializedMessage(ref MessageProperties properties, IMemoryOwner<byte> body)
  • public void Dispose()
• public static class ServiceRegisterExtensions
  • public static IServiceRegister EnableAdvancedMessagePolymorphism(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableAlwaysAckConsumerErrorStrategy(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableAlwaysNackWithoutRequeueConsumerErrorStrategy(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableAlwaysNackWithRequeueConsumerErrorStrategy(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableConsoleLogger(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableDelayedExchangeScheduler(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableLegacyConventions(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableLegacyRpcConventions(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableLegacyTypeNaming(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableMessageVersioning(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableMultiChannelClientCommandDispatcher(this IServiceRegister serviceRegister, int channelsCount)
  • public static void RegisterDefaultServices(this IServiceRegister serviceRegister, Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory)
  • public static ConsumePipelineBuilder UseConsumeErrorStrategy(this ConsumePipelineBuilder pipelineBuilder)
  • public static ConsumePipelineBuilder UseConsumeInterceptors(this ConsumePipelineBuilder pipelineBuilder)
  • public static ProducePipelineBuilder UseProduceInterceptors(this ProducePipelineBuilder pipelineBuilder)
  • public static ConsumePipelineBuilder UseScope(this ConsumePipelineBuilder pipelineBuilder)
• public static class SimpleConsumeConfigurationExtensions
  • public static ISimpleConsumeConfiguration WithPriority(this ISimpleConsumeConfiguration configuration, int priority)
• public struct SubscriptionResult : IDisposable
  • public Exchange Exchange { get; }
  • public Queue Queue { get; }
  • public SubscriptionResult(ref Exchange exchange, ref Queue queue, IDisposable consumerCancellation)
  • public void Dispose()
• public sealed delegate TEventHandler<TEvent> : MulticastDelegate where TEvent : struct
  • public TEventHandler(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(TEvent& modreq(System.Runtime.InteropServices.InAttribute) event, AsyncCallback callback, object object)
  • public virtual void EndInvoke(TEvent& modreq(System.Runtime.InteropServices.InAttribute) event, IAsyncResult result)
  • public virtual void Invoke(TEvent& modreq(System.Runtime.InteropServices.InAttribute) event)
• public class TypeNameSerializer
• public class UnblockedEventArgs : EventArgs
  • public PersistentConnectionType Type { get; }
  • public UnblockedEventArgs(PersistentConnectionType type)

EasyNetQ.AutoSubscribe

• public class AutoSubscriber
  • protected readonly IBus Bus
  • public static string DefaultTopicName { get; set; }
  • public IAutoSubscriberMessageDispatcher AutoSubscriberMessageDispatcher { get; set; }
  • protected Action<ISubscriptionConfiguration> ConfigureSubscriptionConfiguration { get; set; }
  • protected Func<AutoSubscriberConsumerInfo, string> GenerateSubscriptionId { get; set; }
  • public string SubscriptionIdPrefix { get; }
  • public AutoSubscriber(IBus bus, string subscriptionIdPrefix)
  • protected virtual string DefaultSubscriptionIdGenerator(AutoSubscriberConsumerInfo c)
  • protected virtual IEnumerable<AutoSubscriberConsumerInfo> GetSubscriberConsumerInfos(IEnumerable<Type> types, Type interfaceType)
  • protected virtual AutoSubscriberConsumerAttribute GetSubscriptionAttribute(AutoSubscriberConsumerInfo consumerInfo)
  • public virtual Task<IDisposable> SubscribeAsync(Type[] consumerTypes, CancellationToken cancellationToken = default)
• public class AutoSubscriberConsumerAttribute : Attribute
  • public string SubscriptionId { get; set; }
  • public AutoSubscriberConsumerAttribute()
• public class AutoSubscriberConsumerInfo
  • public Type ConcreteType { get; }
  • public MethodInfo ConsumeMethod { get; }
  • public Type MessageType { get; }
  • public AutoSubscriberConsumerInfo(Type concreteType, Type interfaceType, Type messageType)
• public static class AutoSubscriberExtensions
  • public static IDisposable Subscribe(this AutoSubscriber autoSubscriber, Assembly[] assemblies, CancellationToken cancellationToken = default)
  • public static IDisposable Subscribe(this AutoSubscriber autoSubscriber, Type[] consumerTypes, CancellationToken cancellationToken = default)
  • public static Task<IDisposable> SubscribeAsync(this AutoSubscriber autoSubscriber, Assembly[] assemblies, CancellationToken cancellationToken = default)
• public class DefaultAutoSubscriberMessageDispatcher : IAutoSubscriberMessageDispatcher
  • public DefaultAutoSubscriberMessageDispatcher(IServiceResolver resolver)
  • public DefaultAutoSubscriberMessageDispatcher()
  • public void Dispatch<TMessage, TConsumer>(TMessage message, CancellationToken cancellationToken = default) where TConsumer : IConsume<TMessage>
  • public Task DispatchAsync<TMessage, TAsyncConsumer>(TMessage message, CancellationToken cancellationToken = default) where TAsyncConsumer : IConsumeAsync<TMessage>
• public class ForTopicAttribute : Attribute
  • public string Topic { get; set; }
  • public ForTopicAttribute(string topic)
• public interface IAutoSubscriberMessageDispatcher
  • void Dispatch<TMessage, TConsumer>(TMessage message, CancellationToken cancellationToken = default) where TConsumer : IConsume<TMessage>
  • Task DispatchAsync<TMessage, TConsumer>(TMessage message, CancellationToken cancellationToken = default) where TConsumer : IConsumeAsync<TMessage>
• public interface IConsume<T>
  • void Consume(T message, CancellationToken cancellationToken = default)
• public interface IConsumeAsync<T>
  • Task ConsumeAsync(T message, CancellationToken cancellationToken = default)
• public class SubscriptionConfigurationAttribute : Attribute
  • public bool AutoDelete { get; set; }
  • public int Expires { get; set; }
  • public ushort PrefetchCount { get; set; }
  • public int Priority { get; set; }
  • public SubscriptionConfigurationAttribute()

EasyNetQ.ChannelDispatcher

• public interface IPersistentChannelDispatcher
  • ValueTask<TResult> InvokeAsync<TResult, TChannelAction>(TChannelAction channelAction, PersistentChannelDispatchOptions options, CancellationToken cancellationToken = default) where TChannelAction : struct, IPersistentChannelAction<TResult>
• public sealed class MultiPersistentChannelDispatcher : IPersistentChannelDispatcher, IDisposable
  • public MultiPersistentChannelDispatcher(int channelsCount, IProducerConnection producerConnection, IConsumerConnection consumerConnection, IPersistentChannelFactory channelFactory)
  • public void Dispose()
  • public ValueTask<TResult> InvokeAsync<TResult, TChannelAction>(TChannelAction channelAction, PersistentChannelDispatchOptions options, CancellationToken cancellationToken = default) where TChannelAction : struct, IPersistentChannelAction<TResult>
• public class PersistentChannelDispatchOptions
  • public static readonly PersistentChannelDispatchOptions ConsumerTopology
  • public static readonly PersistentChannelDispatchOptions ProducerPublish
  • public static readonly PersistentChannelDispatchOptions ProducerPublishWithConfirms
  • public static readonly PersistentChannelDispatchOptions ProducerTopology
  • public PersistentConnectionType ConnectionType { get; }
  • public string Name { get; }
  • public bool PublisherConfirms { get; }
  • protected bool Equals(PersistentChannelDispatchOptions other)
• public sealed class SinglePersistentChannelDispatcher : IPersistentChannelDispatcher, IDisposable
  • public SinglePersistentChannelDispatcher(IProducerConnection producerConnection, IConsumerConnection consumerConnection, IPersistentChannelFactory channelFactory)
  • public void Dispose()
  • public ValueTask<TResult> InvokeAsync<TResult, TChannelAction>(TChannelAction channelAction, PersistentChannelDispatchOptions options, CancellationToken cancellationToken = default) where TChannelAction : struct, IPersistentChannelAction<TResult>

EasyNetQ.ConnectionString

• public class AmqpConnectionStringParser : IConnectionStringParser
  • public AmqpConnectionStringParser()
  • public ConnectionConfiguration Parse(string connectionString)
• public class ConnectionStringParser : IConnectionStringParser
  • public ConnectionStringParser()
  • public ConnectionConfiguration Parse(string connectionString)
• public interface IConnectionStringParser
  • ConnectionConfiguration Parse(string connectionString)

EasyNetQ.Consumer

• public static class AckStrategies
  • public static readonly AckStrategy Ack
  • public static readonly AckStrategy NackWithoutRequeue
  • public static readonly AckStrategy NackWithRequeue
• public sealed delegate AckStrategy : MulticastDelegate
  • public AckStrategy(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(IModel model, ulong deliveryTag, AsyncCallback callback, object object)
  • public virtual AckResult EndInvoke(IAsyncResult result)
  • public virtual AckResult Invoke(IModel model, ulong deliveryTag)
• public class Base64ErrorMessageSerializer : IErrorMessageSerializer
  • public Base64ErrorMessageSerializer()
  • public byte[] Deserialize(string messageBody)
  • public string Serialize(byte[] messageBody)
• public struct ConsumeContext : IEquatable<ConsumeContext>
  • public ReadOnlyMemory<byte> Body { get; set; }
  • public CancellationToken CancellationToken { get; set; }
  • public MessageProperties Properties { get; set; }
  • public MessageReceivedInfo ReceivedInfo { get; set; }
  • public IServiceResolver ServiceResolver { get; set; }
  • public ConsumeContext(ref MessageReceivedInfo ReceivedInfo, ref MessageProperties Properties, ref ReadOnlyMemory Body, ref IServiceResolver ServiceResolver, ref CancellationToken CancellationToken)
  • public static bool op_Equality(ConsumeContext left, ConsumeContext right)
  • public static bool op_Inequality(ConsumeContext left, ConsumeContext right)
  • public void Deconstruct(out MessageReceivedInfo ReceivedInfo, out MessageProperties Properties, out ReadOnlyMemory Body, out IServiceResolver ServiceResolver, out CancellationToken CancellationToken)
  • public bool Equals(ConsumeContext other)
• public sealed delegate ConsumeDelegate : MulticastDelegate
  • public ConsumeDelegate(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(ConsumeContext context, AsyncCallback callback, object object)
  • public virtual ValueTask<AckStrategy> EndInvoke(IAsyncResult result)
  • public virtual ValueTask<AckStrategy> Invoke(ConsumeContext context)
• public sealed class ConsumePipelineBuilder
  • public ConsumePipelineBuilder()
  • public ConsumeDelegate Build()
  • public ConsumePipelineBuilder Use(Func<ConsumeDelegate, ConsumeDelegate> middleware)
• public class Consumer : IConsumer, IDisposable
  • public Guid Id { get; }
  • public Consumer(ILogger<Consumer> logger, ConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
  • public void Dispose()
  • public void StartConsuming()
• public class ConsumerConfiguration
  • public IReadOnlyDictionary<Queue, PerQueueConsumerConfiguration> PerQueueConfigurations { get; }
  • public ushort PrefetchCount { get; }
  • public ConsumerConfiguration(ushort prefetchCount, IReadOnlyDictionary<Queue, PerQueueConsumerConfiguration> perQueueConfigurations)
• public sealed class ConsumerConnection : PersistentConnection, IConsumerConnection, IPersistentConnection, IDisposable
  • public ConsumerConnection(ILogger<ConsumerConnection> logger, ConnectionConfiguration configuration, IConnectionFactory connectionFactory, IEventBus eventBus)
• public class ConsumerFactory : IConsumerFactory, IDisposable
  • public ConsumerFactory(ILogger<Consumer> logger, IEventBus eventBus, IInternalConsumerFactory internalConsumerFactory)
  • public IConsumer CreateConsumer(ConsumerConfiguration configuration)
  • public void Dispose()
• public class DefaultConsumeErrorStrategy : IConsumeErrorStrategy
  • public DefaultConsumeErrorStrategy(ILogger<DefaultConsumeErrorStrategy> logger, IConsumerConnection connection, ISerializer serializer, IConventions conventions, ITypeNameSerializer typeNameSerializer, IErrorMessageSerializer errorMessageSerializer, ConnectionConfiguration configuration)
  • public virtual ValueTask<AckStrategy> HandleCancelledAsync(ConsumeContext context)
  • public virtual ValueTask<AckStrategy> HandleErrorAsync(ConsumeContext context, Exception exception)
• public class DefaultErrorMessageSerializer : IErrorMessageSerializer
  • public DefaultErrorMessageSerializer()
  • public byte[] Deserialize(string messageBody)
  • public string Serialize(byte[] messageBody)
• public class HandlerCollection : IHandlerCollection, IHandlerRegistration
  • public bool ThrowOnNoMatchingHandler { get; set; }
  • public HandlerCollection()
  • public IHandlerRegistration Add<T>(IMessageHandler<T> handler)
  • public IMessageHandler GetHandler(Type messageType)
• public class HandlerCollectionFactory : IHandlerCollectionFactory
  • public HandlerCollectionFactory()
  • public IHandlerCollection CreateHandlerCollection(ref Queue queue)
• public class HandlerCollectionPerQueueFactory : IHandlerCollectionFactory
  • public HandlerCollectionPerQueueFactory()
  • public IHandlerCollection CreateHandlerCollection(ref Queue queue)
• public static class HandlerRegistrationExtensions
  • public static IHandlerRegistration Add<T>(this IHandlerRegistration handlerRegistration, Action<IMessage<T>, MessageReceivedInfo> handler)
  • public static IHandlerRegistration Add<T>(this IHandlerRegistration handlerRegistration, Func<IMessage<T>, MessageReceivedInfo, Task> handler)
  • public static IHandlerRegistration Add<T>(this IHandlerRegistration handlerRegistration, Func<IMessage<T>, MessageReceivedInfo, Task<AckStrategy>> handler)
  • public static IHandlerRegistration Add<T>(this IHandlerRegistration handlerRegistration, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> handler)
• public interface IConsumeErrorStrategy
  • ValueTask<AckStrategy> HandleCancelledAsync(ConsumeContext context)
  • ValueTask<AckStrategy> HandleErrorAsync(ConsumeContext context, Exception exception)
• public interface IConsumer : IDisposable
  • Guid Id { get; }
  • void StartConsuming()
• public interface IConsumerConnection : IPersistentConnection, IDisposable
• public interface IConsumerFactory : IDisposable
  • IConsumer CreateConsumer(ConsumerConfiguration configuration)
• public interface IErrorMessageSerializer
  • byte[] Deserialize(string messageBody)
  • string Serialize(byte[] messageBody)
• public interface IHandlerCollection : IHandlerRegistration
  • IMessageHandler GetHandler(Type messageType)
• public interface IHandlerCollectionFactory
  • IHandlerCollection CreateHandlerCollection(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue)
• public interface IHandlerRegistration
  • IHandlerRegistration Add<T>(IMessageHandler<T> handler)
• public interface IInternalConsumer : IDisposable
  • event EventHandler<InternalConsumerCancelledEventArgs> Cancelled
  • InternalConsumerStatus StartConsuming(bool firstStart = true)
  • void StopConsuming()
• public interface IInternalConsumerFactory
  • IInternalConsumer CreateConsumer(ConsumerConfiguration configuration)
• public sealed delegate IMessageHandler : MulticastDelegate
  • public IMessageHandler(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(IMessage message, MessageReceivedInfo receivedInfo, CancellationToken cancellationToken, AsyncCallback callback, object object)
  • public virtual Task<AckStrategy> EndInvoke(IAsyncResult result)
  • public virtual Task<AckStrategy> Invoke(IMessage message, MessageReceivedInfo receivedInfo, CancellationToken cancellationToken)
• public sealed delegate IMessageHandler<T> : MulticastDelegate
  • public IMessageHandler(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(IMessage<T> message, MessageReceivedInfo receivedInfo, CancellationToken cancellationToken, AsyncCallback callback, object object)
  • public virtual Task<AckStrategy> EndInvoke(IAsyncResult result)
  • public virtual Task<AckStrategy> Invoke(IMessage<T> message, MessageReceivedInfo receivedInfo, CancellationToken cancellationToken)
• public class InternalConsumer : IInternalConsumer, IDisposable
  • public event EventHandler<InternalConsumerCancelledEventArgs> Cancelled
  • public InternalConsumer(IServiceResolver serviceResolver, ILogger<InternalConsumer> logger, ConsumerConfiguration configuration, IConsumerConnection connection, IEventBus eventBus)
  • public void Dispose()
  • public InternalConsumerStatus StartConsuming(bool firstStart)
  • public void StopConsuming()
• public class InternalConsumerCancelledEventArgs : EventArgs
  • public IReadOnlyCollection<Queue> Active { get; }
  • public Queue Cancelled { get; }
  • public InternalConsumerCancelledEventArgs(ref Queue cancelled, IReadOnlyCollection<Queue> active)
• public class InternalConsumerFactory : IInternalConsumerFactory
  • public InternalConsumerFactory(IServiceResolver serviceResolver, ILogger<InternalConsumer> logger, IConsumerConnection connection, IEventBus eventBus)
  • public IInternalConsumer CreateConsumer(ConsumerConfiguration configuration)
• public struct InternalConsumerStatus
  • public IReadOnlyCollection<Queue> Active { get; }
  • public IReadOnlyCollection<Queue> Failed { get; }
  • public IReadOnlyCollection<Queue> Started { get; }
  • public InternalConsumerStatus(IReadOnlyCollection<Queue> started, IReadOnlyCollection<Queue> active, IReadOnlyCollection<Queue> failed)
• public sealed delegate MessageHandler : MulticastDelegate
  • public MessageHandler(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(ReadOnlyMemory<byte> body, MessageProperties properties, MessageReceivedInfo receivedInfo, CancellationToken cancellationToken, AsyncCallback callback, object object)
  • public virtual Task<AckStrategy> EndInvoke(IAsyncResult result)
  • public virtual Task<AckStrategy> Invoke(ReadOnlyMemory<byte> body, MessageProperties properties, MessageReceivedInfo receivedInfo, CancellationToken cancellationToken)
• public class PerQueueConsumerConfiguration
  • public IDictionary<string, object> Arguments { get; }
  • public bool AutoAck { get; }
  • public ConsumeDelegate ConsumeDelegate { get; }
  • public string ConsumerTag { get; }
  • public bool IsExclusive { get; }
  • public PerQueueConsumerConfiguration(bool autoAck, string consumerTag, bool isExclusive, IDictionary<string, object> arguments, ConsumeDelegate consumeDelegate)
• public sealed class SimpleConsumeErrorStrategy : IConsumeErrorStrategy
  • public static readonly SimpleConsumeErrorStrategy Ack
  • public static readonly SimpleConsumeErrorStrategy NackWithoutRequeue
  • public static readonly SimpleConsumeErrorStrategy NackWithRequeue
  • public ValueTask<AckStrategy> HandleCancelledAsync(ConsumeContext context)
  • public ValueTask<AckStrategy> HandleErrorAsync(ConsumeContext context, Exception exception)

EasyNetQ.DI

• public struct AsyncServiceResolverScope : IServiceResolverScope, IServiceResolver, IDisposable, IAsyncDisposable
  • public AsyncServiceResolverScope(IServiceResolverScope serviceResolverScope)
  • public IServiceResolverScope CreateScope()
  • public void Dispose()
  • public ValueTask DisposeAsync()
  • public TService Resolve<TService>()
• public interface IServiceRegister
  • IServiceRegister Register(Type serviceType, Type implementationType, Lifetime lifetime = 1)
  • IServiceRegister Register(Type serviceType, Func<IServiceResolver, object> implementationFactory, Lifetime lifetime = 1)
  • IServiceRegister Register(Type serviceType, object implementationInstance)
  • IServiceRegister TryRegister(Type serviceType, Type implementationType, Lifetime lifetime = 1)
  • IServiceRegister TryRegister(Type serviceType, Func<IServiceResolver, object> implementationFactory, Lifetime lifetime = 1)
  • IServiceRegister TryRegister(Type serviceType, object implementationInstance)
• public interface IServiceResolver
  • IServiceResolverScope CreateScope()
  • TService Resolve<TService>()
• public interface IServiceResolverScope : IServiceResolver, IDisposable
• public enum Lifetime
  • Singleton = 1
  • Transient = 0
• public static class ServiceRegisterExtensions
  • public static IServiceRegister Register<TService>(this IServiceRegister services, Lifetime lifetime = 1)
  • public static IServiceRegister Register<TService, TImplementation>(this IServiceRegister services, Lifetime lifetime = 1) where TImplementation : TService
  • public static IServiceRegister Register<TService>(this IServiceRegister services, Func<IServiceResolver, TService> implementationFactory, Lifetime lifetime = 1)
  • public static IServiceRegister Register<TService, TImplementation>(this IServiceRegister services, Func<IServiceResolver, TImplementation> implementationFactory, Lifetime lifetime = 1) where TImplementation : TService
  • public static IServiceRegister Register<TService>(this IServiceRegister services, TService implementationInstance)
  • public static IServiceRegister TryRegister<TService, TImplementation>(this IServiceRegister services, Lifetime lifetime = 1)
  • public static IServiceRegister TryRegister<TService, TImplementation>(this IServiceRegister services, Func<IServiceResolver, TImplementation> implementationFactory, Lifetime lifetime = 1) where TImplementation : TService
  • public static IServiceRegister TryRegister<TService>(this IServiceRegister services, Func<IServiceResolver, TService> implementationFactory, Lifetime lifetime = 1)
  • public static IServiceRegister TryRegister<TService>(this IServiceRegister services, TService implementationInstance)
• public class ServiceResolverScope : IServiceResolverScope, IServiceResolver, IDisposable
  • public ServiceResolverScope(IServiceResolver resolver)
  • public IServiceResolverScope CreateScope()
  • public void Dispose()
  • public TService Resolve<TService>()

EasyNetQ.Events

• public struct AckEvent
  • public AckResult AckResult { get; }
  • public ReadOnlyMemory<byte> Body { get; }
  • public MessageProperties Properties { get; }
  • public MessageReceivedInfo ReceivedInfo { get; }
  • public AckEvent(ref MessageReceivedInfo info, ref MessageProperties properties, ref ReadOnlyMemory body, AckResult ackResult)
• public enum AckResult
  • Ack = 0
  • Exception = 2
  • Nack = 1
• public struct ChannelRecoveredEvent
  • public IModel Channel { get; }
  • public ChannelRecoveredEvent(IModel channel)
• public struct ChannelShutdownEvent
  • public IModel Channel { get; }
  • public ChannelShutdownEvent(IModel channel)
• public struct ConnectionBlockedEvent
  • public string Reason { get; }
  • public PersistentConnectionType Type { get; }
  • public ConnectionBlockedEvent(PersistentConnectionType type, string reason)
• public struct ConnectionCreatedEvent
  • public AmqpTcpEndpoint Endpoint { get; }
  • public PersistentConnectionType Type { get; }
  • public ConnectionCreatedEvent(PersistentConnectionType type, AmqpTcpEndpoint endpoint)
• public struct ConnectionDisconnectedEvent
  • public AmqpTcpEndpoint Endpoint { get; }
  • public string Reason { get; }
  • public PersistentConnectionType Type { get; }
  • public ConnectionDisconnectedEvent(PersistentConnectionType type, AmqpTcpEndpoint endpoint, string reason)
• public struct ConnectionRecoveredEvent
  • public AmqpTcpEndpoint Endpoint { get; }
  • public PersistentConnectionType Type { get; }
  • public ConnectionRecoveredEvent(PersistentConnectionType type, AmqpTcpEndpoint endpoint)
• public struct ConnectionUnblockedEvent
  • public PersistentConnectionType Type { get; }
  • public ConnectionUnblockedEvent(PersistentConnectionType type)
• public struct ConsumerModelDisposedEvent
  • public IReadOnlyCollection<string> ConsumerTags { get; }
  • public ConsumerModelDisposedEvent(string[] consumerTags)
• public struct DeliveredMessageEvent
  • public ReadOnlyMemory<byte> Body { get; }
  • public MessageProperties Properties { get; }
  • public MessageReceivedInfo ReceivedInfo { get; }
  • public DeliveredMessageEvent(ref MessageReceivedInfo info, ref MessageProperties properties, ref ReadOnlyMemory body)
• public struct MessageConfirmationEvent
  • public IModel Channel { get; }
  • public ulong DeliveryTag { get; }
  • public bool IsNack { get; }
  • public bool Multiple { get; }
  • public static MessageConfirmationEvent Ack(IModel channel, ulong deliveryTag, bool multiple)
  • public static MessageConfirmationEvent Nack(IModel channel, ulong deliveryTag, bool multiple)
• public struct PublishedMessageEvent
  • public ReadOnlyMemory<byte> Body { get; }
  • public string Exchange { get; }
  • public MessageProperties Properties { get; }
  • public string RoutingKey { get; }
  • public PublishedMessageEvent(string exchange, string routingKey, ref MessageProperties properties, ref ReadOnlyMemory body)
• public struct ReturnedMessageEvent
  • public ReadOnlyMemory<byte> Body { get; }
  • public IModel Channel { get; }
  • public MessageReturnedInfo Info { get; }
  • public MessageProperties Properties { get; }
  • public ReturnedMessageEvent(IModel channel, ref ReadOnlyMemory body, ref MessageProperties properties, ref MessageReturnedInfo info)
• public struct StartConsumingFailedEvent
  • public IConsumer Consumer { get; }
  • public Queue Queue { get; }
  • public StartConsumingFailedEvent(IConsumer consumer, ref Queue queue)
• public struct StartConsumingSucceededEvent
  • public IConsumer Consumer { get; }
  • public Queue Queue { get; }
  • public StartConsumingSucceededEvent(IConsumer consumer, ref Queue queue)
• public struct StoppedConsumingEvent
  • public IConsumer Consumer { get; }
  • public StoppedConsumingEvent(IConsumer consumer)

EasyNetQ.Interception

• public class CompositeProduceConsumerInterceptor : IProduceConsumeInterceptor
  • public CompositeProduceConsumerInterceptor(IEnumerable<IProduceConsumeInterceptor> interceptors)
  • public ConsumedMessage OnConsume(ref ConsumedMessage message)
  • public ProducedMessage OnProduce(ref ProducedMessage message)
• public class GZipInterceptor : IProduceConsumeInterceptor
  • public GZipInterceptor()
  • public ConsumedMessage OnConsume(ref ConsumedMessage message)
  • public ProducedMessage OnProduce(ref ProducedMessage message)
• public interface IProduceConsumeInterceptor
  • ConsumedMessage OnConsume(ConsumedMessage& modreq(System.Runtime.InteropServices.InAttribute) message)
  • ProducedMessage OnProduce(ProducedMessage& modreq(System.Runtime.InteropServices.InAttribute) message)
• public class TripleDESInterceptor : IProduceConsumeInterceptor
  • public TripleDESInterceptor(byte[] key, byte[] iv)
  • public ConsumedMessage OnConsume(ref ConsumedMessage message)
  • public ProducedMessage OnProduce(ref ProducedMessage message)

EasyNetQ.Internals

• public sealed class ArrayPooledMemoryStream : Stream, IMemoryOwner<byte>, IDisposable
  • public Memory<byte> Memory { get; }
  • public ArrayPooledMemoryStream()
• public sealed class AsyncCache<TKey, TValue> : IDisposable
  • public AsyncCache(Func<TKey, CancellationToken, Task<TValue>> valueFactory)
  • public void Dispose()
  • public Task<TValue> GetOrAddAsync(TKey key, CancellationToken cancellationToken = default)
• public sealed class AsyncCountdownEvent : IDisposable
  • public AsyncCountdownEvent()
  • public void Decrement()
  • public void Dispose()
  • public void Increment()
  • public void Wait()
• public struct AsyncLock : IDisposable
  • public struct Releaser : IDisposable
  • public AsyncLock()
  • public Releaser Acquire(CancellationToken cancellationToken = default)
  • public Task<Releaser> AcquireAsync(CancellationToken cancellationToken = default)
  • public void Dispose()
  • public bool TryAcquire(out Releaser result)
• public sealed class AsyncQueue<T> : IDisposable
  • public int Count { get; }
  • public AsyncQueue()
  • public AsyncQueue(IEnumerable<T> collection)
  • public Task<T> DequeueAsync(CancellationToken cancellationToken = default)
  • public void Dispose()
  • public void Enqueue(T element)
  • public bool TryDequeue(out T element)
• public struct AwaitableDisposable<T> where T : IDisposable
  • public AwaitableDisposable(Task<T> task)
  • public static Task<T> op_Implicit(AwaitableDisposable<T> source)
  • public Task<T> AsTask()
  • public ConfiguredTaskAwaitable<T> ConfigureAwait(bool continueOnCapturedContext)
  • public TaskAwaiter<T> GetAwaiter()
• public static class AwaitableDisposableExtensions
  • public static AwaitableDisposable<T> ToAwaitableDisposable<T>(this Task<T> source) where T : IDisposable
• public static class CancellationTokenExtensions
  • public struct ValueCancellationTokenSource : IDisposable
  • public static ValueCancellationTokenSource WithTimeout(this CancellationToken cancellationToken, TimeSpan timeout)
• public static class ConcurrentDictionaryExtensions
  • public static void ClearAndDispose<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> source) where TValue : IDisposable
  • public static void ClearAndDispose<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> source, Action<TValue> dispose)
  • public static void Remove<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> source, TKey key)
• public static class DictionaryExtensions
  • public static string Stringify(this IDictionary<string, object> source)
• public static class DisposableAction
  • public static DisposableAction<TState> Create<TState>(Action<TState> action, TState state)
• public struct DisposableAction<TState> : IDisposable
  • public DisposableAction(Action<TState> action, TState state)
  • public void Dispose()
• public sealed class EmptyMemoryOwner : IMemoryOwner<byte>, IDisposable
  • public static readonly EmptyMemoryOwner Instance
  • public Memory<byte> Memory { get; }
  • public EmptyMemoryOwner()
  • public void Dispose()
• public sealed class ReadOnlyMemoryStream : Stream
  • public ReadOnlyMemoryStream(ref ReadOnlyMemory content)
• public static class ReflectionHelpers
  • public static TAttribute GetAttribute<TAttribute>(this Type type) where TAttribute : Attribute
  • public static IEnumerable<TAttribute> GetAttributes<TAttribute>(this Type type) where TAttribute : Attribute
• public static class StringExtensions
  • public static string Trim(this string s, int start, int length)
• public static class TaskHelpers
  • public static void AttachCancellation<T>(this TaskCompletionSource<T> taskCompletionSource, CancellationToken cancellationToken)
  • public static Func<T1, T2, T3, CancellationToken, Task> FromAction<T1, T2, T3>(Action<T1, T2, T3, CancellationToken> action)
  • public static Func<T1, T2, CancellationToken, Task> FromAction<T1, T2>(Action<T1, T2, CancellationToken> action)
  • public static Func<T1, CancellationToken, Task> FromAction<T1>(Action<T1, CancellationToken> action)
  • public static Func<T1, CancellationToken, Task<T2>> FromFunc<T1, T2>(Func<T1, CancellationToken, T2> func)
• public static class Timers
  • public static IDisposable Start(Action callback, TimeSpan dueTime, TimeSpan period, ILogger logger)
• public static class UriExtensions
  • public static Dictionary<string, string> ParseQuery(this Uri uri)

EasyNetQ.Loggers

• public class ConsoleLogger : IEasyNetQLogger

EasyNetQ.Logging

• public sealed class ConsoleLogger<TCategoryName> : ILogger<TCategoryName>, ILogger
  • public ConsoleLogger()
  • public bool Log(LogLevel logLevel, Func<string> messageFunc, Exception exception = null, object[] formatParameters)
• public interface ILogger
  • bool Log(LogLevel logLevel, Func<string> messageFunc, Exception exception = null, object[] formatParameters)
• public interface ILogger<TCategoryName> : ILogger
• public static class LoggerExtensions
  • public static void Debug(this ILogger logger, Func<string> messageFunc)
  • public static void Debug(this ILogger logger, string message)
  • public static void Debug(this ILogger logger, string message, object[] args)
  • public static void Debug(this ILogger logger, Exception exception, string message, object[] args)
  • public static void DebugException(this ILogger logger, string message, Exception exception)
  • public static void DebugException(this ILogger logger, string message, Exception exception, object[] args)
  • public static void DebugFormat(this ILogger logger, string message, object[] args)
  • public static void Error(this ILogger logger, Func<string> messageFunc)
  • public static void Error(this ILogger logger, string message)
  • public static void Error(this ILogger logger, string message, object[] args)
  • public static void Error(this ILogger logger, Exception exception, string message, object[] args)
  • public static void ErrorException(this ILogger logger, string message, Exception exception, object[] args)
  • public static void ErrorFormat(this ILogger logger, string message, object[] args)
  • public static void Fatal(this ILogger logger, Func<string> messageFunc)
  • public static void Fatal(this ILogger logger, string message)
  • public static void Fatal(this ILogger logger, string message, object[] args)
  • public static void Fatal(this ILogger logger, Exception exception, string message, object[] args)
  • public static void FatalException(this ILogger logger, string message, Exception exception, object[] args)
  • public static void FatalFormat(this ILogger logger, string message, object[] args)
  • public static void Info(this ILogger logger, Func<string> messageFunc)
  • public static void Info(this ILogger logger, string message)
  • public static void Info(this ILogger logger, string message, object[] args)
  • public static void Info(this ILogger logger, Exception exception, string message, object[] args)
  • public static void InfoException(this ILogger logger, string message, Exception exception, object[] args)
  • public static void InfoFormat(this ILogger logger, string message, object[] args)
  • public static bool IsDebugEnabled(this ILogger logger)
  • public static bool IsErrorEnabled(this ILogger logger)
  • public static bool IsFatalEnabled(this ILogger logger)
  • public static bool IsInfoEnabled(this ILogger logger)
  • public static bool IsTraceEnabled(this ILogger logger)
  • public static bool IsWarnEnabled(this ILogger logger)
  • public static void Trace(this ILogger logger, Func<string> messageFunc)
  • public static void Trace(this ILogger logger, string message)
  • public static void Trace(this ILogger logger, string message, object[] args)
  • public static void Trace(this ILogger logger, Exception exception, string message, object[] args)
  • public static void TraceException(this ILogger logger, string message, Exception exception, object[] args)
  • public static void TraceFormat(this ILogger logger, string message, object[] args)
  • public static void Warn(this ILogger logger, Func<string> messageFunc)
  • public static void Warn(this ILogger logger, string message)
  • public static void Warn(this ILogger logger, string message, object[] args)
  • public static void Warn(this ILogger logger, Exception exception, string message, object[] args)
  • public static void WarnException(this ILogger logger, string message, Exception exception, object[] args)
  • public static void WarnFormat(this ILogger logger, string message, object[] args)
• public enum LogLevel
  • Debug = 1
  • Error = 4
  • Fatal = 5
  • Info = 2
  • Trace = 0
  • Warn = 3
• public sealed class NoopLogger<TCategoryName> : ILogger<TCategoryName>, ILogger
  • public NoopLogger()
  • public bool Log(LogLevel logLevel, Func<string> messageFunc, Exception exception = null, object[] formatParameters)

EasyNetQ.MessageVersioning

• public interface ISupersede<T>
• public class MessageTypeProperty
  • public static MessageTypeProperty CreateForMessageType(Type messageType, ITypeNameSerializer typeNameSerializer)
  • public static MessageTypeProperty ExtractFromProperties(MessageProperties messageProperties, ITypeNameSerializer typeNameSerializer)
  • public MessageProperties AppendTo(ref MessageProperties messageProperties)
  • public Type GetMessageType()
• public class MessageVersionStack : IEnumerable<Type>, IEnumerable
  • public MessageVersionStack(Type messageType)
  • public IEnumerator<Type> GetEnumerator()
  • public bool IsEmpty()
  • public Type Pop()
• public class VersionedExchangeDeclareStrategy : IExchangeDeclareStrategy
  • public VersionedExchangeDeclareStrategy(IConventions conventions, IAdvancedBus advancedBus)
  • public Task<Exchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)
  • public Task<Exchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
• public class VersionedMessageSerializationStrategy : IMessageSerializationStrategy
  • public VersionedMessageSerializationStrategy(ITypeNameSerializer typeNameSerializer, ISerializer serializer, ICorrelationIdGenerationStrategy correlationIdGenerator)
  • public IMessage DeserializeMessage(ref MessageProperties properties, ref ReadOnlyMemory body)
  • public SerializedMessage SerializeMessage(IMessage message)

EasyNetQ.MultipleExchange

• public class MultipleExchangeDeclareStrategy : IExchangeDeclareStrategy
  • public MultipleExchangeDeclareStrategy(IConventions conventions, IAdvancedBus advancedBus)
  • public Task<Exchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
  • public Task<Exchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)

EasyNetQ.Persistent

• public struct ActionBasedPersistentChannelAction : IPersistentChannelAction<bool>
  • public ActionBasedPersistentChannelAction(Action<IModel> action)
  • public bool Invoke(IModel model)
• public struct FuncBasedPersistentChannelAction<TResult> : IPersistentChannelAction<TResult>
  • public FuncBasedPersistentChannelAction(Func<IModel, TResult> func)
  • public TResult Invoke(IModel model)
• public interface IPersistentChannel : IDisposable
  • ValueTask<TResult> InvokeChannelActionAsync<TResult, TChannelAction>(TChannelAction channelAction, CancellationToken cancellationToken = default) where TChannelAction : struct, IPersistentChannelAction<TResult>
• public interface IPersistentChannelAction<TResult>
  • TResult Invoke(IModel model)
• public interface IPersistentChannelFactory
  • IPersistentChannel CreatePersistentChannel(IPersistentConnection connection, PersistentChannelOptions options)
• public interface IPersistentConnection : IDisposable
  • bool IsConnected { get; }
  • void Connect()
  • IModel CreateModel()
• public class PersistentChannel : IPersistentChannel, IDisposable
  • public PersistentChannel(ref PersistentChannelOptions options, ILogger<PersistentChannel> logger, IPersistentConnection connection, IEventBus eventBus)
  • public void Dispose()
  • public ValueTask<TResult> InvokeChannelActionAsync<TResult, TChannelAction>(TChannelAction channelAction, CancellationToken cancellationToken = default) where TChannelAction : struct, IPersistentChannelAction<TResult>
• public class PersistentChannelFactory : IPersistentChannelFactory
  • public PersistentChannelFactory(ILogger<PersistentChannel> logger, IEventBus eventBus)
  • public IPersistentChannel CreatePersistentChannel(IPersistentConnection connection, PersistentChannelOptions options)
• public struct PersistentChannelOptions
  • public bool PublisherConfirms { get; }
  • public PersistentChannelOptions(bool publisherConfirms)
• public class PersistentConnection : IPersistentConnection, IDisposable
  • public bool IsConnected { get; }
  • public PersistentConnection(PersistentConnectionType type, ILogger<IPersistentConnection> logger, ConnectionConfiguration configuration, IConnectionFactory connectionFactory, IEventBus eventBus)
  • public void Connect()
  • public IModel CreateModel()
  • public void Dispose()
• public enum PersistentConnectionType
  • Consumer = 1
  • Producer = 0

EasyNetQ.Producer

• public interface IProducerConnection : IPersistentConnection, IDisposable
• public interface IPublishConfirmationListener : IDisposable
  • IPublishPendingConfirmation CreatePendingConfirmation(IModel model)
• public interface IPublishPendingConfirmation
  • ulong Id { get; }
  • void Cancel()
  • Task WaitAsync(CancellationToken cancellationToken = default)
• public struct ProduceContext : IEquatable<ProduceContext>
  • public ReadOnlyMemory<byte> Body { get; set; }
  • public CancellationToken CancellationToken { get; set; }
  • public string Exchange { get; set; }
  • public bool Mandatory { get; set; }
  • public MessageProperties Properties { get; set; }
  • public string RoutingKey { get; set; }
  • public IServiceResolver ServiceResolver { get; set; }
  • public ProduceContext(ref string Exchange, ref string RoutingKey, ref bool Mandatory, ref MessageProperties Properties, ref ReadOnlyMemory Body, ref IServiceResolver ServiceResolver, ref CancellationToken CancellationToken)
  • public static bool op_Equality(ProduceContext left, ProduceContext right)
  • public static bool op_Inequality(ProduceContext left, ProduceContext right)
  • public void Deconstruct(out string Exchange, out string RoutingKey, out bool Mandatory, out MessageProperties Properties, out ReadOnlyMemory Body, out IServiceResolver ServiceResolver, out CancellationToken CancellationToken)
  • public bool Equals(ProduceContext other)
• public sealed delegate ProduceDelegate : MulticastDelegate
  • public ProduceDelegate(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(ProduceContext context, AsyncCallback callback, object object)
  • public virtual ValueTask EndInvoke(IAsyncResult result)
  • public virtual ValueTask Invoke(ProduceContext context)
• public sealed class ProducePipelineBuilder
  • public ProducePipelineBuilder()
  • public ProduceDelegate Build()
  • public ProducePipelineBuilder Use(Func<ProduceDelegate, ProduceDelegate> middleware)
• public sealed class ProducerConnection : PersistentConnection, IProducerConnection, IPersistentConnection, IDisposable
  • public ProducerConnection(ILogger<ProducerConnection> logger, ConnectionConfiguration configuration, IConnectionFactory connectionFactory, IEventBus eventBus)
• public class PublishConfirmationListener : IPublishConfirmationListener, IDisposable
  • public PublishConfirmationListener(IEventBus eventBus)
  • public IPublishPendingConfirmation CreatePendingConfirmation(IModel model)
  • public void Dispose()
• public class PublishInterruptedException : Exception
  • public PublishInterruptedException()
  • public PublishInterruptedException(string message)
  • public PublishInterruptedException(string message, Exception inner)
  • protected PublishInterruptedException(SerializationInfo info, StreamingContext context)
• public class PublishNackedException : Exception
  • public PublishNackedException()
  • public PublishNackedException(string message)
  • public PublishNackedException(string message, Exception inner)
  • protected PublishNackedException(SerializationInfo info, StreamingContext context)
• public class PublishReturnedException : Exception
  • public PublishReturnedException()
  • public PublishReturnedException(string message)
  • public PublishReturnedException(string message, Exception inner)
  • protected PublishReturnedException(SerializationInfo info, StreamingContext context)

EasyNetQ.SystemMessages

• public class Error
  • public MessageBasicProperties BasicProperties { get; set; }
  • public MessageProperties BasicProperties { get; set; }
  • public string Queue { get; set; }
  • public Error()
  • public Error(string routingKey, string exchange, string queue, string exception, string message, DateTime dateTime, MessageProperties basicProperties)
• public class MessageBasicProperties
• public class ScheduleMe

EasyNetQ.Topology

• public class Binding : IBinding, ITopology
• public class DefaultExchange : Exchange
• public struct Binding<TBindable> where TBindable : struct, IBindable
  • public IDictionary<string, object> Arguments { get; }
  • public TBindable Destination { get; }
  • public string RoutingKey { get; }
  • public Exchange Source { get; }
  • public Binding(ref Exchange source, ref TBindable destination, string routingKey, IDictionary<string, object> arguments = null)
• public struct Exchange : IBindable
  • protected readonly IList<IBinding> bindings
  • public IDictionary Arguments { get; }
  • public bool AutoDelete { get; }
  • public string ExchangeType { get; }
  • public const string DefaultName = ""
  • public static Exchange Default { get; }
  • public IDictionary<string, object> Arguments { get; }
  • public bool IsAutoDelete { get; }
  • public bool IsDurable { get; }
  • protected Exchange(string name, string exchangeType)
  • protected Exchange(string name, string exchangeType, bool autoDelete, IDictionary arguments)
  • public static IExchange DeclareDirect(string exchangeName)
  • public static IExchange DeclareDirect(string exchangeName, bool autoDelete, IDictionary arguments)
  • public static IExchange DeclareFanout(string exchangeName)
  • public static IExchange DeclareFanout(string exchangeName, bool autoDelete, IDictionary arguments)
  • public static IExchange DeclareTopic(string exchangeName)
  • public static IExchange DeclareTopic(string exchangeName, bool autoDelete, IDictionary arguments)
  • public static IExchange GetDefault()
  • public virtual void BindTo(IExchange exchange, string[] routingKeys)
  • public virtual void Visit(ITopologyVisitor visitor)
  • public string Type { get; }
  • public Exchange(string name, string type = "direct", bool durable = true, bool autoDelete = false, IDictionary<string, object> arguments = null)
• public class ExchangeType
• public interface IBindable
  • void BindTo(IExchange exchange, string[] routingKeys)
  • string Name { get; }
• public interface IBinding : ITopology
• public interface IExchange : IBindable, ITopology
• public interface IQueue : IBindable, ITopology
• public interface ITopology
• public interface ITopologyVisitor
• public struct Queue : IBindable
  • public bool IsSingleUse { get; }
  • public IDictionary<string, object> Arguments { get; }
  • public bool IsAutoDelete { get; }
  • public bool IsDurable { get; }
  • public bool IsExclusive { get; }
  • protected Queue(bool durable, bool exclusive, bool autoDelete, string name, IDictionary<string, object> arguements)
  • protected Queue(bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
  • public static IQueue Declare(bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
  • public static IQueue Declare(bool durable, bool exclusive, bool autoDelete, string name, IDictionary<string, object> arguments)
  • public static IQueue DeclareDurable(string queueName)
  • public static IQueue DeclareDurable(string queueName, IDictionary<string, object> arguments)
  • public static IQueue DeclareTransient(string queueName)
  • public static IQueue DeclareTransient(string queueName, IDictionary<string, object> arguments)
  • public static IQueue DeclareTransient()
  • public void BindTo(IExchange exchange, string[] routingKeys)
  • public IQueue SetAsSingleUse()
  • public void Visit(ITopologyVisitor visitor)
  • public Queue(string name, bool isDurable = true, bool isExclusive = false, bool isAutoDelete = false, IDictionary<string, object> arguments = null)
• public class TopologyBuilder : ITopologyVisitor