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

API Diff between 7.8.0 and 3.4.0-alpha0019

901 Additions 435 Removals

EasyNetQ

public class AdvancedBusEventHandlers
- public static readonly AdvancedBusEventHandlers Default
- public EventHandler<ConnectionBlockedEventArgs> Blocked { get; }
- public EventHandler Connected { get; }
- public EventHandler Disconnected { get; }
- public EventHandler<BlockedEventArgs> Blocked { get; }
- public EventHandler<ConnectedEventArgs> Connected { get; }
- public EventHandler<DisconnectedEventArgs> Disconnected { get; }
- public EventHandler Unblocked { get; }
- public AdvancedBusEventHandlers(EventHandler connected = null, EventHandler disconnected = null, EventHandler<ConnectionBlockedEventArgs> blocked = null, EventHandler unblocked = null, EventHandler<MessageReturnedEventArgs> messageReturned = null)
- public 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 IBinding Bind(this IAdvancedBus bus, IExchange source, IExchange destination, string routingKey, CancellationToken cancellationToken = default)
- public static IBinding Bind(this IAdvancedBus bus, IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
- public static IBinding Bind(this IAdvancedBus bus, IExchange exchange, IQueue queue, string routingKey, CancellationToken cancellationToken = default)
- public static IBinding Bind(this IAdvancedBus bus, IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
- public static IDisposable Consume<T>(this IAdvancedBus bus, IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage)
- public static IDisposable Consume<T>(this IAdvancedBus bus, IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
- public static IDisposable Consume<T>(this IAdvancedBus bus, IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Action<IHandlerRegistration> addHandlers)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- public static IExchange ExchangeDeclare(this IAdvancedBus bus, string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, string alternateExchange = null, bool delayed = false, CancellationToken cancellationToken = default)
- public static void ExchangeDelete(this IAdvancedBus bus, IExchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public static IBasicGetResult<T> GetMessage<T>(this IAdvancedBus bus, IQueue queue, CancellationToken cancellationToken = default)
- public static IBasicGetResult GetMessage(this IAdvancedBus bus, IQueue queue, CancellationToken cancellationToken = default)
- public static uint GetMessagesCount(this IAdvancedBus bus, IQueue queue, CancellationToken cancellationToken = default)
- public static void Publish(this IAdvancedBus bus, IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body, CancellationToken cancellationToken = default)
- public static void Publish<T>(this IAdvancedBus bus, IExchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken = default)
- public static IQueue QueueDeclare(this IAdvancedBus bus, CancellationToken cancellationToken = default)
- public static IQueue QueueDeclare(this IAdvancedBus bus, string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default, CancellationToken cancellationToken = default)
- public static void QueueDelete(this IAdvancedBus bus, IQueue queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- public static void QueuePurge(this IAdvancedBus bus, IQueue queue, CancellationToken cancellationToken = default)
- public static void Unbind(this IAdvancedBus bus, IBinding binding, CancellationToken cancellationToken = default)
- 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 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, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, MessageHandler handler, Action<ISimpleConsumeConfiguration> configure)
- public static Exchange ExchangeDeclare(this IAdvancedBus bus, string name, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
- public static Exchange ExchangeDeclare(this IAdvancedBus bus, string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public static Task<Exchange> ExchangeDeclareAsync(this IAdvancedBus bus, string name, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
- public static void ExchangeDeclarePassive(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
- public static void ExchangeDelete(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 name, CancellationToken cancellationToken = default)
- public static void Publish(this IAdvancedBus bus, Exchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, ReadOnlyMemory<byte> body, CancellationToken cancellationToken = default)
- public static void Publish<T>(this IAdvancedBus bus, Exchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, string name, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, string name, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
- public static Task<Queue> QueueDeclareAsync(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
- public static Task<Queue> QueueDeclareAsync(this IAdvancedBus bus, string name, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
- public static void QueueDeclarePassive(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
- public static void QueueDelete(this IAdvancedBus bus, string name, 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 BasicGetResult : IBasicGetResult
public class BasicGetResult<T> : IBasicGetResult<T>
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 Uri AMQPConnectionString { get; set; }
- public IList<AuthMechanismFactory> AuthMechanisms { get; set; }
- public const int DefaultAmqpsPort = 5671
- public const int DefaultPort = 5672
- public IList<IAuthMechanismFactory> AuthMechanisms { get; set; }
- public IEnumerable<HostConfiguration> Hosts { get; set; }
- public int? ConsumerDispatcherConcurrency { get; set; }
- public IList<HostConfiguration> Hosts { get; set; }
- public bool MandatoryPublish { get; set; }
- public ushort RequestedHeartbeat { get; set; }
- public ushort RequestedChannelMax { get; set; }
- public TimeSpan RequestedHeartbeat { get; set; }
- public ushort Timeout { get; set; }
- public bool UseBackgroundThreads { get; set; }
- public TimeSpan Timeout { get; set; }
- public void Validate()
public class ConnectionFactoryInfo
public class ConnectionFactoryWrapper : IConnectionFactory
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
- public ReadOnlyMemory<byte> Body { get; }
- public MessageProperties Properties { get; }
- public MessageReceivedInfo ReceivedInfo { get; }
- public ConsumedMessage(MessageReceivedInfo receivedInfo, MessageProperties properties, ref ReadOnlyMemory body)
public class Conventions : IConventions
- public QueueTypeConvention QueueTypeConvention { get; set; }
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 DefaultMessageSerializationStrategy : IMessageSerializationStrategy
- public IMessage DeserializeMessage(MessageProperties properties, byte[] body)
- public IMessage DeserializeMessage(MessageProperties properties, ref ReadOnlyMemory body)
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 static class DelayedExchangeExtensions
- public static IExchangeDeclareConfiguration AsDelayedExchange(this IExchangeDeclareConfiguration configuration, string exchangeType = "fanout")
- public static IMessage<T> WithDelay<T>(this IMessage<T> message, 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 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)
- protected EasyNetQException(SerializationInfo info, StreamingContext context)
public class EasyNetQResponderException : EasyNetQException
- public EasyNetQResponderException(string format, string[] args)
- public EasyNetQResponderException(string format, object[] args)
- protected EasyNetQResponderException(SerializationInfo info, StreamingContext context)
public sealed class EventBus : IEventBus
- public EventBus()
- public void Publish<TEvent>(TEvent event)
- public IDisposable Subscribe<TEvent>(Action<TEvent> eventHandler)
- 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 static class ExchangeDeclareConfigurationExtensions
- public static IExchangeDeclareConfiguration WithAlternateExchange(this IExchangeDeclareConfiguration configuration, Exchange alternateExchange)
public static class Extensions
public interface IAdvancedBus : IDisposable
- event EventHandler<ConnectionBlockedEventArgs> Blocked
- event EventHandler Connected
- event EventHandler Disconnected
- event EventHandler<BlockedEventArgs> Blocked
- event EventHandler<ConnectedEventArgs> Connected
- event EventHandler<DisconnectedEventArgs> Disconnected
- event EventHandler Unblocked
- Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, CancellationToken cancellationToken = default)
- Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
- Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, CancellationToken cancellationToken = default)
- Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
- IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
- IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure)
- Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, string alternateExchange = null, bool delayed = false, CancellationToken cancellationToken = default)
- Task ExchangeDeleteAsync(IExchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- Task<IBasicGetResult<T>> GetMessageAsync<T>(IQueue queue, CancellationToken cancellationToken = default)
- Task<IBasicGetResult> GetMessageAsync(IQueue queue, CancellationToken cancellationToken = default)
- Task<uint> GetMessagesCountAsync(IQueue queue, CancellationToken cancellationToken = default)
- Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken = default)
- Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken = default)
- Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body, CancellationToken cancellationToken = default)
- Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default, CancellationToken cancellationToken = default)
- Task<IQueue> QueueDeclareAsync(CancellationToken cancellationToken = default)
- Task QueueDeleteAsync(IQueue queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- Task QueuePurgeAsync(IQueue queue, CancellationToken cancellationToken = default)
- Task UnbindAsync(IBinding binding, CancellationToken cancellationToken = default)
- event EventHandler<UnblockedEventArgs> Unblocked
- Task<Binding<Queue>> BindAsync(Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task<Binding<Exchange>> BindAsync(Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- 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<Exchange> ExchangeDeclareAsync(string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- Task ExchangeDeclarePassiveAsync(string name, CancellationToken cancellationToken = default)
- Task ExchangeDeleteAsync(Exchange 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 name, CancellationToken cancellationToken = default)
- Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken = default)
- Task PublishAsync<T>(Exchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken = default)
- Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, MessageProperties properties, ReadOnlyMemory<byte> body, CancellationToken cancellationToken = default)
- Task<Queue> QueueDeclareAsync(string name, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- Task<Queue> QueueDeclareAsync(CancellationToken cancellationToken = default)
- Task QueueDeclarePassiveAsync(string name, CancellationToken cancellationToken = default)
- Task QueueDeleteAsync(string name, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- Task QueuePurgeAsync(string name, CancellationToken cancellationToken = default)
- Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
public interface IBasicGetResult
public interface IBasicGetResult<T>
public interface IBus : IDisposable
- IPubSub PubSub { get; }
- IRpc Rpc { get; }
- IScheduler Scheduler { get; }
- ISendReceive SendReceive { get; }
- IPubSub PubSub { get; }
- IRpc Rpc { get; }
- IScheduler Scheduler { get; }
- ISendReceive SendReceive { get; }
public interface IClusterHostSelectionStrategy<T>
public interface IConnectionFactory
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
- QueueTypeConvention QueueTypeConvention { get; }
public interface IEventBus
- void Publish<TEvent>(TEvent event)
- IDisposable Subscribe<TEvent>(Action<TEvent> eventHandler)
- 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 IFuturePublishConfiguration
- IFuturePublishConfiguration WithHeaders(IDictionary<string, object> headers)
- IFuturePublishConfiguration WithPriority(byte priority)
- IFuturePublishConfiguration WithTopic(string topic)
public interface IMessageSerializationStrategy
- IMessage DeserializeMessage(MessageProperties properties, byte[] body)
- IMessage DeserializeMessage(MessageProperties properties, ReadOnlyMemory body)
public interface IPersistentConnection : IDisposable
public interface IPersistentConnectionFactory
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 : IDisposable
- 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)
- object BytesToMessage(Type type, byte[] bytes)
- byte[] MessageToBytes<T>(T message)
- object BytesToMessage(Type messageType, ReadOnlyMemory bytes)
- IMemoryOwner<byte> MessageToBytes(Type messageType, object message)
public interface ISubscriptionResult : IDisposable
public interface ITimeoutStrategy
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 class JsonSerializer : ISerializer
- public JsonSerializer()
- public JsonSerializer(JsonSerializerSettings serializerSettings)
- public T BytesToMessage<T>(byte[] bytes)
- public object BytesToMessage(Type type, 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 static class LegacyTypeNamingExtensions
public static class LinqExtensions
public class Message<T> : IMessage<T>, IMessage
- public Message()
public class MessageNotAvailableException : Exception
public class MessageProperties : ICloneable
- public string Expiration { get; set; }
- public TimeSpan? Expiration { get; set; }
- public MessageProperties(IBasicProperties basicProperties)
- public void CopyFrom(IBasicProperties basicProperties)
- public void CopyTo(IBasicProperties basicProperties)
public static class MessagePropertiesExtensions
- public static void CopyFrom(this MessageProperties source, IBasicProperties basicProperties)
- public static void CopyTo(this MessageProperties source, IBasicProperties basicProperties)
public class MessageReceivedInfo
- public ulong DeliverTag { get; set; }
- public ulong DeliveryTag { get; }
- public MessageReceivedInfo()
public class MessageReturnedEventArgs : EventArgs
- public byte[] MessageBody { get; }
- public ReadOnlyMemory<byte> MessageBody { get; }
- public MessageReturnedEventArgs(byte[] messageBody, MessageProperties messageProperties, MessageReturnedInfo messageReturnedInfo)
- public MessageReturnedEventArgs(ref ReadOnlyMemory messageBody, MessageProperties messageProperties, ref MessageReturnedInfo messageReturnedInfo)
public class OrderedClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
public class PersistentConnection : IPersistentConnection, IDisposable
public class PersistentConnectionFactory : IPersistentConnectionFactory
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
- public ReadOnlyMemory<byte> Body { get; }
- public MessageProperties Properties { get; }
- public ProducedMessage(MessageProperties properties, ref ReadOnlyMemory body)
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, MessageReceivedInfo receivedInfo, 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 class QueueAttribute : Attribute
- public string QueueType { get; set; }
public class QueueConsumerPair
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 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 event EventHandler<ConnectionBlockedEventArgs> Blocked
- public event EventHandler Connected
- public event EventHandler Disconnected
- public event EventHandler<BlockedEventArgs> Blocked
- public event EventHandler<ConnectedEventArgs> Connected
- public event EventHandler<DisconnectedEventArgs> Disconnected
- public event EventHandler Unblocked
- public RabbitAdvancedBus(IConnectionFactory connectionFactory, IConsumerFactory consumerFactory, IClientCommandDispatcherFactory clientCommandDispatcherFactory, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IServiceResolver container, ConnectionConfiguration connectionConfiguration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, AdvancedBusEventHandlers advancedBusEventHandlers, IPersistentConnectionFactory persistentConnectionFactory)
- public Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, CancellationToken cancellationToken)
- public Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken)
- public Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, CancellationToken cancellationToken)
- public Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken)
- public IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
- public IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure)
- public IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure)
- public event EventHandler<UnblockedEventArgs> Unblocked
- public RabbitAdvancedBus(ILogger<RabbitAdvancedBus> logger, IProducerConnection producerConnection, IConsumerConnection consumerConnection, IConsumerFactory consumerFactory, IPersistentChannelDispatcher persistentChannelDispatcher, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IServiceResolver container, ConnectionConfiguration configuration, IEnumerable<IProduceConsumeInterceptor> produceConsumeInterceptors, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, IPullingConsumerFactory pullingConsumerFactory, AdvancedBusEventHandlers advancedBusEventHandlers, IConsumeScopeProvider consumeScopeProvider)
- public Task<Binding<Queue>> BindAsync(Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public Task<Binding<Exchange>> BindAsync(Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public 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)
- public Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, string alternateExchange = null, bool delayed = false, CancellationToken cancellationToken = default)
- public virtual Task ExchangeDeleteAsync(IExchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public Task<IBasicGetResult<T>> GetMessageAsync<T>(IQueue queue, CancellationToken cancellationToken)
- public Task<IBasicGetResult> GetMessageAsync(IQueue queue, CancellationToken cancellationToken)
- public Task<uint> GetMessagesCountAsync(IQueue queue, CancellationToken cancellationToken)
- protected void OnBlocked(ConnectionBlockedEvent args)
- protected void OnConnected()
- protected void OnDisconnected()
- protected void OnMessageReturned(ReturnedMessageEvent args)
- protected void OnUnblocked()
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken)
- public virtual Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken)
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body, CancellationToken cancellationToken)
- public Task<IQueue> QueueDeclareAsync(CancellationToken cancellationToken)
- public Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default, CancellationToken cancellationToken = default)
- public virtual Task QueueDeleteAsync(IQueue queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- public virtual Task QueuePurgeAsync(IQueue queue, CancellationToken cancellationToken)
- public virtual Task UnbindAsync(IBinding binding, CancellationToken cancellationToken)
- public Task<Exchange> ExchangeDeclareAsync(string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public Task ExchangeDeclarePassiveAsync(string name, CancellationToken cancellationToken = default)
- public virtual Task ExchangeDeleteAsync(Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public virtual Task ExchangeUnbindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public Task<QueueStats> GetQueueStatsAsync(string name, CancellationToken cancellationToken)
- public virtual Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken)
- public virtual Task PublishAsync<T>(Exchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken)
- public virtual Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, MessageProperties properties, ReadOnlyMemory<byte> body, CancellationToken cancellationToken)
- public Task<Queue> QueueDeclareAsync(CancellationToken cancellationToken)
- public Task<Queue> QueueDeclareAsync(string name, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public Task QueueDeclarePassiveAsync(string name, CancellationToken cancellationToken = default)
- public virtual Task QueueDeleteAsync(string name, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- public virtual Task QueuePurgeAsync(string name, CancellationToken cancellationToken)
- public virtual Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
public class RabbitBus : IBus, IDisposable
- 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 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 hostName, ushort hostPort, string virtualHost, string username, string password, ushort requestedHeartbeat, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, TimeSpan requestedHeartbeat, Action<IServiceRegister> registerServices)
public class RandomClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
public static class ReflectionHelpers
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 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, TResponse> responder, Action<IResponderConfiguration> configure, 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 virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
- public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
- public virtual string Invoke()
- 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 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 byte[] Body { get; }
- public ReadOnlyMemory<byte> Body { get; }
- public SerializedMessage(MessageProperties properties, byte[] body)
- public SerializedMessage(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 class SimpleConsumeConfigurationExtensions
- public static ISimpleConsumeConfiguration WithPriority(this ISimpleConsumeConfiguration configuration, int priority)
public struct SubscriptionResult : IDisposable
- public IDisposable ConsumerCancellation { get; }
- public IExchange Exchange { get; }
- public IQueue Queue { get; }
- public SubscriptionResult(IExchange exchange, IQueue queue, IDisposable consumerCancellation)
- public Exchange Exchange { get; }
- public Queue Queue { get; }
- public SubscriptionResult(ref Exchange exchange, ref Queue queue, IDisposable consumerCancellation)
public sealed class TimeBudget
public class TimeoutSecondsAttribute : Attribute
public class TimeoutStrategy : ITimeoutStrategy
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 UnblockedEventArgs : EventArgs
- public PersistentConnectionType Type { get; }
- public UnblockedEventArgs(PersistentConnectionType type)

EasyNetQ.DI

public class DefaultServiceContainer : IServiceRegister
public static class DefaultServicesRegistration
public class DefaultConsumeScopeProvider : IConsumeScopeProvider
- public DefaultConsumeScopeProvider(IServiceResolver resolver)
- public IServiceResolverScope CreateScope()
public interface IConsumeScopeProvider
- IServiceResolverScope CreateScope()
public interface IServiceRegister
- IServiceRegister Register<TService, TImplementation>(Lifetime lifetime = 1) where TImplementation : TService
- IServiceRegister Register<TService>(TService instance)
- IServiceRegister Register<TService>(Func<IServiceResolver, TService> factory, Lifetime lifetime = 1)
- 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 class NoopConsumeScopeProvider : IConsumeScopeProvider
- public NoopConsumeScopeProvider()
- public IServiceResolverScope CreateScope()
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)

EasyNetQ.Events

public struct AckEvent
- public byte[] Body { get; }
- public ReadOnlyMemory<byte> Body { get; }
- public AckEvent(MessageReceivedInfo info, MessageProperties properties, byte[] body, AckResult ackResult)
- public AckEvent(MessageReceivedInfo info, MessageProperties properties, ref ReadOnlyMemory body, AckResult ackResult)
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 ConnectionBlockedEvent(string reason)
- public PersistentConnectionType Type { get; }
- public ConnectionBlockedEvent(PersistentConnectionType type, string reason)
public struct ConnectionCreatedEvent
- public ConnectionCreatedEvent()
- public AmqpTcpEndpoint Endpoint { get; }
- public PersistentConnectionType Type { get; }
- public ConnectionCreatedEvent(PersistentConnectionType type, AmqpTcpEndpoint endpoint)
public struct ConnectionDisconnectedEvent
- public 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 ConnectionUnblockedEvent()
- public PersistentConnectionType Type { get; }
- public ConnectionUnblockedEvent(PersistentConnectionType type)
public struct ConsumerModelDisposedEvent
- public string ConsumerTag { get; }
- public ConsumerModelDisposedEvent(string consumerTag)
- public IReadOnlyCollection<string> ConsumerTags { get; }
- public ConsumerModelDisposedEvent(string[] consumerTags)
public struct DeliveredMessageEvent
- public byte[] Body { get; }
- public ReadOnlyMemory<byte> Body { get; }
- public DeliveredMessageEvent(MessageReceivedInfo info, MessageProperties properties, byte[] body)
- public DeliveredMessageEvent(MessageReceivedInfo info, MessageProperties properties, ref ReadOnlyMemory body)
public struct MessageConfirmationEvent
- public MessageConfirmationEvent()
public class PublishChannelCreatedEvent
public struct PublishedMessageEvent
- public byte[] Body { get; }
- public string ExchangeName { get; }
- public ReadOnlyMemory<byte> Body { get; }
- public Exchange Exchange { get; }
- public PublishedMessageEvent(string exchangeName, string routingKey, MessageProperties properties, byte[] body)
- public PublishedMessageEvent(ref Exchange exchange, string routingKey, MessageProperties properties, ref ReadOnlyMemory body)
public struct ReturnedMessageEvent
- public byte[] Body { get; }
- public ReadOnlyMemory<byte> Body { get; }
- public IModel Channel { get; }
- public ReturnedMessageEvent(byte[] body, MessageProperties properties, MessageReturnedInfo info)
- public ReturnedMessageEvent(IModel channel, ref ReadOnlyMemory body, MessageProperties properties, ref MessageReturnedInfo info)
public struct StartConsumingFailedEvent
- public IQueue Queue { get; }
- public StartConsumingFailedEvent(IConsumer consumer, IQueue queue)
- public Queue Queue { get; }
- public StartConsumingFailedEvent(IConsumer consumer, ref Queue queue)
public struct StartConsumingSucceededEvent
- public IQueue Queue { get; }
- public StartConsumingSucceededEvent(IConsumer consumer, IQueue queue)
- public Queue Queue { get; }
- public StartConsumingSucceededEvent(IConsumer consumer, ref Queue queue)

EasyNetQ.FluentConfiguration

public interface IPublishConfiguration
public interface IRequestConfiguration
public interface ISubscriptionConfiguration
public class PublishConfiguration : IPublishConfiguration
public class RequestConfiguration : IRequestConfiguration
public class SubscriptionConfiguration : ISubscriptionConfiguration

EasyNetQ.Interception

public class CompositeInterceptor : IProduceConsumeInterceptor
public class DefaultInterceptor : IProduceConsumeInterceptor
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 RawMessage OnConsume(RawMessage rawMessage)
- public RawMessage OnProduce(RawMessage rawMessage)
- public ConsumedMessage OnConsume(ref ConsumedMessage message)
- public ProducedMessage OnProduce(ref ProducedMessage message)
public interface IInterceptorRegistrator
public static class InterceptionExtensions
public class InterceptorRegistrator : IInterceptorRegistrator
public interface IProduceConsumeInterceptor
- RawMessage OnConsume(RawMessage rawMessage)
- RawMessage OnProduce(RawMessage rawMessage)
- ConsumedMessage OnConsume(ConsumedMessage& modreq(System.Runtime.InteropServices.InAttribute) message)
- ProducedMessage OnProduce(ProducedMessage& modreq(System.Runtime.InteropServices.InAttribute) message)
public struct RawMessage
public class TripleDESInterceptor : IProduceConsumeInterceptor
- public RawMessage OnConsume(RawMessage rawMessage)
- public RawMessage OnProduce(RawMessage rawMessage)
- 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 Task<IDisposable> AcquireAsync(CancellationToken cancellationToken = default)
- public Releaser Acquire(CancellationToken cancellationToken = default)
- public Task<Releaser> AcquireAsync(CancellationToken cancellationToken = default)
- public void Dispose()
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 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 void UnionWith(this IDictionary<string, object> source, IDictionary<string, object> addendum)
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 static class EnumerableExtensions
- public static IEnumerable<T> Intersperse<T>(this IEnumerable<T> items, T separator)
- public static IEnumerable<T> SurroundWith<T>(this IEnumerable<T> items, T first, T last)
public class NoResult : IEquatable<NoResult>
- public static readonly NoResult Instance
- protected virtual Type EqualityContract { get; }
- protected NoResult(NoResult original)
- public static bool op_Equality(NoResult left, NoResult right)
- public static bool op_Inequality(NoResult left, NoResult right)
- public virtual NoResult <Clone>$()
- public virtual bool Equals(NoResult other)
- protected virtual bool PrintMembers(StringBuilder builder)
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 Task Completed { get; }
- public static TaskCompletionSource<T> CreateTcs<T>()
- public static void AttachCancellation<T>(this TaskCompletionSource<T> taskCompletionSource, CancellationToken cancellationToken)
- public static Task FromCancelled()
- public static Task<T> FromCancelled<T>()
- public static Task FromException(Exception exception)
- public static Task<T> FromException<T>(Exception exception)
- public static Task<T> FromResult<T>(T result)
- public static void TrySetCanceledAsynchronously<T>(this TaskCompletionSource<T> source)
- public static void TrySetExceptionAsynchronously<T>(this TaskCompletionSource<T> source, Exception exception)
- public static void TrySetResultAsynchronously<T>(this TaskCompletionSource<T> source, T result)
public static class Timers
- public static void RunOnce(TimerCallback callback, TimeSpan dueTime)
- public static IDisposable Start(TimerCallback callback, TimeSpan dueTime, TimeSpan period)
- 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.LightInject

public class AssemblyScanner : IAssemblyScanner
public class CachedTypeExtractor : ITypeExtractor
public class CompositionRootAttributeExtractor : ICompositionRootAttributeExtractor
public class CompositionRootExecutor : ICompositionRootExecutor
public class CompositionRootTypeAttribute : Attribute
public class CompositionRootTypeExtractor : ITypeExtractor
public class ConcreteTypeExtractor : ITypeExtractor
public class ConstructionInfo
public class ConstructionInfoProvider : IConstructionInfoProvider
public class ConstructorDependency : Dependency
public class ConstructorDependencySelector : IConstructorDependencySelector
public class ContainerOptions
public class DecoratorRegistration : Registration
public abstract class Dependency
public class DynamicMethod
public class Emitter : IEmitter
public static class EmitterExtensions
public static class Ensure
public class ExcludeFromCodeCoverageAttribute : Attribute
public class GenericArgumentMapper : IGenericArgumentMapper
public class GenericMappingResult
public interface IAssemblyScanner
public interface ICompositionRoot
public interface ICompositionRootAttributeExtractor
public interface ICompositionRootExecutor
public interface IConstructionInfoBuilder
public interface IConstructionInfoProvider
public interface IConstructorDependencySelector
public interface IConstructorSelector
public interface IEmitter
public interface IGenericArgumentMapper
public class ILGenerator
public interface ILifetime
public interface IMethodSkeleton
public sealed class ImmutableHashTable<TKey, TValue>
public static class ImmutableHashTableExtensions
public sealed class ImmutableHashTree<TKey, TValue>
public static class ImmutableHashTreeExtensions
public sealed class ImmutableList<T>
public class Instruction
public class Instruction<T> : Instruction
public interface IPropertyDependencySelector
public interface IPropertySelector
public interface IScopeManager
public interface IScopeManagerProvider
public interface IServiceContainer : IServiceRegistry, IServiceFactory, IDisposable
public interface IServiceFactory
public interface IServiceNameProvider
public interface IServiceRegistry
public interface ITypeConstructionInfoBuilder
public interface ITypeExtractor
public sealed class KeyValue<TKey, TValue>
public class LocalBuilder
public class LogEntry
public static class LogExtensions
public class LogicalThreadStorage<T>
public enum LogLevel
public class MostResolvableConstructorSelector : IConstructorSelector
public class PerContainerLifetime : ILifetime, IDisposable
public class PerLogicalCallContextScopeManager : ScopeManager
public class PerLogicalCallContextScopeManagerProvider : ScopeManagerProvider
public class PerRequestLifeTime : ILifetime
public class PerScopeLifetime : ILifetime
public class PerThreadScopeManager : ScopeManager
public class PerThreadScopeManagerProvider : ScopeManagerProvider
public class PropertyDependency : Dependency
public class PropertyDependencySelector : IPropertyDependencySelector
public class PropertySelector : IPropertySelector
public abstract class Registration
public static class RuntimeArgumentsLoader
public class Scope : IServiceFactory, IDisposable
public abstract class ScopeManager : IScopeManager
public abstract class ScopeManagerProvider : IScopeManagerProvider
public class ServiceContainer : IServiceContainer, IServiceRegistry, IServiceFactory, IDisposable
public static class ServiceFactoryExtensions
public class ServiceNameProvider : IServiceNameProvider
public class ServiceRegistration : Registration
public class ServiceRequest
public class ThreadSafeDictionary<TKey, TValue> : ConcurrentDictionary<TKey, TValue>
public class TypeConstructionInfoBuilder : IConstructionInfoBuilder

EasyNetQ.Logging

public class ConsoleLogProvider : ILogProvider
public interface ILog
public interface ILogProvider
public static class LogExtensions
public sealed delegate Logger : MulticastDelegate
public class ConsoleLogger : ILogger
- public ConsoleLogger()
- public bool Log(LogLevel logLevel, Func<string> messageFunc, Exception exception = null, object[] formatParameters)
public class ConsoleLogger<TCategoryName> : ConsoleLogger, ILogger<TCategoryName>, ILogger
- public ConsoleLogger()
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 static class LogProvider
public class NoopLogger : ILogger
- public NoopLogger()
- public bool Log(LogLevel logLevel, Func<string> messageFunc, Exception exception = null, object[] formatParameters)
public class NoopLogger<TCategoryName> : ILogger<TCategoryName>, ILogger
- public NoopLogger()
- public bool Log(LogLevel logLevel, Func<string> messageFunc, Exception exception = null, object[] formatParameters)

EasyNetQ.Logging.LogProviders

public class LibLogException : Exception
public abstract class LogProviderBase : ILogProvider

EasyNetQ.MessageVersioning

public static class MessageVersioningExtensions
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 IMessage DeserializeMessage(MessageProperties properties, byte[] body)
- public IMessage DeserializeMessage(MessageProperties properties, ref ReadOnlyMemory body)
public class VersionedPublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy

EasyNetQ.MultipleExchange

public static class MultipleExchangeExtension
public class MultipleExchangePublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
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<NoResult>
- public ActionBasedPersistentChannelAction(Action<IModel> action)
- public NoResult Invoke(IModel model)
public struct FuncBasedPersistentChannelAction<TResult> : IPersistentChannelAction<TResult>
- public FuncBasedPersistentChannelAction(Func<IModel, TResult> func)
- public TResult Invoke(IModel model)
public interface IPersistentChannel : IDisposable
- Task<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, IPersistentConnection connection, IEventBus eventBus)
- public PersistentChannel(ref PersistentChannelOptions options, IPersistentConnection connection, IEventBus eventBus, ILogger<PersistentChannel> logger)
- public void Dispose()
- public Task<TResult> InvokeChannelActionAsync<TResult, TChannelAction>(TChannelAction channelAction, CancellationToken cancellationToken = default) where TChannelAction : struct, IPersistentChannelAction<TResult>
public class PersistentChannelFactory : IPersistentChannelFactory
- public PersistentChannelFactory(IEventBus eventBus)
- public PersistentChannelFactory(IEventBus eventBus, ILogger<PersistentChannel> logger)
- 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 class ClientCommandDispatcher : IClientCommandDispatcher, IDisposable
public class ClientCommandDispatcherFactory : IClientCommandDispatcherFactory
public class ClientCommandDispatcherSingleton : IClientCommandDispatcher, IDisposable
public class DefaultPubSub : IPubSub
public class DefaultRpc : IRpc
public class DefaultSendReceive : ISendReceive
public interface IClientCommandDispatcher : IDisposable
public interface IClientCommandDispatcherFactory
public interface IPersistentChannel : IDisposable
public interface IPersistentChannelFactory
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 interface IExchangeDeclareStrategy
- Task<Exchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken = default)
- Task<Exchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken = default)
public interface IProducerConnection : IPersistentConnection, IDisposable
public interface IPublishConfirmationListener : IDisposable
- IPublishConfirmationWaiter GetWaiter(IModel model)
- IPublishPendingConfirmation CreatePendingConfirmation(IModel model)
public interface IPublishConfirmationWaiter
public interface IPublishExchangeDeclareStrategy
public interface IPubSub
public interface IReceiveRegistration
public interface IResponderConfiguration
public interface IRpc
public interface ISendReceive
public class PersistentChannel : IPersistentChannel, IDisposable
public class PersistentChannelFactory : IPersistentChannelFactory
public interface IPublishPendingConfirmation
- ulong Id { get; }
- void Cancel()
- Task WaitAsync(CancellationToken cancellationToken = default)
public class ProducerConnection : PersistentConnection, IProducerConnection, IPersistentConnection, IDisposable
- public ProducerConnection(ILogger<ProducerConnection> logger, ConnectionConfiguration configuration, IConnectionFactory connectionFactory, IEventBus eventBus)
public class PublishConfirmationListener : IPublishConfirmationListener, IDisposable
- public IPublishPendingConfirmation CreatePendingConfirmation(IModel model)
- public IPublishConfirmationWaiter GetWaiter(IModel model)
public class PublishConfirmationWaiter : IPublishConfirmationWaiter
public class PublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
public static class PublishExchangeDeclareStrategyExtensions
public class PublishInterruptedException : Exception
- protected PublishInterruptedException(SerializationInfo info, StreamingContext context)
public class PublishNackedException : Exception
- protected PublishNackedException(SerializationInfo info, StreamingContext context)
public static class PubSubExtensions
public static class ReceiveRegistrationExtensions
public class ResponderConfiguration : IResponderConfiguration
public static class RpcExtensions
public static class SendReceiveExtensions
public class PublishReturnedException : Exception
- public PublishReturnedException()
- public PublishReturnedException(string message)
- public PublishReturnedException(string message, Exception inner)
- protected PublishReturnedException(SerializationInfo info, StreamingContext context)

