API Diff between 5.3.0-alpha0077 and 8.0.0-alpha6
1000 Additions
355 Removals
EasyNetQ
-
public class AdvancedBusEventHandlers
-
public static class AdvancedBusExtensions
- public static Binding<Exchange> Bind(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, CancellationToken cancellationToken = default)
- public static Binding<Exchange> Bind(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Binding<Queue> Bind(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, CancellationToken cancellationToken = default)
- public static Binding<Queue> Bind(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Task<Binding<Queue>> BindAsync(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Task<Binding<Exchange>> BindAsync(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Task<Binding<Queue>> BindAsync(this IAdvancedBus bus, Exchange source, Queue queue, string routingKey, CancellationToken cancellationToken = default)
- public static Task<Binding<Exchange>> BindAsync(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, CancellationToken cancellationToken = default)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, Task> handler)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, IMessageHandler<T> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<IHandlerRegistration> addHandlers)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<IHandlerRegistration> addHandlers, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task<AckStrategy>> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task<AckStrategy>> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, MessageHandler handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, MessageHandler handler, Action<ISimpleConsumeConfiguration> configure)
- public static Exchange ExchangeDeclare(this IAdvancedBus bus, string exchange, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
- public static Exchange ExchangeDeclare(this IAdvancedBus bus, string exchange, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public static Task<Exchange> ExchangeDeclareAsync(this IAdvancedBus bus, string exchange, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
- public static 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 Task ExchangeDeleteAsync(this IAdvancedBus bus, Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public static void ExchangeUnbindAsync(this IAdvancedBus bus, string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static QueueStats GetQueueStats(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
- public static void Publish(this IAdvancedBus bus, 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 queue, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, string queue, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
- public static Task<Queue> QueueDeclareAsync(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
- public static Task<Queue> QueueDeclareAsync(this IAdvancedBus bus, string queue, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
- public static void 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 queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- public static void QueuePurge(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
- public static void QueueUnbindAsync(this IAdvancedBus bus, string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static void Unbind(this IAdvancedBus bus, Binding<Queue> binding, CancellationToken cancellationToken = default)
- public static void Unbind(this IAdvancedBus bus, Binding<Exchange> binding, CancellationToken cancellationToken = default)
- public static Task UnbindAsync(this IAdvancedBus bus, Binding<Queue> binding, CancellationToken cancellationToken = default)
- public static Task UnbindAsync(this IAdvancedBus bus, Binding<Exchange> binding, CancellationToken cancellationToken = default)
- public 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 class BasicGetResult<T> : IBasicGetResult<T>
-
public class BlockedEventArgs : EventArgs
-
public class ConnectedEventArgs : EventArgs
-
public class ConnectionConfiguration
-
public static class ConsumeConfigurationExtensions
-
public struct ConsumedMessage
-
public class Conventions : IConventions
-
public class DeadLetterExchangeAndMessageTtlScheduler : IScheduler
-
public static class DeadLetterStrategy
-
public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
-
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 class DelayedExchangeScheduler : IScheduler
-
public class DisconnectedEventArgs : EventArgs
-
public sealed class EventBus : IEventBus
-
public sealed class ExchangeAttribute : Attribute
-
public static class ExchangeDeclareConfigurationExtensions
-
public class ExternalScheduler : IScheduler
-
public class 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 exchange, 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(string exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- Task ExchangeUnbindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task<QueueStats> GetQueueStatsAsync(string queue, CancellationToken cancellationToken = default)
- Task PublishAsync(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 queue, 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 queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- Task QueuePurgeAsync(string queue, CancellationToken cancellationToken = default)
- Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- 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
-
public interface IBasicGetResult<T>
-
public interface IConsumeConfiguration
-
public interface IConventions
-
public interface IEventBus
-
public interface IFuturePublishConfiguration
-
public interface IMessageSerializationStrategy
-
public interface IPerQueueConsumeConfiguration
-
public interface IPersistentConnection : IDisposable
-
public interface IPublishConfiguration
-
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
-
public interface IResponderConfiguration
-
public interface IScheduler
-
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
-
public interface ISimpleConsumeConfiguration
-
public interface ISubscriptionConfiguration
-
public interface ISubscriptionResult : IDisposable
-
public interface ITypeNameSerializer
-
public class JsonSerializer : ISerializer
-
public class LegacyTypeNameSerializer : ITypeNameSerializer
-
public static class LinqExtensions
-
public static class MessageFactory
-
public class MessageNotAvailableException : Exception
-
public class MessageProperties
-
public class MessageReceivedInfo
-
public class MessageReturnedEventArgs : EventArgs
-
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 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 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 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 exchange, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public Task<IExchange> ExchangeDeclareAsync(string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public virtual Task ExchangeDeleteAsync(string exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public virtual Task ExchangeUnbindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public Task<QueueStats> GetQueueStatsAsync(string queue, CancellationToken cancellationToken)
- public virtual Task PublishAsync(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 queue, 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 queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- public virtual Task QueuePurgeAsync(string queue, CancellationToken cancellationToken)
- public virtual Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public 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 sealed delegate RpcReturnQueueNamingConvention : MulticastDelegate
-
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 static class ServiceRegisterExtensions
-
public static class SimpleConsumeConfigurationExtensions
-
public sealed class SubscriptionResult : ISubscriptionResult, IDisposable
-
public sealed delegate TEventHandler<TEvent> : MulticastDelegate where TEvent : struct
-
public class UnblockedEventArgs : EventArgs
EasyNetQ.AutoSubscribe
EasyNetQ.ChannelDispatcher
EasyNetQ.ConnectionString
EasyNetQ.Consumer
-
public class Consumer : IConsumer, IDisposable
-
public class BasicConsumer : IBasicConsumer, IDisposable
- public string ConsumerTag { get; }
- public IModel Model { get; }
- public Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> OnMessage { get; }
- public IQueue Queue { get; }
- public event EventHandler<ConsumerEventArgs> ConsumerCancelled
- public BasicConsumer(Action<BasicConsumer> cancelled, IConsumerDispatcher consumerDispatcher, IQueue queue, IEventBus eventBus, IHandlerRunner handlerRunner, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IModel model)
- public void Dispose()
- public void HandleBasicCancel(string consumerTag)
- public void HandleBasicCancelOk(string consumerTag)
- public void HandleBasicConsumeOk(string consumerTag)
- public void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, ReadOnlyMemory<byte> body)
- public void HandleModelShutdown(object model, ShutdownEventArgs reason)
-
public class ConsumerCancellation : IDisposable
-
public class ConsumerConfiguration : IConsumerConfiguration
-
public sealed class ConsumerConnection : PersistentConnection, IConsumerConnection, IPersistentConnection, IDisposable
-
public class ConsumerDispatcher : IConsumerDispatcher, IDisposable
-
public class ConsumerDispatcherFactory : IConsumerDispatcherFactory, IDisposable
-
public class ConsumerExecutionContext
- public ReadOnlyMemory<byte> Body { get; }
- public MessageHandler Handler { get; }
- public byte[] Body { get; }
- public MessageReceivedInfo Info { get; }
- public MessageReceivedInfo ReceivedInfo { get; }
- public ConsumerExecutionContext(MessageHandler handler, MessageReceivedInfo receivedInfo, MessageProperties properties, ref ReadOnlyMemory body)
- public Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> UserHandler { get; }
- public ConsumerExecutionContext(Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> userHandler, MessageReceivedInfo info, MessageProperties properties, byte[] body)
-
public class ConsumerFactory : IConsumerFactory, IDisposable
- public ConsumerFactory(ILogger<Consumer> logger, IEventBus eventBus, IInternalConsumerFactory internalConsumerFactory)
- public IConsumer CreateConsumer(ConsumerConfiguration configuration)
- public ConsumerFactory(IPersistentConnection connection, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
- public IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
- public IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
-
public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
- public DefaultConsumerErrorStrategy(ILogger<DefaultConsumerErrorStrategy> logger, IConsumerConnection connection, ISerializer serializer, IConventions conventions, ITypeNameSerializer typeNameSerializer, IErrorMessageSerializer errorMessageSerializer, ConnectionConfiguration configuration)
- public DefaultConsumerErrorStrategy(IPersistentConnection connection, ISerializer serializer, IConventions conventions, ITypeNameSerializer typeNameSerializer, IErrorMessageSerializer errorMessageSerializer, ConnectionConfiguration connectionConfiguration)
- public virtual Task<AckStrategy> HandleConsumerCancelledAsync(ConsumerExecutionContext context, CancellationToken cancellationToken)
- public virtual Task<AckStrategy> HandleConsumerErrorAsync(ConsumerExecutionContext context, Exception exception, CancellationToken cancellationToken)
- public virtual AckStrategy HandleConsumerCancelled(ConsumerExecutionContext context)
- public virtual AckStrategy HandleConsumerError(ConsumerExecutionContext context, Exception exception)
-
public class ExclusiveConsumer : IConsumer, IDisposable
-
public class HandlerCollection : IHandlerCollection, IHandlerRegistration
-
public class HandlerCollectionFactory : IHandlerCollectionFactory
-
public class HandlerCollectionPerQueueFactory : IHandlerCollectionFactory
-
public static class HandlerRegistrationExtensions
-
public class HandlerRunner : IHandlerRunner, IDisposable
-
public interface IConsumer : IDisposable
-
public interface IConsumerConnection : IPersistentConnection, IDisposable
-
public interface IConsumerConfiguration
-
public interface IConsumerDispatcher : IDisposable
-
public interface IConsumerDispatcherFactory : IDisposable
-
public interface IConsumerErrorStrategy : IDisposable
-
public interface IConsumerFactory : IDisposable
- IConsumer CreateConsumer(ConsumerConfiguration configuration)
- IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
- IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
-
public interface IHandlerCollection : IHandlerRegistration
-
public interface IHandlerCollectionFactory
-
public interface IHandlerRegistration
-
public interface IInternalConsumer : IDisposable
- event EventHandler<InternalConsumerCancelledEventArgs> Cancelled
- InternalConsumerStatus StartConsuming(bool firstStart = true)
- void StopConsuming()
- event Action<IInternalConsumer> Cancelled
- StartConsumingStatus StartConsuming(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
- StartConsumingStatus StartConsuming(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
-
public interface IInternalConsumerFactory : IDisposable
-
public sealed delegate IMessageHandler : MulticastDelegate
-
public sealed delegate IMessageHandler<T> : MulticastDelegate
-
public class InternalConsumer : IInternalConsumer, IDisposable
- public event EventHandler<InternalConsumerCancelledEventArgs> Cancelled
- public InternalConsumer(ILogger<InternalConsumer> logger, ConsumerConfiguration configuration, IConsumerConnection connection, IHandlerRunner handlerRunner, IEventBus eventBus)
- public IModel Model { get; }
- public event Action<IInternalConsumer> Cancelled
- public InternalConsumer(IPersistentConnection connection, IHandlerRunner handlerRunner, IConsumerDispatcher consumerDispatcher, IConventions conventions, IEventBus eventBus)
- public InternalConsumerStatus StartConsuming(bool firstStart)
- public void StopConsuming()
- public StartConsumingStatus StartConsuming(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
- public StartConsumingStatus StartConsuming(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
-
public class InternalConsumerCancelledEventArgs : EventArgs
-
public class InternalConsumerFactory : IInternalConsumerFactory, IDisposable
-
public struct InternalConsumerStatus
-
public sealed delegate MessageHandler : MulticastDelegate
-
public class PerQueueConsumerConfiguration
-
public class SimpleConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
-
public class PersistentConsumer : IConsumer, IDisposable
-
public class PersistentMultipleConsumer : IConsumer, IDisposable
-
public enum StartConsumingStatus
-
public class TransientConsumer : IConsumer, IDisposable
EasyNetQ.DI
-
public class DefaultConsumeScopeProvider : IConsumeScopeProvider
-
public interface IConsumeScopeProvider
-
public class DefaultServiceContainer : IServiceRegister
-
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
EasyNetQ.Interception
EasyNetQ.Internals
EasyNetQ.LightInject
-
public class AssemblyScanner : IAssemblyScanner
- public (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 : ITypeExtractor
-
public class : ICompositionRootAttributeExtractor
-
public class CompositionRootExecutor : ICompositionRootExecutor
-
public class CompositionRootTypeAttribute : Attribute
-
public class : ITypeExtractor
-
public class : ITypeExtractor
-
public class ConstructionInfo
-
public class ConstructionInfoProvider : IConstructionInfoProvider
-
public class ConstructorDependency : Dependency
-
public class ConstructorDependencySelector : IConstructorDependencySelector
-
public class ContainerOptions
-
public class DecoratorRegistration : Registration
-
public abstract class Dependency
-
public class DynamicMethod
-
public class Emitter : IEmitter
-
public static class EmitterExtensions
- public static 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 class GenericArgumentMapper : IGenericArgumentMapper
-
public class GenericMappingResult
-
public interface IAssemblyScanner
-
public interface ICompositionRoot
-
public interface
-
public interface ICompositionRootExecutor
-
public interface IConstructionInfoBuilder
-
public interface IConstructionInfoProvider
-
public interface IConstructorDependencySelector
-
public interface IConstructorSelector
-
public interface IEmitter
-
public interface IGenericArgumentMapper
-
public class ILGenerator
-
public interface ILifetime
-
public interface IMethodSkeleton
-
public sealed class ImmutableHashTable<TKey, TValue>
-
public static class ImmutableHashTableExtensions
-
public sealed class ImmutableHashTree<TKey, TValue>
- public static 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 class Instruction
-
public class Instruction<T> : Instruction
-
public interface IPropertyDependencySelector
-
public interface IPropertySelector
-
public interface IScopeManager
-
public interface IScopeManagerProvider
-
public interface IServiceContainer : IServiceRegistry, IServiceFactory, IDisposable
-
public interface IServiceFactory
-
public interface IServiceNameProvider
-
public interface IServiceRegistry
- 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
-
public interface
-
public sealed class KeyValue<TKey, TValue>
- public readonly TKey Key
- public readonly TValue Value
- public KeyValue(TKey key, TValue value)
-
public class LocalBuilder
-
public class LogEntry
-
public static class LogExtensions
-
public class LogicalThreadStorage<T>
-
public enum LogLevel
-
public class MostResolvableConstructorSelector : IConstructorSelector
-
public class PerContainerLifetime : ILifetime, IDisposable
-
public class PerLogicalCallContextScopeManager : ScopeManager
-
public class PerLogicalCallContextScopeManagerProvider : ScopeManagerProvider
-
public class PerRequestLifeTime : ILifetime
-
public class PerScopeLifetime : ILifetime
-
public class PerThreadScopeManager : ScopeManager
-
public class PerThreadScopeManagerProvider : ScopeManagerProvider
-
public class PropertyDependency : Dependency
-
public class PropertyDependencySelector : IPropertyDependencySelector
-
public class PropertySelector : IPropertySelector
-
public abstract class Registration
-
public static class RuntimeArgumentsLoader
- public static object[] Load(object[] constants)
-
public class Scope : IServiceFactory, IDisposable
-
public abstract class ScopeManager : IScopeManager
-
public abstract class ScopeManagerProvider : IScopeManagerProvider
-
public class ServiceContainer : IServiceContainer, IServiceRegistry, IServiceFactory, IDisposable
- public IAssemblyScanner AssemblyScanner { get; set; }
- public IEnumerable<ServiceRegistration> AvailableServices { get; }
- public ICompositionRootExecutor CompositionRootExecutor { get; set; }
- public ITypeExtractor { 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 class ServiceRegistration : Registration
-
public class ServiceRequest
-
public class ThreadSafeDictionary<TKey, TValue> : ConcurrentDictionary<TKey, TValue>
-
public class TypeConstructionInfoBuilder : IConstructionInfoBuilder
EasyNetQ.Logging
-
public sealed class ConsoleLogger<TCategoryName> : ILogger<TCategoryName>, ILogger
-
public interface ILogger
-
public interface ILogger<TCategoryName> : ILogger
-
public static class LoggerExtensions
-
public class ConsoleLogProvider : ILogProvider
-
public interface ILog
-
public interface ILogProvider
-
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 sealed class NoopLogger<TCategoryName> : ILogger<TCategoryName>, ILogger
-
public static class LogProvider
EasyNetQ.Logging.LogProviders
EasyNetQ.MessageVersioning
EasyNetQ.MultipleExchange
EasyNetQ.Persistent
EasyNetQ.Producer
EasyNetQ.SystemMessages
EasyNetQ.Topology