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

API Diff between 3.0.1 and 0.27.4.220

1228 Additions 151 Removals

EasyNetQ

public class AdvancedBusEventHandlers
- public static readonly AdvancedBusEventHandlers Default
- public EventHandler<ConnectionBlockedEventArgs> Blocked { get; }
- public EventHandler Connected { get; }
- public EventHandler Disconnected { get; }
- public EventHandler<MessageReturnedEventArgs> MessageReturned { get; }
- public EventHandler Unblocked { get; }
- public AdvancedBusEventHandlers(EventHandler connected = null, EventHandler disconnected = null, EventHandler<ConnectionBlockedEventArgs> blocked = null, EventHandler unblocked = null, EventHandler<MessageReturnedEventArgs> messageReturned = null)
public static class BusExtensions
public class 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 ComponentRegistration
public class ConnectionConfiguration
- public IList<AuthMechanismFactory> AuthMechanisms { get; set; }
- public IEnumerable<IHostConfiguration> Hosts { get; set; }
- public TimeSpan ConnectIntervalAttempt { get; set; }
- public IEnumerable<HostConfiguration> Hosts { get; set; }
- public string Name { get; set; }
- public bool UseBackgroundThreads { get; set; }
public class ConnectionFactoryInfo
- public IHostConfiguration HostConfiguration { get; }
- public ConnectionFactoryInfo(ConnectionFactory connectionFactory, IHostConfiguration hostConfiguration)
- public HostConfiguration HostConfiguration { get; }
- public ConnectionFactoryInfo(ConnectionFactory connectionFactory, HostConfiguration hostConfiguration)
public class ConnectionFactoryWrapper : IConnectionFactory
- public virtual IConnectionConfiguration Configuration { get; }
- public virtual IHostConfiguration CurrentHost { get; }
- public virtual ConnectionConfiguration Configuration { get; }
- public virtual HostConfiguration CurrentHost { get; }
- public ConnectionFactoryWrapper(IConnectionConfiguration connectionConfiguration, IClusterHostSelectionStrategy<ConnectionFactoryInfo> clusterHostSelectionStrategy)
- public ConnectionFactoryWrapper(ConnectionConfiguration connectionConfiguration, IClusterHostSelectionStrategy<ConnectionFactoryInfo> clusterHostSelectionStrategy)
public class Conventions : IConventions
- public RpcExchangeNameConvention RpcExchangeNamingConvention { get; set; }
- public RpcExchangeNameConvention RpcRequestExchangeNamingConvention { get; set; }
- public RpcExchangeNameConvention RpcResponseExchangeNamingConvention { get; set; }
public class CorrelationIdGenerator
public class DefaultClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
public class DefaultServiceProvider : IContainer, IServiceProvider, IServiceRegister
public class DefaultCorrelationIdGenerationStrategy : ICorrelationIdGenerationStrategy
- public DefaultCorrelationIdGenerationStrategy()
- public string GetCorrelationId()
public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
- public DefaultMessageSerializationStrategy(ITypeNameSerializer typeNameSerializer, ISerializer serializer, ICorrelationIdGenerationStrategy correlationIdGenerator)
- public IMessage DeserializeMessage(MessageProperties properties, byte[] body)
- public SerializedMessage SerializeMessage(IMessage message)
public class DefaultTypeNameSerializer : ITypeNameSerializer
- public DefaultTypeNameSerializer()
- public Type DeSerialize(string typeName)
- public string Serialize(Type type)
public class DeliveryModeAttribute : Attribute
- public bool IsPersistent { get; }
- public DeliveryModeAttribute(bool isPersistent)
public class EasyNetQException : Exception
- protected EasyNetQException(SerializationInfo info, StreamingContext context)
public class EasyNetQInvalidMessageTypeException : EasyNetQException
public class EasyNetQResponderException : EasyNetQException
- protected EasyNetQResponderException(SerializationInfo info, StreamingContext context)
public static class Extensions
- public static void Add<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> source, TKey key, TValue value)
- public static TimeSpan Double(this TimeSpan timeSpan)
- public static void Remove<TKey, TValue>(this ConcurrentDictionary<TKey, TValue> source, TKey key)
- public static string Trim(this string s, int start, int length)
public class HostConfiguration
- public SslOption Ssl { get; }
public interface IAdvancedBus : IDisposable
- IContainer Container { get; }
- IServiceResolver Container { get; }
- IConventions Conventions { get; }
- event Action Connected
- event Action Disconnected
- event EventHandler<ConnectionBlockedEventArgs> Blocked
- event EventHandler Connected
- event EventHandler Disconnected
- event EventHandler<MessageReturnedEventArgs> MessageReturned
- event EventHandler Unblocked
- IBinding Bind(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
- IBinding Bind(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers)
- Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey)
- Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
- Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey)
- Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers)
- IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
- IDisposable Consume<T>(IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)
- IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
- IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null, bool delayed = false)
- Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null, bool delayed = false)
- void Publish(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
- void Publish<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
- Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
- Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
- IQueue QueueDeclare(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int perQueueTtl = 2147483647, int expires = 2147483647)
- IBasicGetResult<T> Get<T>(IQueue queue)
- IBasicGetResult Get(IQueue queue)
- uint MessageCount(IQueue queue)
- void Publish(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body)
- void Publish<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message)
- Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, IMessage message)
- Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message)
- Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body)
- IQueue QueueDeclare(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default)
- Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default)
public interface IBasicGetResult
- byte[] Body { get; }
- MessageReceivedInfo Info { get; }
- MessageProperties Properties { get; }
public interface IBasicGetResult<T>
- IMessage<T> Message { get; }
- bool MessageAvailable { get; }
public interface IBus : IDisposable
- event Action Connected
- event Action Disconnected
- void Publish<T>(T message, Action<IPublishConfiguration> configure)
- Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure)
- IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- TResponse Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, Action<IResponderConfiguration> configure)
- IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
- IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage)
- IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
- IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
- Task SendAsync<T>(string queue, T message)
- ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage)
- ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
- ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
public interface IConnectionConfiguration
public interface IConnectionFactory
- IConnectionConfiguration Configuration { get; }
- IHostConfiguration CurrentHost { get; }
- ConnectionConfiguration Configuration { get; }
- HostConfiguration CurrentHost { get; }
public interface IContainer : IServiceProvider, IServiceRegister
public interface IConventions
- RpcExchangeNameConvention RpcExchangeNamingConvention { get; set; }
- RpcExchangeNameConvention RpcRequestExchangeNamingConvention { get; set; }
- RpcExchangeNameConvention RpcResponseExchangeNamingConvention { get; set; }
public interface IEasyNetQLogger
public interface ICorrelationIdGenerationStrategy
- string GetCorrelationId()
public interface IHostConfiguration
public interface IMessage
- Type MessageType { get; }
- MessageProperties Properties { get; }
- object GetBody()
public interface IMessage<T> : IMessage
- MessageProperties Properties { get; }
public interface IMessageDeliveryModeStrategy
- byte GetDeliveryMode(Type messageType)
public interface IMessageSerializationStrategy
- IMessage DeserializeMessage(MessageProperties properties, byte[] body)
- SerializedMessage SerializeMessage(IMessage message)
public interface IPersistentConnection : IDisposable
- void Initialize()
public interface ISaga
public interface IPersistentConnectionFactory
- IPersistentConnection CreateConnection()
public interface ISerializer
- object BytesToMessage(string typeName, byte[] bytes)
- object BytesToMessage(Type type, byte[] bytes)
public interface IServiceProvider
public interface IServiceRegister
public interface ISubscriptionResult : IDisposable
- IDisposable ConsumerCancellation { get; }
- IExchange Exchange { get; }
- IQueue Queue { get; }
public interface ITimeoutStrategy
- ulong GetTimeoutSeconds(Type messageType)
public class JsonSerializer : ISerializer
- public JsonSerializer(ITypeNameSerializer typeNameSerializer)
- public JsonSerializer()
- public JsonSerializer(JsonSerializerSettings serializerSettings)
- public object BytesToMessage(string typeName, byte[] bytes)
- public object BytesToMessage(Type type, byte[] bytes)
public class LegacyTypeNameSerializer : ITypeNameSerializer
- public LegacyTypeNameSerializer()
- public Type DeSerialize(string typeName)
- public string Serialize(Type type)
public static class LegacyTypeNamingExtensions
- public static IServiceRegister EnableLegacyTypeNaming(this IServiceRegister serviceRegister)
public static class LinqExtensions
- public static IEnumerable<T> AtLeastOneWithDefault<T>(this IEnumerable<T> items, T default)
- public static IEnumerable<KeyValuePair<string, string>> EnumerateDictionary(this IDictionary<string, object> dictionary)
public static class Message
public class Message<T> : IMessage<T>, IMessage
- public Type MessageType { get; }
- public Message(T body, MessageProperties properties)
- public object GetBody()
public static class MessageDeliveryMode
- public const byte NonPersistent = 1
- public const byte Persistent = 2
public class MessageDeliveryModeStrategy : IMessageDeliveryModeStrategy
- public MessageDeliveryModeStrategy(ConnectionConfiguration connectionConfiguration)
- public byte GetDeliveryMode(Type messageType)
public static class MessageFactory
- public static IMessage CreateInstance(Type messageType, object body)
- public static IMessage CreateInstance(Type messageType, object body, MessageProperties properties)
public class MessageNotAvailableException : Exception
- public MessageNotAvailableException()
- public MessageNotAvailableException(string message)
- public MessageNotAvailableException(string message, Exception inner)
public class MessageProperties
- public void AppendPropertyDebugStringTo(StringBuilder stringBuilder)
- public object Clone()
public class MessageReturnedEventArgs : EventArgs
- public byte[] MessageBody { get; }
- public MessageProperties MessageProperties { get; }
- public MessageReturnedInfo MessageReturnedInfo { get; }
- public MessageReturnedEventArgs(byte[] messageBody, MessageProperties messageProperties, MessageReturnedInfo messageReturnedInfo)
public class MessageReturnedInfo
- public string Exchange { get; set; }
- public string ReturnReason { get; set; }
- public string RoutingKey { get; set; }
- public MessageReturnedInfo(string exchange, string routingKey, string returnReason)
public class OrderedClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
- public virtual bool Succeeded { get; }
- public OrderedClusterHostSelectionStrategy()
- public virtual void Add(T item)
- public virtual T Current()
- public virtual IEnumerator<T> GetEnumerator()
- public virtual bool Next()
- public virtual void Reset()
- public virtual void Success()
public class PersistentConnection : IPersistentConnection, IDisposable
- public PersistentConnection(IConnectionFactory connectionFactory, IEasyNetQLogger logger, IEventBus eventBus)
- public PersistentConnection(IConnectionFactory connectionFactory, IEventBus eventBus)
- public void Initialize()
public class PersistentConnectionFactory : IPersistentConnectionFactory
- public PersistentConnectionFactory(IConnectionFactory connectionFactory, IEventBus eventBus)
- public IPersistentConnection CreateConnection()
public class QueueAttribute : Attribute
- 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, 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 class RabbitAdvancedBus : IAdvancedBus, IDisposable
- public IContainer Container { get; }
- public IServiceResolver Container { get; }
- public IConventions Conventions { get; }
- public event Action Connected
- public event Action Disconnected
- public RabbitAdvancedBus(IConnectionFactory connectionFactory, ISerializer serializer, IConsumerFactory consumerFactory, IEasyNetQLogger logger, Func<string> getCorrelationId, IClientCommandDispatcherFactory clientCommandDispatcherFactory, IPublisherConfirms publisherConfirms, IEventBus eventBus, ITypeNameSerializer typeNameSerializer, IHandlerCollectionFactory handlerCollectionFactory, IContainer container)
- public event EventHandler<ConnectionBlockedEventArgs> Blocked
- public event EventHandler Connected
- public event EventHandler Disconnected
- public event EventHandler<MessageReturnedEventArgs> MessageReturned
- public event EventHandler Unblocked
- public RabbitAdvancedBus(IConnectionFactory connectionFactory, IConsumerFactory consumerFactory, IClientCommandDispatcherFactory clientCommandDispatcherFactory, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IServiceResolver container, ConnectionConfiguration connectionConfiguration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, AdvancedBusEventHandlers advancedBusEventHandlers, IPersistentConnectionFactory persistentConnectionFactory)
- public virtual IBinding Bind(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
- public virtual IBinding Bind(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers)
- public Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey)
- public Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
- public Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey)
- public Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers)
- public IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
- public IDisposable Consume<T>(IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- public IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- public IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- public IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)
- public IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
- public virtual IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null, bool delayed = false)
- public Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null, bool delayed = false)
- public IBasicGetResult<T> Get<T>(IQueue queue)
- public IBasicGetResult Get(IQueue queue)
- public uint MessageCount(IQueue queue)
- protected void OnBlocked(ConnectionBlockedEvent args)
- public void Publish(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
- public void Publish<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
- public virtual Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
- public virtual IQueue QueueDeclare(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int perQueueTtl = 2147483647, int expires = 2147483647)
- protected void OnMessageReturned(ReturnedMessageEvent args)
- protected void OnUnblocked()
- public void Publish(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body)
- public void Publish<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message)
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, IMessage message)
- public virtual Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message)
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body)
- public virtual IQueue QueueDeclare(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default)
- public Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default)
public class RabbitBus : IBus, IDisposable
- public IConventions Conventions { get; }
- public IEasyNetQLogger Logger { get; }
- public event Action Connected
- public event Action Disconnected
- public RabbitBus(IEasyNetQLogger logger, IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IRpc rpc, ISendReceive sendReceive, IConnectionConfiguration connectionConfiguration)
- public RabbitBus(IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IRpc rpc, ISendReceive sendReceive, ConnectionConfiguration connectionConfiguration)
- protected void OnConnected()
- protected void OnDisconnected()
- public virtual void Publish<T>(T message, Action<IPublishConfiguration> configure)
- public virtual Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure)
- public virtual IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- public virtual TResponse Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- public virtual Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- public IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, Action<IResponderConfiguration> configure)
- public IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
- public virtual IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage)
- public virtual IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
- public virtual IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- public virtual IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
- public virtual Task SendAsync<T>(string queue, T message)
- public virtual ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage)
- public virtual ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
- public virtual ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- public virtual ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
public static class RabbitHutch
- public static IBus CreateBus(string connectionString, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, ushort requestedHeartbeat, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(IConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
- public static IBus CreateBus()
- public static void SetContainerFactory(Func<IContainer> createContainer)
- public static IBus CreateBus(string connectionString, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, ushort requestedHeartbeat, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(ConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory, Action<IServiceRegister> registerServices)
- public static void RegisterBus(IServiceRegister serviceRegister, Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory, Action<IServiceRegister> registerServices)
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 RpcExchangeNameConvention : MulticastDelegate
- public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
- public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
- public virtual string Invoke()
- public virtual string Invoke(Type messageType)
public sealed delegate SubsriberNameFromDelegate : MulticastDelegate
public class SerializedMessage
- public byte[] Body { get; }
- public MessageProperties Properties { get; }
- public SerializedMessage(MessageProperties properties, byte[] body)
public static class TaskHelpers
public sealed class TimeBudget
- public static TimeSpan op_Implicit(TimeBudget source)
- public static TimeBudget Start(TimeSpan budget)
- public bool IsExpired()
public class TimeoutSecondsAttribute : Attribute
- public ushort Timeout { get; }
- public TimeoutSecondsAttribute(ushort timeout)
public class TimeoutStrategy : ITimeoutStrategy
- public TimeoutStrategy(ConnectionConfiguration connectionConfiguration)
- public ulong GetTimeoutSeconds(Type messageType)
public class TypeNameSerializer : ITypeNameSerializer

EasyNetQ.AutoSubscribe

public class AutoSubscriber
- protected const string ConsumeAsyncMethodName = "ConsumeAsync"
- protected const string SubscribeAsyncMethodName = "SubscribeAsync"
- protected const string SubscribeMethodName = "Subscribe"
- protected Action<ISubscriptionConfiguration> ConfigureSubscriptionConfiguration { get; set; }
- protected virtual bool IsValidMarkerType(Type markerType)
- public virtual void Subscribe(Type[] consumerTypes)
- public virtual void SubscribeAsync(Type[] consumerTypes)
public class AutoSubscriberConsumerInfo
- public readonly Type ConcreteType
- public readonly Type InterfaceType
- public readonly Type MessageType
- public Type ConcreteType { get; }
- public MethodInfo ConsumeMethod { get; }
- public Type InterfaceType { get; }
- public Type MessageType { get; }
public class DefaultAutoSubscriberMessageDispatcher : IAutoSubscriberMessageDispatcher
- public DefaultAutoSubscriberMessageDispatcher(IServiceResolver resolver)
public interface IConsumeAsync<T>
- Task Consume(T message)
- Task ConsumeAsync(T message)
public class SubscriptionConfigurationAttribute : Attribute
- public bool AutoDelete { get; set; }
- public int Expires { get; set; }
- public ushort PrefetchCount { get; set; }
- public int Priority { get; set; }
- public SubscriptionConfigurationAttribute()

EasyNetQ.ConnectionString

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

EasyNetQ.Consumer

public static class AckStrategies
- public static AckStrategy Ack
- public static AckStrategy NackWithoutRequeue
- public static AckStrategy NackWithRequeue
- public static AckStrategy Nothing
public sealed delegate AckStrategy : MulticastDelegate
- public AckStrategy(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(IModel model, ulong deliveryTag, AsyncCallback callback, object object)
- public virtual AckResult EndInvoke(IAsyncResult result)
- public virtual AckResult Invoke(IModel model, ulong deliveryTag)
public class Base64ErrorMessageSerializer : IErrorMessageSerializer
- public Base64ErrorMessageSerializer()
- public byte[] Deserialize(string messageBody)
- public string Serialize(byte[] messageBody)
public class BasicConsumer : IBasicConsumer, IDisposable
- public string ConsumerTag { get; }
- public IModel Model { get; }
- public Func<byte[], MessageProperties, MessageReceivedInfo, 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, 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, byte[] body)
- public void HandleModelShutdown(object model, ShutdownEventArgs reason)
public class ConsumerConfiguration : IConsumerConfiguration
- public bool IsExclusive { get; }
- public ushort PrefetchCount { get; }
- public int Priority { get; }
- public ConsumerConfiguration(ushort defaultPrefetchCount)
- public IConsumerConfiguration AsExclusive()
- public IConsumerConfiguration WithPrefetchCount(ushort prefetchCount)
- public IConsumerConfiguration WithPriority(int priority)
public class ConsumerDispatcher : IConsumerDispatcher, IDisposable
- public ConsumerDispatcher(IEasyNetQLogger logger)
- public ConsumerDispatcher(ConnectionConfiguration configuration)
public class ConsumerDispatcherFactory : IConsumerDispatcherFactory, IDisposable
- public ConsumerDispatcherFactory(IEasyNetQLogger logger)
- public ConsumerDispatcherFactory(ConnectionConfiguration configuration)
public class ConsumerFactory : IConsumerFactory, IDisposable
- public IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection)
- public IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration)
- public IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, Task>>> queueConsumerPairs, IPersistentConnection connection, IConsumerConfiguration configuration)
public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
- public DefaultConsumerErrorStrategy(IConnectionFactory connectionFactory, ISerializer serializer, IEasyNetQLogger logger, IConventions conventions, ITypeNameSerializer typeNameSerializer)
- public DefaultConsumerErrorStrategy(IConnectionFactory connectionFactory, ISerializer serializer, IConventions conventions, ITypeNameSerializer typeNameSerializer, IErrorMessageSerializer errorMessageSerializer)
- protected void Connect()
- public virtual PostExceptionAckStrategy HandleConsumerError(ConsumerExecutionContext context, Exception exception)
- public AckStrategy HandleConsumerCancelled(ConsumerExecutionContext context)
- public virtual AckStrategy HandleConsumerError(ConsumerExecutionContext context, Exception exception)
public class DefaultErrorMessageSerializer : IErrorMessageSerializer
- public DefaultErrorMessageSerializer()
- public byte[] Deserialize(string messageBody)
- public string Serialize(byte[] messageBody)
public class ExclusiveConsumer : IConsumer, IDisposable
- public ExclusiveConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
- public void Dispose()
- public IDisposable StartConsuming()
public class HandlerCollection : IHandlerCollection, IHandlerRegistration
- public HandlerCollection(IEasyNetQLogger logger)
- public HandlerCollection()
- public object GetHandler(Type messageType)
- public Func<IMessage, MessageReceivedInfo, Task> GetHandler(Type messageType)
public class HandlerCollectionFactory : IHandlerCollectionFactory
- public HandlerCollectionFactory(IEasyNetQLogger logger)
- public IHandlerCollection CreateHandlerCollection()
- public HandlerCollectionFactory()
- public IHandlerCollection CreateHandlerCollection(IQueue queue)
public class HandlerCollectionPerQueueFactory : IHandlerCollectionFactory
- public HandlerCollectionPerQueueFactory()
- public IHandlerCollection CreateHandlerCollection(IQueue queue)
public class HandlerRunner : IHandlerRunner, IDisposable
- public HandlerRunner(IEasyNetQLogger logger, IConsumerErrorStrategy consumerErrorStrategy, IEventBus eventBus)
- public HandlerRunner(IConsumerErrorStrategy consumerErrorStrategy, IEventBus eventBus)
- protected virtual void DoAck(ConsumerExecutionContext context, AckStrategy ackStrategy)
- protected virtual AckStrategy GetAckStrategy(ConsumerExecutionContext context, Task task)
public interface IConsumerConfiguration
- bool IsExclusive { get; }
- ushort PrefetchCount { get; }
- int Priority { get; }
- IConsumerConfiguration AsExclusive()
- IConsumerConfiguration WithPrefetchCount(ushort prefetchCount)
- IConsumerConfiguration WithPriority(int priority)
public interface IConsumerErrorStrategy : IDisposable
- PostExceptionAckStrategy HandleConsumerError(ConsumerExecutionContext context, Exception exception)
- AckStrategy HandleConsumerCancelled(ConsumerExecutionContext context)
- AckStrategy HandleConsumerError(ConsumerExecutionContext context, Exception exception)
public interface IConsumerFactory : IDisposable
- IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection)
- IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, Task>>> queueConsumerPairs, IPersistentConnection connection, IConsumerConfiguration configuration)
- IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration)
public interface IErrorMessageSerializer
- byte[] Deserialize(string messageBody)
- string Serialize(byte[] messageBody)
public interface IHandlerCollection : IHandlerRegistration
- object GetHandler(Type messageType)
- Func<IMessage, MessageReceivedInfo, Task> GetHandler(Type messageType)
public interface IHandlerCollectionFactory
- IHandlerCollection CreateHandlerCollection()
- IHandlerCollection CreateHandlerCollection(IQueue queue)
public interface IInternalConsumer : IDisposable
- void StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
- StartConsumingStatus StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
- StartConsumingStatus StartConsuming(IPersistentConnection connection, ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
public class InternalConsumer : IInternalConsumer, IDisposable
- public string ConsumerTag { get; }
- public event ConsumerCancelledEventHandler ConsumerCancelled
- public InternalConsumer(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConsumerDispatcher consumerDispatcher, IConventions conventions, IConnectionConfiguration connectionConfiguration, IEventBus eventBus)
- public event EventHandler<ConsumerEventArgs> ConsumerCancelled
- public InternalConsumer(IHandlerRunner handlerRunner, IConsumerDispatcher consumerDispatcher, IConventions conventions, IEventBus eventBus)
- 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, byte[] body)
- public void HandleModelShutdown(IModel model, ShutdownEventArgs reason)
- public void StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
- public StartConsumingStatus StartConsuming(IPersistentConnection connection, ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
- public StartConsumingStatus StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
public class InternalConsumerFactory : IInternalConsumerFactory, IDisposable
- public InternalConsumerFactory(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConventions conventions, IConnectionConfiguration connectionConfiguration, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
- public InternalConsumerFactory(IHandlerRunner handlerRunner, IConventions conventions, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
public class PersistentConsumer : IConsumer, IDisposable
- public PersistentConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
- public PersistentConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
public enum PostExceptionAckStrategy
public class PersistentMultipleConsumer : IConsumer, IDisposable
- public PersistentMultipleConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, Task>>> queueConsumerPairs, IPersistentConnection connection, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
- public void Dispose()
- public IDisposable StartConsuming()
public enum StartConsumingStatus
- Failed = 1
- Succeed = 0
public class SubscriptionResult : ISubscriptionResult, IDisposable
- public IDisposable ConsumerCancellation { get; }
- public IExchange Exchange { get; }
- public IQueue Queue { get; }
- public SubscriptionResult(IExchange exchange, IQueue queue, IDisposable consumerCancellation)
- public void Dispose()
public class TransientConsumer : IConsumer, IDisposable
- public TransientConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
- public TransientConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)

EasyNetQ.DI

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 static class DefaultServicesRegistration
- public static void RegisterDefaultServices(this IServiceRegister container)
public interface IServiceRegister
- IServiceRegister Register<TService, TImplementation>(Lifetime lifetime = 1) where TImplementation : TService
- IServiceRegister Register<TService>(TService instance)
- IServiceRegister Register<TService>(Func<IServiceResolver, TService> factory, Lifetime lifetime = 1)
public interface IServiceResolver
- IServiceResolverScope CreateScope()
- TService Resolve<TService>()
public interface IServiceResolverScope : IServiceResolver, IDisposable
public enum Lifetime
- Singleton = 1
- Transient = 0
public class ServiceResolverScope : IServiceResolverScope, IServiceResolver, IDisposable
- public ServiceResolverScope(IServiceResolver resolver)
- public IServiceResolverScope CreateScope()
- public void Dispose()
- public TService Resolve<TService>()

EasyNetQ.Events

public class AckEvent
- public ConsumerExecutionContext ConsumerExecutionContext { get; }
- public AckEvent(ConsumerExecutionContext consumerExecutionContext, AckResult ackResult)
- public byte[] Body { get; }
- public MessageProperties Properties { get; }
- public MessageReceivedInfo ReceivedInfo { get; }
- public AckEvent(MessageReceivedInfo info, MessageProperties properties, byte[] body, AckResult ackResult)
public class ConnectionBlockedEvent
- public string Reason { get; }
- public ConnectionBlockedEvent(string reason)
public class ConnectionUnblockedEvent
- public ConnectionUnblockedEvent()
public class DeliveredMessageEvent
- public byte[] Body { get; }
- public MessageProperties Properties { get; }
- public MessageReceivedInfo ReceivedInfo { get; }
- public DeliveredMessageEvent(MessageReceivedInfo info, MessageProperties properties, byte[] body)
public class MessageConfirmationEvent
- public IModel Channel { get; }
- public ulong DeliveryTag { get; }
- public bool IsNack { get; }
- public bool Multiple { get; }
- public MessageConfirmationEvent()
- public static MessageConfirmationEvent Ack(IModel channel, ulong deliveryTag, bool multiple)
- public static MessageConfirmationEvent Nack(IModel channel, ulong deliveryTag, bool multiple)
public class PublishedMessageEvent
- public byte[] Body { get; }
- public string ExchangeName { get; }
- public MessageProperties Properties { get; }
- public string RoutingKey { get; }
- public PublishedMessageEvent(string exchangeName, string routingKey, MessageProperties properties, byte[] body)
public class ReturnedMessageEvent
- public byte[] Body { get; }
- public MessageReturnedInfo Info { get; }
- public MessageProperties Properties { get; }
- public ReturnedMessageEvent(byte[] body, MessageProperties properties, MessageReturnedInfo info)
public class StartConsumingFailedEvent
- public IConsumer Consumer { get; }
- public IQueue Queue { get; }
- public StartConsumingFailedEvent(IConsumer consumer, IQueue queue)
public class StartConsumingSucceededEvent
- public IConsumer Consumer { get; }
- public IQueue Queue { get; }
- public StartConsumingSucceededEvent(IConsumer consumer, IQueue queue)

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.Loggers

public class ConsoleLogger : IEasyNetQLogger
public class DelegateLogger : IEasyNetQLogger
public class NullLogger : IEasyNetQLogger

EasyNetQ.Logging

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 ILogProvider
- Logger GetLogger(string name)
- IDisposable OpenMappedContext(string key, object value, bool destructure = false)
- IDisposable OpenNestedContext(string message)
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 enum LogLevel
- Debug = 1
- Error = 4
- Fatal = 5
- Info = 2
- Trace = 0
- Warn = 3
public static class LogProvider
- public static bool IsDisabled { get; set; }
- public static void SetCurrentLogProvider(ILogProvider logProvider)

EasyNetQ.MessageVersioning

public interface ISupersede<T>
public class MessageTypeProperty
- public static MessageTypeProperty CreateForMessageType(Type messageType, ITypeNameSerializer typeNameSerializer)
- public static MessageTypeProperty ExtractFromProperties(MessageProperties messageProperties, ITypeNameSerializer typeNameSerializer)
- public void AppendTo(MessageProperties messageProperties)
- public Type GetMessageType()
public static class MessageVersioningExtensions
- public static IServiceRegister EnableMessageVersioning(this IServiceRegister serviceRegister)
public class MessageVersionStack : IEnumerable<Type>, IEnumerable
- public MessageVersionStack(Type messageType)
- public IEnumerator<Type> GetEnumerator()
- public bool IsEmpty()
- public Type Pop()
public class VersionedMessageSerializationStrategy : IMessageSerializationStrategy
- public VersionedMessageSerializationStrategy(ITypeNameSerializer typeNameSerializer, ISerializer serializer, ICorrelationIdGenerationStrategy correlationIdGenerator)
- public IMessage DeserializeMessage(MessageProperties properties, byte[] body)
- public SerializedMessage SerializeMessage(IMessage message)
public class VersionedPublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
- public VersionedPublishExchangeDeclareStrategy(IConventions conventions, IAdvancedBus advancedBus)
- public IExchange DeclareExchange(string exchangeName, string exchangeType)
- public IExchange DeclareExchange(Type messageType, string exchangeType)
- public Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType)
- public Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType)