EasyNetQ.Scheduling

public class DeadLetterExchangeAndMessageTtlScheduler : IScheduler
public class DelayedExchangeScheduler : IScheduler
public class ExternalScheduler : IScheduler
public interface IScheduler
public static class SchedulerExtensions
public static class SchedulingExtensions

EasyNetQ.SystemMessages

public class ScheduleMe
public class UnscheduleMe

EasyNetQ.Topology

public class Binding : IBinding
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
- public static Exchange Default { get; }
- public IDictionary<string, object> Arguments { get; }
- public bool IsAutoDelete { get; }
- public bool IsDurable { get; }
- public Exchange(string name)
- public static IExchange GetDefault()
- public string Type { get; }
- public Exchange(string name, string type = "direct", bool durable = true, bool autoDelete = false, IDictionary<string, object> arguments = null)
public interface IBindable
- string Name { get; }
public interface IBinding
public interface IExchange : IBindable
public interface IQueue : IBindable
public struct Queue : IBindable
- public IDictionary<string, object> Arguments { get; }
- public bool IsAutoDelete { get; }
- public bool IsDurable { get; }
- public Queue(string name, bool isExclusive)
- public Queue(string name, bool isDurable = true, bool isExclusive = false, bool isAutoDelete = false, IDictionary<string, object> arguments = null)

Sprache

public interface IFailure<T> : IResult<T>
public class Input
public interface IResult<T>
public interface ISuccess<T> : IResult<T>
public static class Parse
public class ParseException : Exception
public sealed delegate Parser<T> : MulticastDelegate
public static class ParserExtensions

API Diff between 7.8.0 and 3.4.0-alpha0019

EasyNetQ

EasyNetQ.AmqpExceptions

EasyNetQ.AutoSubscribe

EasyNetQ.ChannelDispatcher

EasyNetQ.ConnectionString

EasyNetQ.Consumer

EasyNetQ.DI

EasyNetQ.Events

EasyNetQ.FluentConfiguration

EasyNetQ.Interception

EasyNetQ.Internals

EasyNetQ.LightInject

EasyNetQ.Logging

EasyNetQ.Logging.LogProviders

EasyNetQ.MessageVersioning

EasyNetQ.MultipleExchange

EasyNetQ.Persistent

EasyNetQ.Producer

EasyNetQ.Scheduling

EasyNetQ.SystemMessages

EasyNetQ.Topology

Sprache