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

API Diff between 5.3.0-alpha0077 and 8.0.0-alpha5

999 Additions 356 Removals

EasyNetQ

public class AdvancedBusEventHandlers
- 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 EventHandler Unblocked { get; }
- public AdvancedBusEventHandlers(EventHandler<ConnectedEventArgs> connected = null, EventHandler<DisconnectedEventArgs> disconnected = null, EventHandler<BlockedEventArgs> blocked = null, EventHandler unblocked = null, EventHandler<MessageReturnedEventArgs> messageReturned = null)
public static class AdvancedBusExtensions
- public static Binding<Exchange> Bind(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, CancellationToken cancellationToken = default)
- public static Binding<Exchange> Bind(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Binding<Queue> Bind(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, CancellationToken cancellationToken = default)
- public static Binding<Queue> Bind(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Task<Binding<Queue>> BindAsync(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Task<Binding<Exchange>> BindAsync(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Task<Binding<Queue>> BindAsync(this IAdvancedBus bus, Exchange source, Queue queue, string routingKey, CancellationToken cancellationToken = default)
- public static Task<Binding<Exchange>> BindAsync(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, CancellationToken cancellationToken = default)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, Task> handler)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, IMessageHandler<T> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<IHandlerRegistration> addHandlers)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<IHandlerRegistration> addHandlers, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task<AckStrategy>> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task<AckStrategy>> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, MessageHandler handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, MessageHandler handler, Action<ISimpleConsumeConfiguration> configure)
- public static Exchange ExchangeDeclare(this IAdvancedBus bus, string 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 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 durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
- public static IExchange ExchangeDeclare(this IAdvancedBus bus, string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public static Task<IExchange> ExchangeDeclareAsync(this IAdvancedBus bus, string name, string type, bool durable = true, bool autoDelete = false, 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 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, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public static IQueue QueueDeclare(this IAdvancedBus bus, string name, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
- public static IQueue QueueDeclare(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
- public static Task<IQueue> QueueDeclareAsync(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
- public static Task<IQueue> QueueDeclareAsync(this IAdvancedBus bus, string name, bool durable, bool exclusive, bool autoDelete, 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 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 class BasicGetResult : IBasicGetResult
- public byte[] Body { get; }
- public MessageReceivedInfo Info { get; }
- public MessageProperties Properties { get; }
- public BasicGetResult(byte[] body, MessageProperties properties, MessageReceivedInfo info)
public class BasicGetResult<T> : IBasicGetResult<T>
- public IMessage<T> Message { get; }
- public bool MessageAvailable { get; }
- public BasicGetResult(IMessage<T> message)
- public BasicGetResult()
public class BlockedEventArgs : EventArgs
- public PersistentConnectionType Type { get; }
- public BlockedEventArgs(PersistentConnectionType type, string reason)
- public BlockedEventArgs(string reason)
public class ConnectedEventArgs : EventArgs
- public PersistentConnectionType Type { get; }
- public ConnectedEventArgs(PersistentConnectionType type, string hostname, int port)
- public ConnectedEventArgs(string hostname, int port)
public class ConnectionConfiguration
- public Uri AmqpConnectionString { get; set; }
- public int? ConsumerDispatcherConcurrency { get; set; }
- public bool MandatoryPublish { get; set; }
- public ushort RequestedChannelMax { get; set; }
public static class ConsumeConfigurationExtensions
public struct ConsumedMessage
public class Conventions : IConventions
- public QueueTypeConvention QueueTypeConvention { get; set; }
public class DeadLetterExchangeAndMessageTtlScheduler : IScheduler
- public Task FuturePublishAsync<T>(T message, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
- public Task FuturePublishAsync<T>(T message, TimeSpan delay, string topic, CancellationToken cancellationToken = default)
public static class DeadLetterStrategy
public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
- public IMessage DeserializeMessage(MessageProperties properties, ref ReadOnlyMemory body)
- public IMessage DeserializeMessage(MessageProperties properties, byte[] body)
public class DefaultPubSub : IPubSub
- public virtual AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken)
- public virtual AwaitableDisposable<ISubscriptionResult> SubscribeAsync<T>(string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken)
public class DefaultRpc : IRpc, IDisposable
- public DefaultRpc(ILogger<DefaultRpc> logger, ConnectionConfiguration configuration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITypeNameSerializer typeNameSerializer, ICorrelationIdGenerationStrategy correlationIdGenerationStrategy)
- public DefaultRpc(ConnectionConfiguration configuration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITypeNameSerializer typeNameSerializer, ICorrelationIdGenerationStrategy correlationIdGenerationStrategy)
- 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)
- protected virtual Task RequestPublishAsync<TRequest>(TRequest request, string routingKey, string returnQueueName, string correlationId, TimeSpan expiration, 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 DefaultSendReceive(ConnectionConfiguration configuration, IAdvancedBus advancedBus, IMessageDeliveryModeStrategy messageDeliveryModeStrategy)
- public AwaitableDisposable<IDisposable> ReceiveAsync<T>(string queue, Func<T, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken)
- public AwaitableDisposable<IDisposable> ReceiveAsync(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken)
- public Task SendAsync<T>(string queue, T message, CancellationToken cancellationToken)
public class DefaultTypeNameSerializer : ITypeNameSerializer
- public Type Deserialize(string typeName)
- public Type DeSerialize(string typeName)
public class DelayedExchangeScheduler : IScheduler
- public Task FuturePublishAsync<T>(T message, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
- public Task FuturePublishAsync<T>(T message, TimeSpan delay, string topic, CancellationToken cancellationToken = default)
public class DisconnectedEventArgs : EventArgs
- public PersistentConnectionType Type { get; }
- public DisconnectedEventArgs(PersistentConnectionType type, string hostname, int port, string reason)
- public DisconnectedEventArgs(string hostname, int port, string reason)
public sealed class EventBus : IEventBus
- public EventBus(ILogger<EventBus> logger)
- public void Publish<TEvent>(ref TEvent event) where TEvent : struct
- public IDisposable Subscribe<TEvent>(TEventHandler<TEvent> eventHandler) where TEvent : struct
- public EventBus()
- public void Publish<TEvent>(TEvent event)
- public IDisposable Subscribe<TEvent>(Action<TEvent> handler)
public sealed class ExchangeAttribute : Attribute
public static class ExchangeDeclareConfigurationExtensions
- public static IExchangeDeclareConfiguration WithAlternateExchange(this IExchangeDeclareConfiguration configuration, ref Exchange alternateExchange)
- public static IExchangeDeclareConfiguration WithAlternateExchange(this IExchangeDeclareConfiguration configuration, IExchange alternateExchange)
public class ExternalScheduler : IScheduler
- public ExternalScheduler(ConnectionConfiguration configuration, IAdvancedBus advancedBus, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IMessageSerializationStrategy messageSerializationStrategy)
- public Task FuturePublishAsync<T>(T message, TimeSpan delay, string topic, CancellationToken cancellationToken = default)
public class HostConfiguration
- public HostConfiguration(string host, ushort port)
- public HostConfiguration()
public interface IAdvancedBus : IDisposable
- event EventHandler<UnblockedEventArgs> Unblocked
- Task ConnectAsync(CancellationToken cancellationToken = default)
- IDisposable Consume(Action<IConsumeConfiguration> configure)
- IPullingConsumer<PullResult> CreatePullingConsumer(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, bool autoAck = true)
- IPullingConsumer<PullResult<T>> CreatePullingConsumer<T>(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, bool autoAck = true)
- Task ExchangeBindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task<Exchange> ExchangeDeclareAsync(string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- 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, Action<IExchangeDeclareConfiguration> configure, 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 QueueBindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task<Queue> QueueDeclareAsync(string name, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- Task<Queue> QueueDeclareAsync(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, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- Task<IQueue> QueueDeclareAsync(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)
- 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)
public interface IBasicGetResult
- byte[] Body { get; }
- MessageReceivedInfo Info { get; }
- MessageProperties Properties { get; }
public interface IBasicGetResult<T>
- IMessage<T> Message { get; }
- bool MessageAvailable { get; }
public interface IConsumeConfiguration
public interface IConventions
- QueueTypeConvention QueueTypeConvention { get; }
public interface IEventBus
- void Publish<TEvent>(TEvent& modreq(System.Runtime.InteropServices.InAttribute) event) where TEvent : struct
- IDisposable Subscribe<TEvent>(TEventHandler<TEvent> eventHandler) where TEvent : struct
- void Publish<TEvent>(TEvent event)
- IDisposable Subscribe<TEvent>(Action<TEvent> handler)
public interface IFuturePublishConfiguration
public interface IMessageSerializationStrategy
- IMessage DeserializeMessage(MessageProperties properties, ReadOnlyMemory body)
- IMessage DeserializeMessage(MessageProperties properties, byte[] body)
public interface IPerQueueConsumeConfiguration
public interface IPersistentConnection : IDisposable
- bool IsConnected { get; }
- IModel CreateModel()
public interface IPublishConfiguration
- IPublishConfiguration WithExpires(TimeSpan expires)
- IPublishConfiguration WithHeaders(IDictionary<string, object> headers)
- IPublishConfiguration WithExpires(int expires)
public interface IPubSub
- AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
- AwaitableDisposable<ISubscriptionResult> SubscribeAsync<T>(string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
public interface IPullingConsumer<TPullResult> : IDisposable where TPullResult : IPullResult
public interface IPullingConsumerFactory
public interface IPullResult : IDisposable
public interface IReceiveConfiguration
public interface IRequestConfiguration
- IRequestConfiguration WithHeaders(IDictionary<string, object> headers)
- IRequestConfiguration WithPriority(byte priority)
public interface IResponderConfiguration
- IResponderConfiguration WithExpires(TimeSpan expires)
- IResponderConfiguration WithMaxPriority(byte priority)
- IResponderConfiguration WithExpires(int expires)
public interface IScheduler
- Task FuturePublishAsync<T>(T message, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
- Task FuturePublishAsync<T>(T message, TimeSpan delay, string topic, CancellationToken cancellationToken = default)
public interface ISendConfiguration
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)
- AwaitableDisposable<IDisposable> ReceiveAsync<T>(string queue, Func<T, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
- AwaitableDisposable<IDisposable> ReceiveAsync(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
- Task SendAsync<T>(string queue, T message, CancellationToken cancellationToken = default)
public interface ISerializer
- object BytesToMessage(Type messageType, ReadOnlyMemory bytes)
- IMemoryOwner<byte> MessageToBytes(Type messageType, object message)
- object BytesToMessage(Type messageType, byte[] bytes)
- byte[] MessageToBytes(Type messageType, object message)
public interface ISimpleConsumeConfiguration
public interface ISubscriptionConfiguration
- ISubscriptionConfiguration WithAlternateExchange(string alternateExchange)
- ISubscriptionConfiguration WithExchangeType(string exchangeType)
- ISubscriptionConfiguration WithQueueType(string queueType = "classic")
- ISubscriptionConfiguration WithSingleActiveConsumer(bool singleActiveConsumer = true)
public interface ISubscriptionResult : IDisposable
- IDisposable ConsumerCancellation { get; }
- IExchange Exchange { get; }
- IQueue Queue { get; }
public interface ITypeNameSerializer
- Type Deserialize(string typeName)
- Type DeSerialize(string typeName)
public class JsonSerializer : ISerializer
- public JsonSerializer(object serializerSettings = null)
- public object BytesToMessage(Type messageType, ref ReadOnlyMemory bytes)
- public IMemoryOwner<byte> MessageToBytes(Type messageType, object message)
- public JsonSerializer()
- public JsonSerializer(JsonSerializerSettings serializerSettings)
- public object BytesToMessage(Type messageType, byte[] bytes)
- public byte[] MessageToBytes(Type messageType, object message)
public class LegacyTypeNameSerializer : ITypeNameSerializer
- public Type Deserialize(string typeName)
- public Type DeSerialize(string typeName)
public static class LinqExtensions
- 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 MessageNotAvailableException : Exception
- public MessageNotAvailableException()
- public MessageNotAvailableException(string message)
- public MessageNotAvailableException(string message, Exception inner)
public class MessageProperties
- public TimeSpan? Expiration { get; set; }
- public string Expiration { get; set; }
- public MessageProperties(IBasicProperties basicProperties)
- public void CopyFrom(IBasicProperties basicProperties)
- public void CopyTo(IBasicProperties basicProperties)
public class MessageReceivedInfo
- public ulong DeliveryTag { get; }
- public ulong DeliverTag { get; set; }
- public MessageReceivedInfo()
public class MessageReturnedEventArgs : EventArgs
- public ReadOnlyMemory<byte> MessageBody { get; }
- public byte[] MessageBody { get; }
- public MessageReturnedEventArgs(ref ReadOnlyMemory messageBody, MessageProperties messageProperties, ref MessageReturnedInfo messageReturnedInfo)
- public MessageReturnedEventArgs(byte[] messageBody, MessageProperties messageProperties, MessageReturnedInfo messageReturnedInfo)
public static class NonGenericPubSubExtensions
public static class NonGenericRpcExtensions
public static class NonGenericSchedulerExtensions
public static class NonGenericSendReceiveExtensions
public static class OverflowType
public static class PerQueueConsumeConfigurationExtensions
public struct ProducedMessage
public class PersistentConnection : IPersistentConnection, IDisposable
- public bool IsConnected { get; }
- public PersistentConnection(ConnectionConfiguration configuration, IConnectionFactory connectionFactory, IEventBus eventBus)
- public IModel CreateModel()
- public void Dispose()
public static class PubSubExtensions
- 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 static ISubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, CancellationToken cancellationToken = default)
- public static ISubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
- public static ISubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
- public static ISubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<ISubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<ISubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<ISubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
public struct PullBatchResult<TPullResult> : IDisposable where TPullResult : IPullResult
public class PullingConsumer : IPullingConsumer<PullResult>, IDisposable
public class PullingConsumer<T> : IPullingConsumer<PullResult<T>>, IDisposable
public static class PullingConsumerExtensions
public class PullingConsumerFactory : IPullingConsumerFactory
public struct PullingConsumerOptions
public struct PullResult : IPullResult, IDisposable
public struct PullResult<T> : IPullResult, IDisposable
public class QueueAttribute : Attribute
- public string Name { get; set; }
- public string Type { get; set; }
- public QueueAttribute()
- public string ExchangeName { get; set; }
- public string QueueName { get; }
- public QueueAttribute(string queueName)
public class QueueConsumerPair
- public Action<IHandlerRegistration> AddHandlers { get; }
- public Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> OnMessage { get; }
- public IQueue Queue { get; }
- public static QueueConsumerPair Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)
- public static QueueConsumerPair Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
- public static QueueConsumerPair Create<T>(IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage)
- public static QueueConsumerPair Create<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
public static class QueueDeclareConfigurationExtensions
- public static IQueueDeclareConfiguration WithDeadLetterExchange(this IQueueDeclareConfiguration configuration, Exchange deadLetterExchange)
- public static IQueueDeclareConfiguration WithDeadLetterExchange(this IQueueDeclareConfiguration configuration, IExchange deadLetterExchange)
- public static IQueueDeclareConfiguration WithDeadLetterStrategy(this IQueueDeclareConfiguration configuration, string deadLetterStrategy = "at-most-once")
- 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 WithQueueType(this IQueueDeclareConfiguration configuration, string queueType = "classic")
- public static IQueueDeclareConfiguration WithSingleActiveConsumer(this IQueueDeclareConfiguration configuration, bool singleActiveConsumer = true)
public static class QueueMasterLocator
public struct QueueStats
public static class QueueType
public sealed delegate QueueTypeConvention : MulticastDelegate
public class RabbitAdvancedBus : IAdvancedBus, IDisposable
- 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 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 event EventHandler Unblocked
- public RabbitAdvancedBus(IPersistentConnection connection, IConsumerFactory consumerFactory, IClientCommandDispatcher clientCommandDispatcher, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IServiceResolver container, ConnectionConfiguration configuration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, AdvancedBusEventHandlers advancedBusEventHandlers)
- 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> arguments, 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> arguments, 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 virtual Task ExchangeBindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public Task<Exchange> ExchangeDeclareAsync(string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public Task<IExchange> ExchangeDeclareAsync(string name, Action<IExchangeDeclareConfiguration> configure, 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 virtual Task QueueBindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public Task<Queue> QueueDeclareAsync(CancellationToken cancellationToken)
- public Task<Queue> QueueDeclareAsync(string name, Action<IQueueDeclareConfiguration> configure, 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)
- 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, Action<IQueueDeclareConfiguration> configure, 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 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 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 sealed delegate RpcReturnQueueNamingConvention : MulticastDelegate
- public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
- public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
- public virtual string Invoke(Type messageType)
- public virtual string Invoke()
public static class SendReceiveExtensions
- 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, Action<T> onMessage, Action<IConsumerConfiguration> configure, 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<T>(this ISendReceive sendReceive, string queue, Func<T, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure, 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, Action<IReceiveConfiguration> configure, CancellationToken cancellationToken)
- public static IDisposable Receive(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure, 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, Action<T> onMessage, Action<IConsumerConfiguration> configure, 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 class SerializedMessage
- public ReadOnlyMemory<byte> Body { get; }
- public byte[] Body { get; }
- public SerializedMessage(MessageProperties properties, IMemoryOwner<byte> body)
- public void Dispose()
- public SerializedMessage(MessageProperties properties, byte[] body)
public static class ServiceRegisterExtensions
- 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 EnableDeadLetterExchangeAndMessageTtlScheduler(this IServiceRegister serviceRegister)
- public static IInterceptorRegistrator EnableGZipCompression(this IInterceptorRegistrator registrator)
- public static IServiceRegister EnableInterception(this IServiceRegister serviceRegister, Action<IInterceptorRegistrator> configure)
- public static void RegisterDefaultServices(this IServiceRegister serviceRegister, Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory)
- public static IInterceptorRegistrator EnableTripleDESEncryption(this IInterceptorRegistrator registrator, byte[] key, byte[] iv)
- public static void RegisterDefaultServices(this IServiceRegister serviceRegister)
public static class SimpleConsumeConfigurationExtensions
public sealed class SubscriptionResult : ISubscriptionResult, IDisposable
- public Exchange Exchange { get; }
- public Queue Queue { get; }
- public SubscriptionResult(ref Exchange exchange, ref Queue queue, IDisposable consumerCancellation)
- public IDisposable ConsumerCancellation { get; }
- public IExchange Exchange { get; }
- public IQueue Queue { get; }
- public SubscriptionResult(IExchange exchange, IQueue queue, IDisposable consumerCancellation)
public sealed delegate TEventHandler<TEvent> : MulticastDelegate where TEvent : struct
public class UnblockedEventArgs : EventArgs

EasyNetQ.AutoSubscribe

public class AutoSubscriber
- public static string DefaultTopicName { get; set; }

EasyNetQ.DI

public class DefaultConsumeScopeProvider : IConsumeScopeProvider
public interface IConsumeScopeProvider
public class DefaultServiceContainer : IServiceRegister
- public DefaultServiceContainer()
- public IServiceRegister Register<TService, TImplementation>(Lifetime lifetime = 1) where TImplementation : TService
- public IServiceRegister Register<TService>(TService instance)
- public IServiceRegister Register<TService>(Func<IServiceResolver, TService> factory, Lifetime lifetime = 1)
- public TService Resolve<TService>()
public interface IServiceRegister
- IServiceRegister Register(Type serviceType, Type implementationType, Lifetime lifetime = 1)
- IServiceRegister Register(Type serviceType, Func<IServiceResolver, object> implementationFactory, Lifetime lifetime = 1)
- IServiceRegister Register(Type serviceType, object implementationInstance)
- IServiceRegister TryRegister(Type serviceType, Type implementationType, Lifetime lifetime = 1)
- IServiceRegister TryRegister(Type serviceType, Func<IServiceResolver, object> implementationFactory, Lifetime lifetime = 1)
- IServiceRegister TryRegister(Type serviceType, object implementationInstance)
- 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)
public class NoopConsumeScopeProvider : IConsumeScopeProvider
public static class ServiceRegisterExtensions

EasyNetQ.Events

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

EasyNetQ.Interception

public class CompositeProduceConsumerInterceptor : IProduceConsumeInterceptor
public class CompositeInterceptor : IProduceConsumeInterceptor
- public CompositeInterceptor()
- public void Add(IProduceConsumeInterceptor interceptor)
- public RawMessage OnConsume(RawMessage rawMessage)
- public RawMessage OnProduce(RawMessage rawMessage)
public class DefaultInterceptor : IProduceConsumeInterceptor
- public DefaultInterceptor()
- public RawMessage OnConsume(RawMessage rawMessage)
- public RawMessage OnProduce(RawMessage rawMessage)
public class GZipInterceptor : IProduceConsumeInterceptor
- public ConsumedMessage OnConsume(ref ConsumedMessage message)
- public ProducedMessage OnProduce(ref ProducedMessage message)
- public RawMessage OnConsume(RawMessage rawMessage)
- public RawMessage OnProduce(RawMessage rawMessage)
public interface IInterceptorRegistrator
- void Add(IProduceConsumeInterceptor interceptor)
public class InterceptorRegistrator : IInterceptorRegistrator
- public InterceptorRegistrator(IServiceRegister serviceRegister)
- public void Add(IProduceConsumeInterceptor interceptor)
- public IServiceRegister Register()
public interface IProduceConsumeInterceptor
- ConsumedMessage OnConsume(ConsumedMessage& modreq(System.Runtime.InteropServices.InAttribute) message)
- ProducedMessage OnProduce(ProducedMessage& modreq(System.Runtime.InteropServices.InAttribute) message)
- RawMessage OnConsume(RawMessage rawMessage)
- RawMessage OnProduce(RawMessage rawMessage)
public struct RawMessage
- public byte[] Body { get; }
- public MessageProperties Properties { get; }
- public RawMessage(MessageProperties properties, byte[] body)
public class TripleDESInterceptor : IProduceConsumeInterceptor
- public ConsumedMessage OnConsume(ref ConsumedMessage message)
- public ProducedMessage OnProduce(ref ProducedMessage message)
- public RawMessage OnConsume(RawMessage rawMessage)
- public RawMessage OnProduce(RawMessage rawMessage)

EasyNetQ.Internals

public sealed class ArrayPooledMemoryStream : Stream, IMemoryOwner<byte>, IDisposable
public sealed class AsyncCountdownEvent : IDisposable
public sealed class AsyncLock : IDisposable
- public struct Releaser : IDisposable
- public Releaser Acquire(CancellationToken cancellationToken = default)
- public Task<Releaser> AcquireAsync(CancellationToken cancellationToken = default)
- public Task<IDisposable> AcquireAsync(CancellationToken cancellationToken = default)
public static class CancellationTokenExtensions
- public struct ValueCancellationTokenSource : IDisposable
- public static ValueCancellationTokenSource WithTimeout(this CancellationToken cancellationToken, TimeSpan timeout)
- public static CancellationTokenSource WithTimeout(this CancellationToken cancellationToken, TimeSpan timeout)
public static class DictionaryExtensions
public sealed class ConcurrentSet<T> : IEnumerable<T>, IEnumerable
- public ConcurrentSet()
- public void Add(T element)
- public void Clear()
- public IEnumerator<T> GetEnumerator()
- public void Remove(T element)
public static class EnumerableExtensions
public class NoResult : IEquatable<NoResult>
public sealed class ReadOnlyMemoryStream : Stream
public static class ReflectionHelpers
public static class Timers
- public static IDisposable Start(Action callback, TimeSpan dueTime, TimeSpan period, ILogger logger)
- public static IDisposable Start(Action callback, TimeSpan dueTime, TimeSpan period)
public static class UriExtensions

EasyNetQ.LightInject

public class AssemblyScanner : IAssemblyScanner
- public AssemblyScanner(ITypeExtractor concreteTypeExtractor, ITypeExtractor compositionRootTypeExtractor, ICompositionRootExecutor compositionRootExecutor, IGenericArgumentMapper genericArgumentMapper)
- public void Scan(Assembly assembly, IServiceRegistry serviceRegistry, Func<ILifetime> lifetimeFactory, Func<Type, Type, bool> shouldRegister, Func<Type, Type, string> serviceNameProvider)
- public void Scan(Assembly assembly, IServiceRegistry serviceRegistry)
public class CachedTypeExtractor : ITypeExtractor
- public CachedTypeExtractor(ITypeExtractor typeExtractor)
- public Type[] Execute(Assembly assembly)
public class CompositionRootAttributeExtractor : ICompositionRootAttributeExtractor
- public CompositionRootAttributeExtractor()
- public CompositionRootTypeAttribute[] GetAttributes(Assembly assembly)
public class CompositionRootExecutor : ICompositionRootExecutor
- public CompositionRootExecutor(IServiceRegistry serviceRegistry, Func<Type, ICompositionRoot> activator)
- public void Execute(Type compositionRootType)
public class CompositionRootTypeAttribute : Attribute
- public Type CompositionRootType { get; }
- public CompositionRootTypeAttribute(Type compositionRootType)
public class CompositionRootTypeExtractor : ITypeExtractor
- public CompositionRootTypeExtractor(ICompositionRootAttributeExtractor compositionRootAttributeExtractor)
- public Type[] Execute(Assembly assembly)
public class ConcreteTypeExtractor : ITypeExtractor
- public ConcreteTypeExtractor()
- public Type[] Execute(Assembly assembly)
public class ConstructionInfo
- public ConstructorInfo Constructor { get; set; }
- public List<ConstructorDependency> ConstructorDependencies { get; }
- public Delegate FactoryDelegate { get; set; }
- public Type ImplementingType { get; set; }
- public List<PropertyDependency> PropertyDependencies { get; }
- public ConstructionInfo()
public class ConstructionInfoProvider : IConstructionInfoProvider
- public ConstructionInfoProvider(IConstructionInfoBuilder constructionInfoBuilder)
- public ConstructionInfo GetConstructionInfo(Registration registration)
public class ConstructorDependency : Dependency
- public bool IsDecoratorTarget { get; set; }
- public ParameterInfo Parameter { get; set; }
- public ConstructorDependency()
public class ConstructorDependencySelector : IConstructorDependencySelector
- public ConstructorDependencySelector()
- public virtual IEnumerable<ConstructorDependency> Execute(ConstructorInfo constructor)
public class ContainerOptions
- public static ContainerOptions Default { get; }
- public bool EnablePropertyInjection { get; set; }
- public bool EnableVariance { get; set; }
- public Func<Type, Action<LogEntry>> LogFactory { get; set; }
- public ContainerOptions()
public class DecoratorRegistration : Registration
- public Func<ServiceRegistration, bool> CanDecorate { get; set; }
- public bool HasDeferredImplementingType { get; }
- public Func<IServiceFactory, ServiceRegistration, Type> ImplementingTypeFactory { get; set; }
- public int Index { get; set; }
- public DecoratorRegistration()
public abstract class Dependency
- public Delegate FactoryExpression { get; set; }
- public bool IsRequired { get; set; }
- public abstract string Name { get; }
- public string ServiceName { get; set; }
- public Type ServiceType { get; set; }
- protected Dependency()
public class DynamicMethod
- public DynamicMethod(Type returnType, Type[] parameterTypes)
- public Delegate CreateDelegate(Type delegateType)
- public Delegate CreateDelegate(Type delegateType, object target)
- public ILGenerator GetILGenerator()
public class Emitter : IEmitter
- public List<Instruction> Instructions { get; }
- public Type StackType { get; }
- public Emitter(ILGenerator generator, Type[] parameterTypes)
- public LocalBuilder DeclareLocal(Type type)
- public void Emit(OpCode code)
- public void Emit(OpCode code, int arg)
- public void Emit(OpCode code, sbyte arg)
- public void Emit(OpCode code, byte arg)
- public void Emit(OpCode code, Type type)
- public void Emit(OpCode code, ConstructorInfo constructor)
- public void Emit(OpCode code, LocalBuilder localBuilder)
- public void Emit(OpCode code, MethodInfo methodInfo)
public static class EmitterExtensions
- public static void Call(this IEmitter emitter, MethodInfo methodInfo)
- public static void Cast(this IEmitter emitter, Type type)
- public static void New(this IEmitter emitter, ConstructorInfo constructorInfo)
- public static void Push(this IEmitter emitter, LocalBuilder localBuilder)
- public static void Push(this IEmitter emitter, int value)
- public static void PushArgument(this IEmitter emitter, int index)
- public static void PushArguments(this IEmitter emitter, ParameterInfo[] parameters)
- public static void PushArrayElement(this IEmitter emitter)
- public static void PushConstant(this IEmitter emitter, int index, Type type)
- public static void PushConstant(this IEmitter emitter, int index)
- public static void PushNewArray(this IEmitter emitter, Type elementType)
- public static void Return(this IEmitter emitter)
- public static void Store(this IEmitter emitter, LocalBuilder localBuilder)
- public static void UnboxOrCast(this IEmitter emitter, Type type)
public static class Ensure
- public static void IsNotNull<T>(T value, string paramName)
public class ExcludeFromCodeCoverageAttribute : Attribute
- public ExcludeFromCodeCoverageAttribute()
public class GenericArgumentMapper : IGenericArgumentMapper
- public GenericArgumentMapper()
- public GenericMappingResult Map(Type genericServiceType, Type openGenericImplementingType)
public class GenericMappingResult
- public bool IsValid { get; }
- public Type[] GetMappedArguments()
public interface IAssemblyScanner
- void Scan(Assembly assembly, IServiceRegistry serviceRegistry, Func<ILifetime> lifetime, Func<Type, Type, bool> shouldRegister, Func<Type, Type, string> serviceNameProvider)
- void Scan(Assembly assembly, IServiceRegistry serviceRegistry)
public interface ICompositionRoot
- void Compose(IServiceRegistry serviceRegistry)
public interface ICompositionRootAttributeExtractor
- CompositionRootTypeAttribute[] GetAttributes(Assembly assembly)
public interface ICompositionRootExecutor
- void Execute(Type compositionRootType)
public interface IConstructionInfoBuilder
- ConstructionInfo Execute(Registration registration)
public interface IConstructionInfoProvider
- ConstructionInfo GetConstructionInfo(Registration registration)
public interface IConstructorDependencySelector
- IEnumerable<ConstructorDependency> Execute(ConstructorInfo constructor)
public interface IConstructorSelector
- ConstructorInfo Execute(Type implementingType)
public interface IEmitter
- List<Instruction> Instructions { get; }
- Type StackType { get; }
- LocalBuilder DeclareLocal(Type type)
- void Emit(OpCode code)
- void Emit(OpCode code, int arg)
- void Emit(OpCode code, sbyte arg)
- void Emit(OpCode code, byte arg)
- void Emit(OpCode code, Type type)
- void Emit(OpCode code, ConstructorInfo constructor)
- void Emit(OpCode code, LocalBuilder localBuilder)
- void Emit(OpCode code, MethodInfo methodInfo)
public interface IGenericArgumentMapper
- GenericMappingResult Map(Type genericServiceType, Type openGenericImplementingType)
public class ILGenerator
- public Expression CurrentExpression { get; }
- public ILGenerator(ParameterExpression[] parameters)
- public LocalBuilder DeclareLocal(Type type)
- public void Emit(OpCode code, ConstructorInfo constructor)
- public void Emit(OpCode code)
- public void Emit(OpCode code, LocalBuilder localBuilder)
- public void Emit(OpCode code, int arg)
- public void Emit(OpCode code, sbyte arg)
- public void Emit(OpCode code, byte arg)
- public void Emit(OpCode code, string arg)
- public void Emit(OpCode code, Type type)
- public void Emit(OpCode code, MethodInfo methodInfo)
public interface ILifetime
- object GetInstance(Func<object> createInstance, Scope scope)
public interface IMethodSkeleton
- Delegate CreateDelegate(Type delegateType)
- IEmitter GetEmitter()
public sealed class ImmutableHashTable<TKey, TValue>
- public static readonly ImmutableHashTable<TKey, TValue> Empty
- public readonly int Count
public static class ImmutableHashTableExtensions
- public static ImmutableHashTable<TKey, TValue> Add<TKey, TValue>(this ImmutableHashTable<TKey, TValue> hashTable, TKey key, TValue value)
- public static TValue Search<TKey, TValue>(this ImmutableHashTable<TKey, TValue> hashTable, TKey key)
public sealed class ImmutableHashTree<TKey, TValue>
- public static readonly ImmutableHashTree<TKey, TValue> Empty
- public readonly ImmutableList<KeyValue<TKey, TValue>> Duplicates
- public readonly int HashCode
- public readonly int Height
- public readonly bool IsEmpty
- public readonly TKey Key
- public readonly ImmutableHashTree<TKey, TValue> Left
- public readonly ImmutableHashTree<TKey, TValue> Right
- public readonly TValue Value
- public ImmutableHashTree(TKey key, TValue value, ImmutableHashTree<TKey, TValue> hashTree)
- public ImmutableHashTree(TKey key, TValue value, ImmutableHashTree<TKey, TValue> left, ImmutableHashTree<TKey, TValue> right)
public static class ImmutableHashTreeExtensions
- public static ImmutableHashTree<TKey, TValue> Add<TKey, TValue>(this ImmutableHashTree<TKey, TValue> tree, TKey key, TValue value)
- public static IEnumerable<KeyValue<TKey, TValue>> InOrder<TKey, TValue>(this ImmutableHashTree<TKey, TValue> hashTree)
- public static TValue Search<TKey, TValue>(this ImmutableHashTree<TKey, TValue> tree, TKey key)
public sealed class ImmutableList<T>
- public static readonly ImmutableList<T> Empty
- public readonly int Count
- public readonly T[] Items
- public ImmutableList(ImmutableList<T> previousList, T value)
- public ImmutableList<T> Add(T value)
public class Instruction
- public OpCode Code { get; }
- public Action<ILGenerator> Emit { get; }
- public Instruction(OpCode code, Action<ILGenerator> emitAction)
public class Instruction<T> : Instruction
- public T Argument { get; }
- public Instruction(OpCode code, T argument, Action<ILGenerator> emitAction)
public interface IPropertyDependencySelector
- IEnumerable<PropertyDependency> Execute(Type type)
public interface IPropertySelector
- IEnumerable<PropertyInfo> Execute(Type type)
public interface IScopeManager
- Scope CurrentScope { get; set; }
- IServiceFactory ServiceFactory { get; }
- Scope BeginScope()
- void EndScope(Scope scope)
public interface IScopeManagerProvider
- IScopeManager GetScopeManager(IServiceFactory serviceFactory)
public interface IServiceContainer : IServiceRegistry, IServiceFactory, IDisposable
- IScopeManagerProvider ScopeManagerProvider { get; set; }
- bool CanGetInstance(Type serviceType, string serviceName)
- object InjectProperties(object instance)
public interface IServiceFactory
- Scope BeginScope()
- object Create(Type serviceType)
- IEnumerable<object> GetAllInstances(Type serviceType)
- object GetInstance(Type serviceType)
- object GetInstance(Type serviceType, object[] arguments)
- object GetInstance(Type serviceType, string serviceName, object[] arguments)
- object GetInstance(Type serviceType, string serviceName)
- object TryGetInstance(Type serviceType)
- object TryGetInstance(Type serviceType, string serviceName)
public interface IServiceNameProvider
- string GetServiceName(Type serviceType, Type implementingType)
public interface IServiceRegistry
- IEnumerable<ServiceRegistration> AvailableServices { get; }
- IServiceRegistry Decorate(Type serviceType, Type decoratorType, Func<ServiceRegistration, bool> predicate)
- IServiceRegistry Decorate(Type serviceType, Type decoratorType)
- IServiceRegistry Decorate<TService, TDecorator>() where TDecorator : TService
- IServiceRegistry Decorate<TService>(Func<IServiceFactory, TService, TService> factory)
- IServiceRegistry Decorate(DecoratorRegistration decoratorRegistration)
- IServiceRegistry Initialize(Func<ServiceRegistration, bool> predicate, Action<IServiceFactory, object> processor)
- IServiceRegistry Override(Func<ServiceRegistration, bool> serviceSelector, Func<IServiceFactory, ServiceRegistration, ServiceRegistration> serviceRegistrationFactory)
- IServiceRegistry Register(Type serviceType, Type implementingType)
- IServiceRegistry Register(Type serviceType, Type implementingType, ILifetime lifetime)
- IServiceRegistry Register(Type serviceType, Type implementingType, string serviceName)
- IServiceRegistry Register(Type serviceType, Type implementingType, string serviceName, ILifetime lifetime)
- IServiceRegistry Register<TService, TImplementation>() where TImplementation : TService
- IServiceRegistry Register<TService, TImplementation>(ILifetime lifetime) where TImplementation : TService
- IServiceRegistry Register<TService, TImplementation>(string serviceName) where TImplementation : TService
- IServiceRegistry Register<TService, TImplementation>(string serviceName, ILifetime lifetime) where TImplementation : TService
- IServiceRegistry Register<TService>()
- IServiceRegistry Register<TService>(ILifetime lifetime)
- IServiceRegistry Register(Type serviceType)
- IServiceRegistry Register(Type serviceType, ILifetime lifetime)
- IServiceRegistry Register<TService>(Func<IServiceFactory, TService> factory)
- IServiceRegistry Register<T, TService>(Func<IServiceFactory, T, TService> factory)
- IServiceRegistry Register<T, TService>(Func<IServiceFactory, T, TService> factory, string serviceName)
- IServiceRegistry Register<T1, T2, TService>(Func<IServiceFactory, T1, T2, TService> factory)
- IServiceRegistry Register<T1, T2, TService>(Func<IServiceFactory, T1, T2, TService> factory, string serviceName)
- IServiceRegistry Register<T1, T2, T3, TService>(Func<IServiceFactory, T1, T2, T3, TService> factory)
- IServiceRegistry Register<T1, T2, T3, TService>(Func<IServiceFactory, T1, T2, T3, TService> factory, string serviceName)
- IServiceRegistry Register<T1, T2, T3, T4, TService>(Func<IServiceFactory, T1, T2, T3, T4, TService> factory)
- IServiceRegistry Register<T1, T2, T3, T4, TService>(Func<IServiceFactory, T1, T2, T3, T4, TService> factory, string serviceName)
- IServiceRegistry Register<TService>(Func<IServiceFactory, TService> factory, ILifetime lifetime)
- IServiceRegistry Register<TService>(Func<IServiceFactory, TService> factory, string serviceName)
- IServiceRegistry Register<TService>(Func<IServiceFactory, TService> factory, string serviceName, ILifetime lifetime)
- IServiceRegistry Register(ServiceRegistration serviceRegistration)
- IServiceRegistry RegisterAssembly(Assembly assembly)
- IServiceRegistry RegisterAssembly(Assembly assembly, Func<Type, Type, bool> shouldRegister)
- IServiceRegistry RegisterAssembly(Assembly assembly, Func<ILifetime> lifetimeFactory)
- IServiceRegistry RegisterAssembly(Assembly assembly, Func<ILifetime> lifetimeFactory, Func<Type, Type, bool> shouldRegister)
- IServiceRegistry RegisterAssembly(Assembly assembly, Func<ILifetime> lifetimeFactory, Func<Type, Type, bool> shouldRegister, Func<Type, Type, string> serviceNameProvider)
- IServiceRegistry RegisterConstructorDependency<TDependency>(Func<IServiceFactory, ParameterInfo, TDependency> factory)
- IServiceRegistry RegisterConstructorDependency<TDependency>(Func<IServiceFactory, ParameterInfo, object[], TDependency> factory)
- IServiceRegistry RegisterFallback(Func<Type, string, bool> predicate, Func<ServiceRequest, object> factory)
- IServiceRegistry RegisterFallback(Func<Type, string, bool> predicate, Func<ServiceRequest, object> factory, ILifetime lifetime)
- IServiceRegistry RegisterFrom<TCompositionRoot>() where TCompositionRoot : ICompositionRoot
- IServiceRegistry RegisterInstance<TService>(TService instance)
- IServiceRegistry RegisterInstance<TService>(TService instance, string serviceName)
- IServiceRegistry RegisterInstance(Type serviceType, object instance)
- IServiceRegistry RegisterInstance(Type serviceType, object instance, string serviceName)
- IServiceRegistry RegisterOrdered(Type serviceType, Type[] implementingTypes, Func<Type, ILifetime> lifetimeFactory)
- IServiceRegistry RegisterOrdered(Type serviceType, Type[] implementingTypes, Func<Type, ILifetime> lifeTimeFactory, Func<int, string> serviceNameFormatter)
- IServiceRegistry RegisterPropertyDependency<TDependency>(Func<IServiceFactory, PropertyInfo, TDependency> factory)
- IServiceRegistry SetDefaultLifetime<T>() where T : ILifetime
public interface ITypeConstructionInfoBuilder
- ConstructionInfo Execute(Registration registration)
public interface ITypeExtractor
- Type[] Execute(Assembly assembly)
public sealed class KeyValue<TKey, TValue>
- public readonly TKey Key
- public readonly TValue Value
- public KeyValue(TKey key, TValue value)
public class LocalBuilder
- public int LocalIndex { get; }
- public Type LocalType { get; }
- public ParameterExpression Variable { get; }
- public LocalBuilder(Type type, int localIndex)
public class LogEntry
- public LogLevel Level { get; }
- public string Message { get; }
- public LogEntry(LogLevel level, string message)
public static class LogExtensions
- public static void Info(this Action<LogEntry> logAction, string message)
- public static void Warning(this Action<LogEntry> logAction, string message)
public class LogicalThreadStorage<T>
- public T Value { get; set; }
- public LogicalThreadStorage()
public enum LogLevel
- Info = 0
- Warning = 1
public class MostResolvableConstructorSelector : IConstructorSelector
- public MostResolvableConstructorSelector(Func<Type, string, bool> canGetInstance)
- public ConstructorInfo Execute(Type implementingType)
- protected virtual string GetServiceName(ParameterInfo parameter)
public class PerContainerLifetime : ILifetime, IDisposable
- public PerContainerLifetime()
- public void Dispose()
- public object GetInstance(Func<object> createInstance, Scope scope)
public class PerLogicalCallContextScopeManager : ScopeManager
- public PerLogicalCallContextScopeManager(IServiceFactory serviceFactory)
public class PerLogicalCallContextScopeManagerProvider : ScopeManagerProvider
- public PerLogicalCallContextScopeManagerProvider()
public class PerRequestLifeTime : ILifetime
- public PerRequestLifeTime()
- public object GetInstance(Func<object> createInstance, Scope scope)
public class PerScopeLifetime : ILifetime
- public PerScopeLifetime()
- public object GetInstance(Func<object> createInstance, Scope scope)
public class PerThreadScopeManager : ScopeManager
- public PerThreadScopeManager(IServiceFactory serviceFactory)
public class PerThreadScopeManagerProvider : ScopeManagerProvider
- public PerThreadScopeManagerProvider()
public class PropertyDependency : Dependency
- public PropertyInfo Property { get; set; }
- public PropertyDependency()
public class PropertyDependencySelector : IPropertyDependencySelector
- protected IPropertySelector PropertySelector { get; }
- public PropertyDependencySelector(IPropertySelector propertySelector)
- public virtual IEnumerable<PropertyDependency> Execute(Type type)
public class PropertySelector : IPropertySelector
- public PropertySelector()
- public IEnumerable<PropertyInfo> Execute(Type type)
- protected virtual bool IsInjectable(PropertyInfo propertyInfo)
public abstract class Registration
- public Delegate FactoryExpression { get; set; }
- public virtual Type ImplementingType { get; set; }
- public Type ServiceType { get; set; }
- protected Registration()
public static class RuntimeArgumentsLoader
- public static object[] Load(object[] constants)
public class Scope : IServiceFactory, IDisposable
- public Scope ChildScope { get; }
- public bool IsDisposed { get; set; }
- public Scope ParentScope { get; }
- public event EventHandler<EventArgs> Completed
- public Scope(IScopeManager scopeManager, Scope parentScope)
- public Scope BeginScope()
- public object Create(Type serviceType)
- public void Dispose()
- public IEnumerable<object> GetAllInstances(Type serviceType)
- public object GetInstance(Type serviceType)
- public object GetInstance(Type serviceType, string serviceName)
- public object GetInstance(Type serviceType, object[] arguments)
- public object GetInstance(Type serviceType, string serviceName, object[] arguments)
- public void TrackInstance(IDisposable disposable)
- public object TryGetInstance(Type serviceType)
- public object TryGetInstance(Type serviceType, string serviceName)
public abstract class ScopeManager : IScopeManager
- public abstract Scope CurrentScope { get; set; }
- public IServiceFactory ServiceFactory { get; }
- protected ScopeManager(IServiceFactory serviceFactory)
- public Scope BeginScope()
- public void EndScope(Scope scope)
- protected Scope GetThisScopeOrFirstValidAncestor(Scope scope)
public abstract class ScopeManagerProvider : IScopeManagerProvider
- protected ScopeManagerProvider()
- protected abstract IScopeManager CreateScopeManager(IServiceFactory serviceFactory)
- public IScopeManager GetScopeManager(IServiceFactory serviceFactory)
public class ServiceContainer : IServiceContainer, IServiceRegistry, IServiceFactory, IDisposable
- public IAssemblyScanner AssemblyScanner { get; set; }
- public IEnumerable<ServiceRegistration> AvailableServices { get; }
- public ICompositionRootExecutor CompositionRootExecutor { get; set; }
- public ITypeExtractor CompositionRootTypeExtractor { get; set; }
- public IConstructorDependencySelector ConstructorDependencySelector { get; set; }
- public IConstructorSelector ConstructorSelector { get; set; }
- public IGenericArgumentMapper GenericArgumentMapper { get; set; }
- public IPropertyDependencySelector PropertyDependencySelector { get; set; }
- public IScopeManagerProvider ScopeManagerProvider { get; set; }
- public IServiceNameProvider ServiceNameProvider { get; set; }
- public ServiceContainer()
- public ServiceContainer(ContainerOptions options)
- public Scope BeginScope()
- public bool CanGetInstance(Type serviceType, string serviceName)
- public ServiceContainer Clone()
- public object Create(Type serviceType)
- public IServiceRegistry Decorate(Type serviceType, Type decoratorType, Func<ServiceRegistration, bool> predicate)
- public IServiceRegistry Decorate(Type serviceType, Type decoratorType)
- public IServiceRegistry Decorate<TService, TDecorator>() where TDecorator : TService
- public IServiceRegistry Decorate<TService>(Func<IServiceFactory, TService, TService> factory)
- public IServiceRegistry Decorate(DecoratorRegistration decoratorRegistration)
- public void Dispose()
- public IEnumerable<object> GetAllInstances(Type serviceType)
- public object GetInstance(Type serviceType)
- public object GetInstance(Type serviceType, object[] arguments)
- public object GetInstance(Type serviceType, string serviceName, object[] arguments)
- public object GetInstance(Type serviceType, string serviceName)
- public IServiceRegistry Initialize(Func<ServiceRegistration, bool> predicate, Action<IServiceFactory, object> processor)
- public object InjectProperties(object instance)
- public IServiceRegistry Override(Func<ServiceRegistration, bool> serviceSelector, Func<IServiceFactory, ServiceRegistration, ServiceRegistration> serviceRegistrationFactory)
- public IServiceRegistry Register<TService>(Func<IServiceFactory, TService> factory, string serviceName, ILifetime lifetime)
- public IServiceRegistry Register(ServiceRegistration serviceRegistration)
- public IServiceRegistry Register(Type serviceType, Type implementingType, ILifetime lifetime)
- public IServiceRegistry Register(Type serviceType, Type implementingType, string serviceName, ILifetime lifetime)
- public IServiceRegistry Register<TService, TImplementation>() where TImplementation : TService
- public IServiceRegistry Register<TService, TImplementation>(ILifetime lifetime) where TImplementation : TService
- public IServiceRegistry Register<TService, TImplementation>(string serviceName) where TImplementation : TService
- public IServiceRegistry Register<TService, TImplementation>(string serviceName, ILifetime lifetime) where TImplementation : TService
- public IServiceRegistry Register<TService>(Func<IServiceFactory, TService> factory, ILifetime lifetime)
- public IServiceRegistry Register<TService>(Func<IServiceFactory, TService> factory, string serviceName)
- public IServiceRegistry Register<TService>()
- public IServiceRegistry Register(Type serviceType)
- public IServiceRegistry Register(Type serviceType, ILifetime lifetime)
- public IServiceRegistry Register<TService>(ILifetime lifetime)
- public IServiceRegistry Register<TService>(Func<IServiceFactory, TService> factory)
- public IServiceRegistry Register<T, TService>(Func<IServiceFactory, T, TService> factory)
- public IServiceRegistry Register<T, TService>(Func<IServiceFactory, T, TService> factory, string serviceName)
- public IServiceRegistry Register<T1, T2, TService>(Func<IServiceFactory, T1, T2, TService> factory)
- public IServiceRegistry Register<T1, T2, TService>(Func<IServiceFactory, T1, T2, TService> factory, string serviceName)
- public IServiceRegistry Register<T1, T2, T3, TService>(Func<IServiceFactory, T1, T2, T3, TService> factory)
- public IServiceRegistry Register<T1, T2, T3, TService>(Func<IServiceFactory, T1, T2, T3, TService> factory, string serviceName)
- public IServiceRegistry Register<T1, T2, T3, T4, TService>(Func<IServiceFactory, T1, T2, T3, T4, TService> factory)
- public IServiceRegistry Register<T1, T2, T3, T4, TService>(Func<IServiceFactory, T1, T2, T3, T4, TService> factory, string serviceName)
- public IServiceRegistry Register(Type serviceType, Type implementingType, string serviceName)
- public IServiceRegistry Register(Type serviceType, Type implementingType)
- public IServiceRegistry RegisterAssembly(Assembly assembly)
- public IServiceRegistry RegisterAssembly(Assembly assembly, Func<Type, Type, bool> shouldRegister)
- public IServiceRegistry RegisterAssembly(Assembly assembly, Func<ILifetime> lifetimeFactory)
- public IServiceRegistry RegisterAssembly(Assembly assembly, Func<ILifetime> lifetimeFactory, Func<Type, Type, bool> shouldRegister)
- public IServiceRegistry RegisterAssembly(Assembly assembly, Func<ILifetime> lifetimeFactory, Func<Type, Type, bool> shouldRegister, Func<Type, Type, string> serviceNameProvider)
- public IServiceRegistry RegisterConstructorDependency<TDependency>(Func<IServiceFactory, ParameterInfo, TDependency> factory)
- public IServiceRegistry RegisterConstructorDependency<TDependency>(Func<IServiceFactory, ParameterInfo, object[], TDependency> factory)
- public IServiceRegistry RegisterFallback(Func<Type, string, bool> predicate, Func<ServiceRequest, object> factory)
- public IServiceRegistry RegisterFallback(Func<Type, string, bool> predicate, Func<ServiceRequest, object> factory, ILifetime lifetime)
- public IServiceRegistry RegisterFrom<TCompositionRoot>() where TCompositionRoot : ICompositionRoot
- public IServiceRegistry RegisterInstance<TService>(TService instance, string serviceName)
- public IServiceRegistry RegisterInstance<TService>(TService instance)
- public IServiceRegistry RegisterInstance(Type serviceType, object instance)
- public IServiceRegistry RegisterInstance(Type serviceType, object instance, string serviceName)
- public IServiceRegistry RegisterOrdered(Type serviceType, Type[] implementingTypes, Func<Type, ILifetime> lifeTimeFactory)
- public IServiceRegistry RegisterOrdered(Type serviceType, Type[] implementingTypes, Func<Type, ILifetime> lifeTimeFactory, Func<int, string> serviceNameFormatter)
- public IServiceRegistry RegisterPropertyDependency<TDependency>(Func<IServiceFactory, PropertyInfo, TDependency> factory)
- public IServiceRegistry SetDefaultLifetime<T>() where T : ILifetime
- public object TryGetInstance(Type serviceType)
- public object TryGetInstance(Type serviceType, string serviceName)
public static class ServiceFactoryExtensions
- public static TService Create<TService>(this IServiceFactory factory)
- public static IEnumerable<TService> GetAllInstances<TService>(this IServiceFactory factory)
- public static TService GetInstance<TService>(this IServiceFactory factory)
- public static TService GetInstance<TService>(this IServiceFactory factory, string serviceName)
- public static TService GetInstance<T, TService>(this IServiceFactory factory, T value)
- public static TService GetInstance<T, TService>(this IServiceFactory factory, T value, string serviceName)
- public static TService GetInstance<T1, T2, TService>(this IServiceFactory factory, T1 arg1, T2 arg2)
- public static TService GetInstance<T1, T2, TService>(this IServiceFactory factory, T1 arg1, T2 arg2, string serviceName)
- public static TService GetInstance<T1, T2, T3, TService>(this IServiceFactory factory, T1 arg1, T2 arg2, T3 arg3)
- public static TService GetInstance<T1, T2, T3, TService>(this IServiceFactory factory, T1 arg1, T2 arg2, T3 arg3, string serviceName)
- public static TService GetInstance<T1, T2, T3, T4, TService>(this IServiceFactory factory, T1 arg1, T2 arg2, T3 arg3, T4 arg4)
- public static TService GetInstance<T1, T2, T3, T4, TService>(this IServiceFactory factory, T1 arg1, T2 arg2, T3 arg3, T4 arg4, string serviceName)
- public static TService TryGetInstance<TService>(this IServiceFactory factory)
- public static TService TryGetInstance<TService>(this IServiceFactory factory, string serviceName)
public class ServiceNameProvider : IServiceNameProvider
- public ServiceNameProvider()
- public string GetServiceName(Type serviceType, Type implementingType)
public class ServiceRegistration : Registration
- public ILifetime Lifetime { get; set; }
- public string ServiceName { get; set; }
- public object Value { get; set; }
- public ServiceRegistration()
public class ServiceRequest
- public IServiceFactory ServiceFactory { get; }
- public string ServiceName { get; }
- public Type ServiceType { get; }
- public ServiceRequest(Type serviceType, string serviceName, IServiceFactory serviceFactory)
public class ThreadSafeDictionary<TKey, TValue> : ConcurrentDictionary<TKey, TValue>
- public ThreadSafeDictionary()
- public ThreadSafeDictionary(IEqualityComparer<TKey> comparer)
public class TypeConstructionInfoBuilder : IConstructionInfoBuilder
- public TypeConstructionInfoBuilder(IConstructorSelector constructorSelector, IConstructorDependencySelector constructorDependencySelector, IPropertyDependencySelector propertyDependencySelector, Func<Type, string, Delegate> getConstructorDependencyExpression, Func<Type, string, Delegate> getPropertyDependencyExpression)
- public ConstructionInfo Execute(Registration registration)

EasyNetQ.Logging

public class ConsoleLogger : ILogger
public class ConsoleLogger<TCategoryName> : ConsoleLogger, ILogger<TCategoryName>, ILogger
public interface ILogger
public interface ILogger<TCategoryName> : ILogger
public static class LoggerExtensions
public class ConsoleLogProvider : ILogProvider
- public static ConsoleLogProvider Instance
- public Logger GetLogger(string name)
- public IDisposable OpenMappedContext(string key, object value, bool destructure = false)
- public IDisposable OpenNestedContext(string message)
public interface ILog
- bool Log(LogLevel logLevel, Func<string> messageFunc, Exception exception = null, object[] formatParameters)
public interface ILogProvider
- Logger GetLogger(string name)
- IDisposable OpenMappedContext(string key, object value, bool destructure = false)
- IDisposable OpenNestedContext(string message)
public static class LogExtensions
- public static void Debug(this ILog logger, Func<string> messageFunc)
- public static void Debug(this ILog logger, string message)
- public static void Debug(this ILog logger, string message, object[] args)
- public static void Debug(this ILog logger, Exception exception, string message, object[] args)
- public static void DebugException(this ILog logger, string message, Exception exception)
- public static void DebugException(this ILog logger, string message, Exception exception, object[] args)
- public static void DebugFormat(this ILog logger, string message, object[] args)
- public static void Error(this ILog logger, Func<string> messageFunc)
- public static void Error(this ILog logger, string message)
- public static void Error(this ILog logger, string message, object[] args)
- public static void Error(this ILog logger, Exception exception, string message, object[] args)
- public static void ErrorException(this ILog logger, string message, Exception exception, object[] args)
- public static void ErrorFormat(this ILog logger, string message, object[] args)
- public static void Fatal(this ILog logger, Func<string> messageFunc)
- public static void Fatal(this ILog logger, string message)
- public static void Fatal(this ILog logger, string message, object[] args)
- public static void Fatal(this ILog logger, Exception exception, string message, object[] args)
- public static void FatalException(this ILog logger, string message, Exception exception, object[] args)
- public static void FatalFormat(this ILog logger, string message, object[] args)
- public static void Info(this ILog logger, Func<string> messageFunc)
- public static void Info(this ILog logger, string message)
- public static void Info(this ILog logger, string message, object[] args)
- public static void Info(this ILog logger, Exception exception, string message, object[] args)
- public static void InfoException(this ILog logger, string message, Exception exception, object[] args)
- public static void InfoFormat(this ILog logger, string message, object[] args)
- public static bool IsDebugEnabled(this ILog logger)
- public static bool IsErrorEnabled(this ILog logger)
- public static bool IsFatalEnabled(this ILog logger)
- public static bool IsInfoEnabled(this ILog logger)
- public static bool IsTraceEnabled(this ILog logger)
- public static bool IsWarnEnabled(this ILog logger)
- public static void Trace(this ILog logger, Func<string> messageFunc)
- public static void Trace(this ILog logger, string message)
- public static void Trace(this ILog logger, string message, object[] args)
- public static void Trace(this ILog logger, Exception exception, string message, object[] args)
- public static void TraceException(this ILog logger, string message, Exception exception, object[] args)
- public static void TraceFormat(this ILog logger, string message, object[] args)
- public static void Warn(this ILog logger, Func<string> messageFunc)
- public static void Warn(this ILog logger, string message)
- public static void Warn(this ILog logger, string message, object[] args)
- public static void Warn(this ILog logger, Exception exception, string message, object[] args)
- public static void WarnException(this ILog logger, string message, Exception exception, object[] args)
- public static void WarnFormat(this ILog logger, string message, object[] args)
public sealed delegate Logger : MulticastDelegate
- public Logger(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(LogLevel logLevel, Func<string> messageFunc, Exception exception, object[] formatParameters, AsyncCallback callback, object object)
- public virtual bool EndInvoke(IAsyncResult result)
- public virtual bool Invoke(LogLevel logLevel, Func<string> messageFunc, Exception exception = null, object[] formatParameters)
public class NoopLogger : ILogger
public class NoopLogger<TCategoryName> : ILogger<TCategoryName>, ILogger
public static class LogProvider
- public static bool IsDisabled { get; set; }
- public static ILog For<T>()
- public static ILog GetCurrentClassLogger()
- public static ILog GetLogger(Type type, string fallbackTypeName = "System.Object")
- public static ILog GetLogger(string name)
- public static IDisposable OpenMappedContext(string key, object value, bool destructure = false)
- public static IDisposable OpenNestedContext(string message)
- public static void SetCurrentLogProvider(ILogProvider logProvider)

EasyNetQ.Logging.LogProviders

public class LibLogException : Exception
- public LibLogException(string message)
- public LibLogException(string message, Exception inner)
public abstract class LogProviderBase : ILogProvider
- protected sealed delegate OpenMdc : MulticastDelegate
- protected sealed delegate OpenNdc : MulticastDelegate
- protected const string ErrorInitializingProvider = "Unable to log due to problem initializing the log provider. See inner exception for details."
- protected LogProviderBase()
- protected static Type FindType(string typeName, string assemblyName)
- protected static Type FindType(string typeName, IReadOnlyList<string> assemblyNames)
- public abstract Logger GetLogger(string name)
- protected virtual OpenMdc GetOpenMdcMethod()
- protected virtual OpenNdc GetOpenNdcMethod()
- public IDisposable OpenMappedContext(string key, object value, bool destructure = false)
- public IDisposable OpenNestedContext(string message)

EasyNetQ.MessageVersioning

public class VersionedExchangeDeclareStrategy : IExchangeDeclareStrategy
- public Task<Exchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)
- public Task<Exchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
- public Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)
- public Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
public class VersionedMessageSerializationStrategy : IMessageSerializationStrategy
- public IMessage DeserializeMessage(MessageProperties properties, ref ReadOnlyMemory body)
- public IMessage DeserializeMessage(MessageProperties properties, byte[] body)

EasyNetQ.MultipleExchange

public class MultipleExchangeDeclareStrategy : IExchangeDeclareStrategy
- public Task<Exchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
- public Task<Exchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)
- public Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
- public Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)

EasyNetQ.Persistent

public struct ActionBasedPersistentChannelAction : IPersistentChannelAction<NoResult>
public struct FuncBasedPersistentChannelAction<TResult> : IPersistentChannelAction<TResult>
public interface IPersistentChannel : IDisposable
public interface IPersistentChannelAction<TResult>
public interface IPersistentChannelFactory
public interface IPersistentConnection : IDisposable
public class PersistentChannel : IPersistentChannel, IDisposable
public class PersistentChannelFactory : IPersistentChannelFactory
public struct PersistentChannelOptions
public class PersistentConnection : IPersistentConnection, IDisposable
public enum PersistentConnectionType

EasyNetQ.Producer

public struct ChannelDispatchOptions
- public static readonly ChannelDispatchOptions Default
- public static readonly ChannelDispatchOptions Publish
- public static readonly ChannelDispatchOptions PublishWithConfirms
- public string Name { get; }
- public bool PublisherConfirms { get; }
- public ChannelDispatchOptions(string name, bool publisherConfirms = false)
public class DefaultExchangeDeclareStrategy : IExchangeDeclareStrategy
- public Task<Exchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)
- public Task<Exchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
- public Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)
- public Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
public interface IClientCommandDispatcher : IDisposable
- Task<T> InvokeAsync<T>(Func<IModel, T> channelAction, ChannelDispatchOptions channelOptions, CancellationToken cancellationToken = default)
public interface IExchangeDeclareStrategy
- Task<Exchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken = default)
- Task<Exchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken = default)
- Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken = default)
- Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken = default)
public interface IProducerConnection : IPersistentConnection, IDisposable
public interface IPersistentChannel : IDisposable
- Task<T> InvokeChannelActionAsync<T>(Func<IModel, T> channelAction, CancellationToken cancellationToken = default)
public interface IPersistentChannelFactory
- IPersistentChannel CreatePersistentChannel(PersistentChannelOptions options)
public class ProducerConnection : PersistentConnection, IProducerConnection, IPersistentConnection, IDisposable
public sealed class MultiChannelClientCommandDispatcher : IClientCommandDispatcher, IDisposable
- public MultiChannelClientCommandDispatcher(int channelsCount, IPersistentChannelFactory channelFactory)
- public void Dispose()
- public Task<T> InvokeAsync<T>(Func<IModel, T> channelAction, ChannelDispatchOptions options, CancellationToken cancellationToken)
public class PersistentChannel : IPersistentChannel, IDisposable
- public PersistentChannel(PersistentChannelOptions options, IPersistentConnection connection, IEventBus eventBus)
- public void Dispose()
- public Task<T> InvokeChannelActionAsync<T>(Func<IModel, T> channelAction, CancellationToken cancellationToken)
public class PersistentChannelFactory : IPersistentChannelFactory
- public PersistentChannelFactory(IPersistentConnection connection, IEventBus eventBus)
- public IPersistentChannel CreatePersistentChannel(PersistentChannelOptions options)
public struct PersistentChannelOptions
- public bool PublisherConfirms { get; }
- public PersistentChannelOptions(bool publisherConfirms)
public sealed class SingleChannelClientCommandDispatcher : IClientCommandDispatcher, IDisposable
- public SingleChannelClientCommandDispatcher(IPersistentChannelFactory channelFactory)
- public void Dispose()
- public Task<T> InvokeAsync<T>(Func<IModel, T> channelAction, ChannelDispatchOptions channelOptions, CancellationToken cancellationToken)

EasyNetQ.SystemMessages

public class Error
- public Error(string routingKey, string exchange, string queue, string exception, string message, DateTime dateTime, MessageProperties basicProperties)
- public Error()
public class ScheduleMe
- public string BindingKey { get; set; }
- public string CancellationKey { get; set; }
- public string Exchange { get; set; }
- public string ExchangeType { get; set; }
- public byte[] InnerMessage { get; set; }
- public MessageProperties MessageProperties { get; set; }
- public string RoutingKey { get; set; }
- public DateTime WakeTime { get; set; }
- public ScheduleMe()
public class UnscheduleMe
- public string CancellationKey { get; set; }
- public UnscheduleMe()

EasyNetQ.Topology

public struct Binding<TBindable> where TBindable : struct, IBindable
public sealed class Binding : IBinding
- public IDictionary<string, object> Arguments { get; }
- public IBindable Bindable { get; }
- public IExchange Exchange { get; }
- public string RoutingKey { get; }
- public Binding(IBindable bindable, IExchange exchange, string routingKey, IDictionary<string, object> arguments)
public sealed class Exchange : IExchange, IBindable
- public static Exchange Default { get; }
- public static IExchange GetDefault()
public interface IBindable
- string Name { get; }
public interface IBinding
- IDictionary<string, object> Arguments { get; }
- IBindable Bindable { get; }
- IExchange Exchange { get; }
- string RoutingKey { get; }
public interface IExchange : IBindable
- IDictionary<string, object> Arguments { get; }
- bool IsAutoDelete { get; }
- bool IsDurable { get; }
- string Name { get; }
- string Type { get; }
public interface IQueue : IBindable
- IDictionary<string, object> Arguments { get; }
- bool IsAutoDelete { get; }
- bool IsDurable { get; }
- bool IsExclusive { get; }
- string Name { get; }

API Diff between 5.3.0-alpha0077 and 8.0.0-alpha5

EasyNetQ

EasyNetQ.AutoSubscribe

EasyNetQ.ChannelDispatcher

EasyNetQ.ConnectionString

EasyNetQ.Consumer

EasyNetQ.DI

EasyNetQ.Events

EasyNetQ.Interception

EasyNetQ.Internals

EasyNetQ.LightInject

EasyNetQ.Logging

EasyNetQ.Logging.LogProviders

EasyNetQ.MessageVersioning

EasyNetQ.MultipleExchange

EasyNetQ.Persistent

EasyNetQ.Producer

EasyNetQ.SystemMessages

EasyNetQ.Topology