EasyNetQ.MultipleExchange

public static class MultipleExchangeExtension
- public static IServiceRegister EnableAdvancedMessagePolymorphism(this IServiceRegister serviceRegister)
public class MultipleExchangePublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
- public MultipleExchangePublishExchangeDeclareStrategy(IConventions conventions, IAdvancedBus advancedBus)
- public IExchange DeclareExchange(Type messageType, string exchangeType)
- public IExchange DeclareExchange(string exchangeName, string exchangeType)
- public Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType)
- public Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType)

EasyNetQ.NonGeneric

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

EasyNetQ.Producer

public class ClientCommandDispatcher : IClientCommandDispatcher, IDisposable
- public ClientCommandDispatcher(IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
- public ClientCommandDispatcher(ConnectionConfiguration configuration, IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
- public Task<T> Invoke<T>(Func<IModel, T> channelAction)
- public Task Invoke(Action<IModel> channelAction)
- public T Invoke<T>(Func<IModel, T> channelAction)
- public void Invoke(Action<IModel> channelAction)
- public Task<T> InvokeAsync<T>(Func<IModel, T> channelAction)
- public Task InvokeAsync(Action<IModel> channelAction)
public class ClientCommandDispatcherFactory : IClientCommandDispatcherFactory
- public ClientCommandDispatcherFactory(IPersistentChannelFactory persistentChannelFactory)
- public ClientCommandDispatcherFactory(ConnectionConfiguration configuration, IPersistentChannelFactory persistentChannelFactory)
public class ClientCommandDispatcherSingleton : IClientCommandDispatcher, IDisposable
- public ClientCommandDispatcherSingleton(IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
- public ClientCommandDispatcherSingleton(ConnectionConfiguration configuration, IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
- public Task<T> Invoke<T>(Func<IModel, T> channelAction)
- public Task Invoke(Action<IModel> channelAction)
- public T Invoke<T>(Func<IModel, T> channelAction)
- public void Invoke(Action<IModel> channelAction)
- public Task<T> InvokeAsync<T>(Func<IModel, T> channelAction)
- public Task InvokeAsync(Action<IModel> channelAction)
public interface IClientCommandDispatcher : IDisposable
- Task<T> Invoke<T>(Func<IModel, T> channelAction)
- Task Invoke(Action<IModel> channelAction)
- T Invoke<T>(Func<IModel, T> channelAction)
- void Invoke(Action<IModel> channelAction)
- Task<T> InvokeAsync<T>(Func<IModel, T> channelAction)
- Task InvokeAsync(Action<IModel> channelAction)
public interface IPublisherConfirms
public interface IPublishConfirmationListener : IDisposable
- IPublishConfirmationWaiter GetWaiter(IModel model)
public interface IPublishConfirmationWaiter
- void Cancel()
- void Wait(TimeSpan timeout)
- Task WaitAsync(TimeSpan timeout)
public interface IPublishExchangeDeclareStrategy
- IExchange DeclareExchange(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
- IExchange DeclareExchange(string exchangeName, string exchangeType)
- IExchange DeclareExchange(Type messageType, string exchangeType)
- Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType)
- Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType)
public interface IResponderConfiguration
- IResponderConfiguration WithPrefetchCount(ushort prefetchCount)
- IResponderConfiguration WithQueueName(string queueName)
public interface IRpc
- Task<TResponse> Request<TRequest, TResponse>(TRequest request)
- Task<TResponse> Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- IDisposable Respond<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
public interface ISendReceive
- IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- Task SendAsync<T>(string queue, T message)
public class PersistentChannel : IPersistentChannel, IDisposable
- public IModel Channel { get; }
- public PersistentChannel(IPersistentConnection connection, IEasyNetQLogger logger, IConnectionConfiguration configuration, IEventBus eventBus)
- public PersistentChannel(IPersistentConnection connection, ConnectionConfiguration configuration, IEventBus eventBus)
public class PersistentChannelFactory : IPersistentChannelFactory
- public PersistentChannelFactory(IEasyNetQLogger logger, IConnectionConfiguration configuration, IEventBus eventBus)
- public PersistentChannelFactory(ConnectionConfiguration configuration, IEventBus eventBus)
public class PublisherConfirms : IPublisherConfirms
public class PublishConfirmationListener : IPublishConfirmationListener, IDisposable
- public PublishConfirmationListener(IEventBus eventBus)
- public void Dispose()
- public IPublishConfirmationWaiter GetWaiter(IModel model)
public class PublishConfirmationWaiter : IPublishConfirmationWaiter
- public PublishConfirmationWaiter(ulong deliveryTag, Task confirmation, CancellationToken cancellation, Action action)
- public void Cancel()
- public void Wait(TimeSpan timeout)
- public Task WaitAsync(TimeSpan timeout)
public class PublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
- public PublishExchangeDeclareStrategy()
- public IExchange DeclareExchange(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
- public PublishExchangeDeclareStrategy(IConventions conventions, IAdvancedBus advancedBus)
- public IExchange DeclareExchange(string exchangeName, string exchangeType)
- public IExchange DeclareExchange(Type messageType, string exchangeType)
- public Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType)
- public Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType)
public class PublishInterruptedException : Exception
- public PublishInterruptedException()
- public PublishInterruptedException(string message)
- public PublishInterruptedException(string message, Exception inner)
public class PublishNackedException : Exception
- protected PublishNackedException(SerializationInfo info, StreamingContext context)
public class ResponderConfiguration : IResponderConfiguration
- public ushort PrefetchCount { get; }
- public string QueueName { get; }
- public ResponderConfiguration(ushort defaultPrefetchCount)
- public IResponderConfiguration WithPrefetchCount(ushort prefetchCount)
- public IResponderConfiguration WithQueueName(string queueName)
public class Rpc : IRpc
- public Rpc(IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IConnectionConfiguration configuration)
- public Task<TResponse> Request<TRequest, TResponse>(TRequest request)
- protected class ResponseAction
- protected struct RpcKey
- protected const string exceptionMessageKey = "ExceptionMessage"
- protected const string isFaultedKey = "IsFaulted"
- protected readonly IAdvancedBus advancedBus
- protected readonly IConventions conventions
- protected readonly TimeSpan disablePeriodicSignaling
- protected readonly IMessageDeliveryModeStrategy messageDeliveryModeStrategy
- protected readonly IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy
- public Rpc(ConnectionConfiguration connectionConfiguration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITimeoutStrategy timeoutStrategy, ITypeNameSerializer typeNameSerializer)
- protected Task ExecuteResponder<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, IMessage<TRequest> requestMessage)
- protected virtual void OnResponderFailure<TRequest, TResponse>(IMessage<TRequest> requestMessage, string exceptionMessage, Exception exception)
- protected virtual void OnResponderSuccess<TRequest, TResponse>(IMessage<TRequest> requestMessage, TResponse response)
- protected void RegisterErrorHandling<TResponse>(Guid correlationId, Timer timer, TaskCompletionSource<TResponse> tcs)
- public virtual Task<TResponse> Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- protected virtual void RequestPublish<TRequest>(TRequest request, string routingKey, string returnQueueName, Guid correlationId)
- public virtual IDisposable Respond<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
- protected virtual string SubscribeToResponse<TRequest, TResponse>()
public class SendReceive : ISendReceive
- public SendReceive(IAdvancedBus advancedBus)
- public SendReceive(IAdvancedBus advancedBus, IMessageDeliveryModeStrategy messageDeliveryModeStrategy)
- public IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- public IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- public IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- public Task SendAsync<T>(string queue, T message)

EasyNetQ.Scheduling

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

EasyNetQ.SystemMessages

public class Error
- public string Queue { get; set; }
public class ScheduleMe
- public string CancellationKey { get; set; }
- public string Exchange { get; set; }
- public string ExchangeType { get; set; }
- public MessageProperties MessageProperties { get; set; }
- public string RoutingKey { get; set; }
public class UnscheduleMe
- public string CancellationKey { get; set; }
- public UnscheduleMe()

EasyNetQ.Topology

public class Binding : IBinding
- public IDictionary<string, object> Headers { get; }
- public Binding(IBindable bindable, IExchange exchange, string routingKey)
- public Binding(IBindable bindable, IExchange exchange, string routingKey, IDictionary<string, object> headers)
public static class ExchangeType
- public ExchangeType()
public interface IBinding
- IDictionary<string, object> Headers { get; }

API Diff between 3.0.1 and 0.27.4.220

EasyNetQ

EasyNetQ.AutoSubscribe

EasyNetQ.ConnectionString

EasyNetQ.Consumer

EasyNetQ.DI

EasyNetQ.Events

EasyNetQ.FluentConfiguration

EasyNetQ.Interception

EasyNetQ.Internals

EasyNetQ.LightInject

EasyNetQ.Loggers

EasyNetQ.Logging

EasyNetQ.MessageVersioning

EasyNetQ.MultipleExchange

EasyNetQ.NonGeneric

EasyNetQ.Producer

EasyNetQ.Scheduling

EasyNetQ.SystemMessages

EasyNetQ.Topology