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

API Diff between 3.0.1 and 0.9.2.76

1578 Additions 172 Removals

EasyNetQ

public class AutoSubscriber
public static class BusExtensions
public class ComponentRegistration
public class ConcurrentHashSet<T> : ISet<T>, ICollection<T>, IEnumerable<T>, IEnumerable
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 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 sealed delegate CancelSubscription : MulticastDelegate
- public CancelSubscription(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
- public virtual void EndInvoke(IAsyncResult result)
- public virtual void Invoke()
public class ConnectionConfiguration
- public IDictionary<string, string> ClientProperties { get; }
- public IEnumerable<IHostConfiguration> Hosts { get; set; }
- public Uri AMQPConnectionString { get; set; }
- public IList<AuthMechanismFactory> AuthMechanisms { get; set; }
- public IDictionary<string, object> ClientProperties { get; }
- public TimeSpan ConnectIntervalAttempt { get; set; }
- public IEnumerable<HostConfiguration> Hosts { get; set; }
- public string Name { get; set; }
- public bool PersistentMessages { get; set; }
- public string Platform { get; set; }
- public string Product { get; set; }
- public bool PublisherConfirms { get; set; }
- public SslOption Ssl { get; }
- public ushort Timeout { 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 ConsumerAttribute : Attribute
public class ConsumerInfo
public sealed delegate ConsumerTagConvention : MulticastDelegate
- public ConsumerTagConvention(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
- public virtual string EndInvoke(IAsyncResult result)
- public virtual string Invoke()
public class Conventions : IConventions
- public ConsumerTagConvention ConsumerTagConvention { get; set; }
- public RpcExchangeNameConvention RpcExchangeNamingConvention { get; set; }
- public RpcExchangeNameConvention RpcRequestExchangeNamingConvention { get; set; }
- public RpcExchangeNameConvention RpcResponseExchangeNamingConvention { get; set; }
- public RpcReturnQueueNamingConvention RpcReturnQueueNamingConvention { get; set; }
- public RpcRoutingKeyNamingConvention RpcRoutingKeyNamingConvention { get; set; }
- public Conventions()
- public Conventions(ITypeNameSerializer typeNameSerializer)
public class CorrelationIdGenerator
public class DefaultClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
public class DefaultMessageDispatcher : IMessageDispatcher
public class DefaultServiceProvider : IServiceProvider, IServiceRegister
public class EasyNetQConsumer : DefaultBasicConsumer
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
- public EasyNetQResponderException()
- public EasyNetQResponderException(string message)
- public EasyNetQResponderException(string format, string[] args)
- public EasyNetQResponderException(string message, Exception inner)
public sealed delegate ErrorExchangeNameConvention : MulticastDelegate
- public virtual IAsyncResult BeginInvoke(string originalRoutingKey, AsyncCallback callback, object object)
- public virtual IAsyncResult BeginInvoke(MessageReceivedInfo info, AsyncCallback callback, object object)
- public virtual string Invoke(string originalRoutingKey)
- public virtual string Invoke(MessageReceivedInfo info)
public class EventBus : IEventBus
- public EventBus()
- public void Publish<TEvent>(TEvent event)
- public CancelSubscription Subscribe<TEvent>(Action<TEvent> eventHandler)
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
- IServiceResolver Container { get; }
- IConventions Conventions { get; }
- ISerializer Serializer { get; }
- SerializeType SerializeType { get; }
- event Action Connected
- event Action Disconnected
- IAdvancedPublishChannel OpenPublishChannel()
- IAdvancedPublishChannel OpenPublishChannel(Action<IChannelConfiguration> configure)
- void Subscribe<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
- void Subscribe(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
- 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)
- IBinding Bind(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
- IBinding Bind(IExchange source, IExchange destination, string routingKey)
- 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)
- void BindingDelete(IBinding binding)
- IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
- IDisposable Consume<T>(IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage)
- IDisposable Consume<T>(IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
- IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers)
- 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)
- IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
- 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 ExchangeDelete(IExchange exchange, bool ifUnused = false)
- 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)
- IQueue QueueDeclare()
- 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)
- void QueueDelete(IQueue queue, bool ifUnused = false, bool ifEmpty = false)
- void QueuePurge(IQueue queue)
public interface IAdvancedPublishChannel : IDisposable
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
- IPublishChannel OpenPublishChannel()
- IPublishChannel OpenPublishChannel(Action<IChannelConfiguration> configure)
- void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder)
- void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, IDictionary<string, object> arguments)
- void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder)
- void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, IDictionary<string, object> arguments)
- void Subscribe<T>(string subscriptionId, Action<T> onMessage)
- void Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration<T>> configure)
- void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration<T>> configure)
- void Publish<T>(T message)
- void Publish<T>(T message, Action<IPublishConfiguration> configure)
- void Publish<T>(T message, string topic)
- Task PublishAsync<T>(T message)
- Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure)
- Task PublishAsync<T>(T message, string topic)
- IDisposable Receive<T>(string queue, Action<T> onMessage)
- IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive<T>(string queue, Func<T, Task> onMessage)
- IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers)
- IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- TResponse Request<TRequest, TResponse>(TRequest request)
- TResponse Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request)
- Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder)
- IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, Action<IResponderConfiguration> configure)
- IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder)
- IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
- void Send<T>(string queue, T message)
- 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 IConsume<T>
public interface IConsumerErrorStrategy : IDisposable
public interface IConsumerFactory : IDisposable
public interface IConventions
- ConsumerTagConvention ConsumerTagConvention { get; set; }
- RpcExchangeNameConvention RpcExchangeNamingConvention { get; set; }
- RpcExchangeNameConvention RpcRequestExchangeNamingConvention { get; set; }
- RpcExchangeNameConvention RpcResponseExchangeNamingConvention { get; set; }
- RpcReturnQueueNamingConvention RpcReturnQueueNamingConvention { get; set; }
- RpcRoutingKeyNamingConvention RpcRoutingKeyNamingConvention { get; set; }
public interface IEasyNetQLogger
public interface IHostConfiguration
public interface ICorrelationIdGenerationStrategy
- string GetCorrelationId()
public interface IEventBus
- void Publish<TEvent>(TEvent event)
- CancelSubscription Subscribe<TEvent>(Action<TEvent> eventHandler)
public interface IMessage
- Type MessageType { get; }
- MessageProperties Properties { get; }
- object GetBody()
public interface IMessage<T> : IMessage
- MessageProperties Properties { get; }
public interface IMessageDispatcher
public interface IMessageDeliveryModeStrategy
- byte GetDeliveryMode(Type messageType)
public interface IMessageSerializationStrategy
- IMessage DeserializeMessage(MessageProperties properties, byte[] body)
- SerializedMessage SerializeMessage(IMessage message)
public interface IPersistentConnection : IDisposable
- event Action Connected
- event Action Disconnected
- void Initialize()
public interface IPublishChannel : IDisposable
public interface IPublisherConfirms
public interface ISaga
public interface IPersistentConnectionFactory
- IPersistentConnection CreateConnection()
public interface ISerializer
- 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 interface ITypeNameSerializer
- Type DeSerialize(string typeName)
- string Serialize(Type type)
public class JsonSerializer : ISerializer
- public JsonSerializer(JsonSerializerSettings serializerSettings)
- 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> Intersperse<T>(this IEnumerable<T> items, T separator)
- public static void Shuffle<T>(this IList<T> list)
- public static IEnumerable<T> SurroundWith<T>(this IEnumerable<T> items, T first, T last)
public class Message<T> : IMessage<T>, IMessage
- public Type MessageType { get; }
- public Message(T body, MessageProperties properties)
- public object GetBody()
public sealed delegate MessageCallback : MulticastDelegate
public static class MessageDeliveryMode
- public const byte NonPersistent = 1
- public const byte Persistent = 2
public class MessageDeliveryModeStrategy : IMessageDeliveryModeStrategy
- public MessageDeliveryModeStrategy(ConnectionConfiguration connectionConfiguration)
- public byte GetDeliveryMode(Type messageType)
public static class MessageFactory
- public static IMessage CreateInstance(Type messageType, object body)
- 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 bool AppIdPresent { get; set; }
- public bool ClusterIdPresent { get; set; }
- public bool ContentEncodingPresent { get; set; }
- public bool ContentTypePresent { get; set; }
- public bool CorrelationIdPresent { get; set; }
- public bool DeliveryModePresent { get; set; }
- public IDictionary Headers { get; set; }
- public bool ExpirationPresent { get; set; }
- public IDictionary<string, object> Headers { get; set; }
- public bool HeadersPresent { get; set; }
- public bool MessageIdPresent { get; set; }
- public bool PriorityPresent { get; set; }
- public bool ReplyToPresent { get; set; }
- public bool TimestampPresent { get; set; }
- public bool TypePresent { get; set; }
- public bool UserIdPresent { get; set; }
- public object Clone()
public class MessageReceivedInfo
- public string Queue { get; set; }
- public MessageReceivedInfo(string consumerTag, ulong deliverTag, bool redelivered, string exchange, string routingKey, string queue)
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 event Action Connected
- public event Action Disconnected
- public PersistentConnection(IConnectionFactory connectionFactory, IEasyNetQLogger logger)
- public PersistentConnection(IConnectionFactory connectionFactory, IEventBus eventBus)
- public void Initialize()
public enum PostExceptionAckStrategy
public class PublisherConfirms : IPublisherConfirms
public class QueueingConsumerFactory : IConsumerFactory, IDisposable
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 const bool NoAck = false
- public IPersistentConnection Connection { get; }
- public IConsumerFactory ConsumerFactory { get; }
- public IServiceResolver Container { get; }
- public Func<string> GetCorrelationId { get; }
- public IEasyNetQLogger Logger { get; }
- public virtual ISerializer Serializer { get; }
- public virtual SerializeType SerializeType { get; }
- public event Action Connected
- public event Action Disconnected
- public RabbitAdvancedBus(IConnectionConfiguration connectionConfiguration, IConnectionFactory connectionFactory, SerializeType serializeType, ISerializer serializer, IConsumerFactory consumerFactory, IEasyNetQLogger logger, Func<string> getCorrelationId, IConventions conventions)
- 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)
- public virtual IBinding Bind(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
- public virtual IBinding Bind(IExchange source, IExchange destination, string routingKey)
- 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 virtual void BindingDelete(IBinding binding)
- public IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
- public IDisposable Consume<T>(IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage)
- public IDisposable Consume<T>(IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
- public IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers)
- 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 IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
- 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, 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 virtual void ExchangeDelete(IExchange exchange, bool ifUnused = false)
- public IBasicGetResult<T> Get<T>(IQueue queue)
- public IBasicGetResult Get(IQueue queue)
- public uint MessageCount(IQueue queue)
- protected void OnBlocked(ConnectionBlockedEvent args)
- public virtual IAdvancedPublishChannel OpenPublishChannel()
- public virtual IAdvancedPublishChannel OpenPublishChannel(Action<IChannelConfiguration> configure)
- public virtual void Subscribe<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
- public virtual void Subscribe(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
- 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()
- 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 virtual void QueueDelete(IQueue queue, bool ifUnused = false, bool ifEmpty = false)
- public virtual void QueuePurge(IQueue queue)
public class RabbitAdvancedPublishChannel : IAdvancedPublishChannel, IDisposable
public class RabbitBus : IBus, IDisposable
- public IConventions Conventions { get; }
- public IEasyNetQLogger Logger { get; }
- public SerializeType SerializeType { get; }
- public event Action Connected
- public event Action Disconnected
- public RabbitBus(SerializeType serializeType, IEasyNetQLogger logger, IConventions conventions, IAdvancedBus advancedBus)
- public RabbitBus(IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IRpc rpc, ISendReceive sendReceive, ConnectionConfiguration connectionConfiguration)
- protected void OnConnected()
- protected void OnDisconnected()
- public virtual IPublishChannel OpenPublishChannel()
- public virtual IPublishChannel OpenPublishChannel(Action<IChannelConfiguration> configure)
- public virtual void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder)
- public virtual void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, IDictionary<string, object> arguments)
- public virtual void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder)
- public virtual void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, IDictionary<string, object> arguments)
- public virtual void Subscribe<T>(string subscriptionId, Action<T> onMessage)
- public virtual void Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration<T>> configure)
- public virtual void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- public virtual void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration<T>> configure)
- public virtual void Publish<T>(T message)
- public virtual void Publish<T>(T message, string topic)
- public virtual void Publish<T>(T message, Action<IPublishConfiguration> configure)
- public virtual Task PublishAsync<T>(T message)
- public virtual Task PublishAsync<T>(T message, string topic)
- public virtual Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure)
- public virtual IDisposable Receive<T>(string queue, Action<T> onMessage)
- public virtual IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Receive<T>(string queue, Func<T, Task> onMessage)
- public virtual IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers)
- public virtual IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- public virtual TResponse Request<TRequest, TResponse>(TRequest request)
- public virtual TResponse Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- public virtual Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request)
- public virtual Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
- public virtual IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder)
- public IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, Action<IResponderConfiguration> configure)
- public virtual IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder)
- public IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
- public virtual void Send<T>(string queue, T message)
- 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 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 class RabbitPublishChannel : IPublishChannel, IDisposable
public class RandomClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
- public bool Succeeded { get; }
- public RandomClusterHostSelectionStrategy()
- public void Add(T item)
- public T Current()
- public virtual IEnumerator<T> GetEnumerator()
- public bool Next()
- public void Reset()
- public void Success()
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 SerializeType : MulticastDelegate
public class SubscriptionAction
public class SubscriptionInfo
public sealed delegate SubsriberNameFromDelegate : MulticastDelegate
public sealed delegate RpcReturnQueueNamingConvention : MulticastDelegate
- public RpcReturnQueueNamingConvention(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
- public virtual string EndInvoke(IAsyncResult result)
- public virtual string Invoke()
public sealed delegate RpcRoutingKeyNamingConvention : MulticastDelegate
- public RpcRoutingKeyNamingConvention(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
- public virtual string EndInvoke(IAsyncResult result)
- public virtual string Invoke(Type messageType)
public class SerializedMessage
- public byte[] Body { get; }
- public MessageProperties Properties { get; }
- public SerializedMessage(MessageProperties properties, byte[] body)
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

EasyNetQ.AmqpExceptions

public class AmapExceptionPreface
- public string Text { get; }
- public AmapExceptionPreface(string text)
public class AmqpException
- public static ushort ConnectionClosed
- public int ClassId { get; }
- public int Code { get; }
- public IList<IAmqpExceptionElement> Elements { get; }
- public int MethodId { get; }
- public AmapExceptionPreface Preface { get; }
- public AmqpException(AmapExceptionPreface preface, IList<IAmqpExceptionElement> elements)
public class AmqpExceptionClassIdElement : AmqpExceptionIntegerValueElement
- public AmqpExceptionClassIdElement()
public class AmqpExceptionCodeElement : AmqpExceptionIntegerValueElement
- public AmqpExceptionCodeElement()
public static class AmqpExceptionGrammar
- public static Parser<ushort> Number
- public static Parser<T> MakeIntegerElementParser<T>(string key) where T : AmqpExceptionIntegerValueElement
- public static AmqpException ParseExceptionString(string exceptionMessage)
public abstract class AmqpExceptionIntegerValueElement : IAmqpExceptionElement
- public int Value { get; set; }
- protected AmqpExceptionIntegerValueElement()
public class AmqpExceptionKeyValueElement : IAmqpExceptionElement
- public string Key { get; }
- public string Value { get; }
- public AmqpExceptionKeyValueElement(string key, string value)
public class AmqpExceptionMethodIdElement : AmqpExceptionIntegerValueElement
- public AmqpExceptionMethodIdElement()
public interface IAmqpExceptionElement
public class TextElement : IAmqpExceptionElement
- public string Text { get; }
- public TextElement(string text)

EasyNetQ.AutoSubscribe

public class AutoSubscriber
- protected const string ConsumeAsyncMethodName = "ConsumeAsync"
- protected const string ConsumeMethodName = "Consume"
- protected const string DispatchAsyncMethodName = "DispatchAsync"
- protected const string DispatchMethodName = "Dispatch"
- protected const string SubscribeAsyncMethodName = "SubscribeAsync"
- protected const string SubscribeMethodName = "Subscribe"
- protected readonly IBus bus
- public IAutoSubscriberMessageDispatcher AutoSubscriberMessageDispatcher { get; set; }
- protected Action<ISubscriptionConfiguration> ConfigureSubscriptionConfiguration { get; set; }
- protected Func<AutoSubscriberConsumerInfo, string> GenerateSubscriptionId { get; set; }
- public string SubscriptionIdPrefix { get; }
- public AutoSubscriber(IBus bus, string subscriptionIdPrefix)
- protected virtual string DefaultSubscriptionIdGenerator(AutoSubscriberConsumerInfo c)
- protected virtual MethodInfo GetSubscribeMethodOfBus(string methodName, Type parmType)
- protected virtual AutoSubscriberConsumerAttribute GetSubscriptionAttribute(AutoSubscriberConsumerInfo consumerInfo)
- protected virtual IEnumerable<KeyValuePair<Type, AutoSubscriberConsumerInfo[]>> GetSubscriptionInfos(IEnumerable<Type> types, Type interfaceType)
- protected virtual void InvokeMethods(IEnumerable<KeyValuePair<Type, AutoSubscriberConsumerInfo[]>> subscriptionInfos, string dispatchName, MethodInfo genericBusSubscribeMethod, Func<Type, Type> subscriberTypeFromMessageTypeDelegate)
- public virtual void Subscribe(Assembly[] assemblies)
- public virtual void Subscribe(Type[] consumerTypes)
- public virtual void SubscribeAsync(Assembly[] assemblies)
- public virtual void SubscribeAsync(Type[] consumerTypes)
public class AutoSubscriberConsumerAttribute : Attribute
- public string SubscriptionId { get; set; }
- public AutoSubscriberConsumerAttribute()
public class AutoSubscriberConsumerInfo
- public Type ConcreteType { get; }
- public MethodInfo ConsumeMethod { get; }
- public Type InterfaceType { get; }
- public Type MessageType { get; }
- public AutoSubscriberConsumerInfo(Type concreteType, Type interfaceType, Type messageType)
public class DefaultAutoSubscriberMessageDispatcher : IAutoSubscriberMessageDispatcher
- public DefaultAutoSubscriberMessageDispatcher(IServiceResolver resolver)
- public DefaultAutoSubscriberMessageDispatcher()
- public void Dispatch<TMessage, TConsumer>(TMessage message) where TConsumer : IConsume<TMessage>
- public Task DispatchAsync<TMessage, TAsyncConsumer>(TMessage message) where TAsyncConsumer : IConsumeAsync<TMessage>
public class ForTopicAttribute : Attribute
- public string Topic { get; set; }
- public ForTopicAttribute(string topic)
public interface IAutoSubscriberMessageDispatcher
- void Dispatch<TMessage, TConsumer>(TMessage message) where TConsumer : IConsume<TMessage>
- Task DispatchAsync<TMessage, TConsumer>(TMessage message) where TConsumer : IConsumeAsync<TMessage>
public interface IConsume<T>
- void Consume(T message)
public interface IConsumeAsync<T>
- 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<Uri> AMQP
- public static Parser<Func<ConnectionConfiguration, ConnectionConfiguration>> AMQPAlone
- public static Parser<bool> Bool
- 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 ConsumerCancellation : IDisposable
- public ConsumerCancellation(Action onCancellation)
- public void Dispose()
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 bool IsDisposed { get; }
- public ConsumerDispatcher(ConnectionConfiguration configuration)
- public void Dispose()
- public void OnDisconnected()
- public void QueueAction(Action action)
public class ConsumerDispatcherFactory : IConsumerDispatcherFactory, IDisposable
- public ConsumerDispatcherFactory(ConnectionConfiguration configuration)
- public void Dispose()
- public IConsumerDispatcher GetConsumerDispatcher()
- public void OnDisconnected()
public class ConsumerExecutionContext
- public byte[] Body { get; }
- public IBasicConsumer Consumer { get; }
- public MessageReceivedInfo Info { get; }
- public MessageProperties Properties { get; }
- public Func<byte[], MessageProperties, MessageReceivedInfo, Task> UserHandler { get; }
- public ConsumerExecutionContext(Func<byte[], MessageProperties, MessageReceivedInfo, Task> userHandler, MessageReceivedInfo info, MessageProperties properties, byte[] body, IBasicConsumer consumer)
public class ConsumerFactory : IConsumerFactory, IDisposable
- public ConsumerFactory(IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
- 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 void Dispose()
public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
- public DefaultConsumerErrorStrategy(IConnectionFactory connectionFactory, ISerializer serializer, IConventions conventions, ITypeNameSerializer typeNameSerializer, IErrorMessageSerializer errorMessageSerializer)
- protected void Connect()
- public virtual void Dispose()
- 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 bool ThrowOnNoMatchingHandler { get; set; }
- public HandlerCollection()
- public IHandlerRegistration Add<T>(Func<IMessage<T>, MessageReceivedInfo, Task> handler)
- public IHandlerRegistration Add<T>(Action<IMessage<T>, MessageReceivedInfo> handler)
- public Func<IMessage<T>, MessageReceivedInfo, Task> GetHandler<T>()
- public Func<IMessage, MessageReceivedInfo, Task> GetHandler(Type messageType)
public class HandlerCollectionFactory : IHandlerCollectionFactory
- 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(IConsumerErrorStrategy consumerErrorStrategy, IEventBus eventBus)
- public void Dispose()
- protected virtual void DoAck(ConsumerExecutionContext context, AckStrategy ackStrategy)
- protected virtual AckStrategy GetAckStrategy(ConsumerExecutionContext context, Task task)
- public virtual void InvokeUserMessageHandler(ConsumerExecutionContext context)
public interface IConsumer : IDisposable
- IDisposable StartConsuming()
public interface IConsumerConfiguration
- bool IsExclusive { get; }
- ushort PrefetchCount { get; }
- int Priority { get; }
- IConsumerConfiguration AsExclusive()
- IConsumerConfiguration WithPrefetchCount(ushort prefetchCount)
- IConsumerConfiguration WithPriority(int priority)
public interface IConsumerDispatcher : IDisposable
- void OnDisconnected()
- void QueueAction(Action action)
public interface IConsumerDispatcherFactory : IDisposable
- IConsumerDispatcher GetConsumerDispatcher()
- void OnDisconnected()
public interface IConsumerErrorStrategy : IDisposable
- AckStrategy HandleConsumerCancelled(ConsumerExecutionContext context)
- AckStrategy HandleConsumerError(ConsumerExecutionContext context, Exception exception)
public interface IConsumerFactory : IDisposable
- 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
- Func<IMessage<T>, MessageReceivedInfo, Task> GetHandler<T>()
- Func<IMessage, MessageReceivedInfo, Task> GetHandler(Type messageType)
public interface IHandlerCollectionFactory
- IHandlerCollection CreateHandlerCollection(IQueue queue)
public interface IHandlerRegistration
- bool ThrowOnNoMatchingHandler { get; set; }
- IHandlerRegistration Add<T>(Func<IMessage<T>, MessageReceivedInfo, Task> handler)
- IHandlerRegistration Add<T>(Action<IMessage<T>, MessageReceivedInfo> handler)
public interface IHandlerRunner : IDisposable
- void InvokeUserMessageHandler(ConsumerExecutionContext context)
public interface IInternalConsumer : IDisposable
- event Action<IInternalConsumer> Cancelled
- 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 interface IInternalConsumerFactory : IDisposable
- IInternalConsumer CreateConsumer()
- void OnDisconnected()
public class InternalConsumer : IInternalConsumer, IDisposable
- public IModel Model { get; }
- public event Action<IInternalConsumer> Cancelled
- public event EventHandler<ConsumerEventArgs> ConsumerCancelled
- public InternalConsumer(IHandlerRunner handlerRunner, IConsumerDispatcher consumerDispatcher, IConventions conventions, IEventBus eventBus)
- public void Dispose()
- 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, IConventions conventions, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
- public IInternalConsumer CreateConsumer()
- public void Dispose()
- public void OnDisconnected()
public interface IReceiveRegistration
- IReceiveRegistration Add<T>(Func<T, Task> onMessage)
- IReceiveRegistration Add<T>(Action<T> onMessage)
public class PersistentConsumer : IConsumer, IDisposable
- public PersistentConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
- public void Dispose()
- public IDisposable StartConsuming()
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, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
- public void Dispose()
- public IDisposable StartConsuming()

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 AckResult AckResult { get; }
- public byte[] Body { get; }
- public MessageProperties Properties { get; }
- public MessageReceivedInfo ReceivedInfo { get; }
- public AckEvent(MessageReceivedInfo info, MessageProperties properties, byte[] body, AckResult ackResult)
public enum AckResult
- Ack = 0
- Exception = 2
- Nack = 1
- Nothing = 3
public class ConnectionBlockedEvent
- public string Reason { get; }
- public ConnectionBlockedEvent(string reason)
public class ConnectionCreatedEvent
- public ConnectionCreatedEvent()
public class ConnectionDisconnectedEvent
- public ConnectionDisconnectedEvent()
public class ConnectionUnblockedEvent
- public ConnectionUnblockedEvent()
public class ConsumerModelDisposedEvent
- public string ConsumerTag { get; }
- public ConsumerModelDisposedEvent(string consumerTag)
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 PublishChannelCreatedEvent
- public IModel Channel { get; }
- public PublishChannelCreatedEvent(IModel channel)
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)
public class StoppedConsumingEvent
- public IConsumer Consumer { get; }
- public StoppedConsumingEvent(IConsumer consumer)

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

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 void Publish(this IBus bus, Type messageType, object message)
- public static void Publish(this IBus bus, Type messageType, object message, string topic)
- public static Task PublishAsync(this IBus bus, Type messageType, object message)
- public static Task PublishAsync(this IBus bus, Type messageType, object message, string topic)
- 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(ConnectionConfiguration configuration, IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
- public void Dispose()
- 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(ConnectionConfiguration configuration, IPersistentChannelFactory persistentChannelFactory)
- public IClientCommandDispatcher GetClientCommandDispatcher(IPersistentConnection connection)
public class ClientCommandDispatcherSingleton : IClientCommandDispatcher, IDisposable
- public ClientCommandDispatcherSingleton(ConnectionConfiguration configuration, IPersistentConnection connection, IPersistentChannelFactory persistentChannelFactory)
- public void Dispose()
- 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
- 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 IClientCommandDispatcherFactory
- IClientCommandDispatcher GetClientCommandDispatcher(IPersistentConnection connection)
public interface IPersistentChannel : IDisposable
- void InvokeChannelAction(Action<IModel> channelAction)
public interface IPersistentChannelFactory
- IPersistentChannel CreatePersistentChannel(IPersistentConnection connection)
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(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, Action<IRequestConfiguration> configure)
- IDisposable Respond<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder)
- IDisposable Respond<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
public interface ISendReceive
- IDisposable Receive<T>(string queue, Action<T> onMessage)
- IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive<T>(string queue, Func<T, Task> onMessage)
- IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers)
- IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- void Send<T>(string queue, T message)
- Task SendAsync<T>(string queue, T message)
public class PersistentChannel : IPersistentChannel, IDisposable
- public PersistentChannel(IPersistentConnection connection, ConnectionConfiguration configuration, IEventBus eventBus)
- public void Dispose()
- public void InvokeChannelAction(Action<IModel> channelAction)
public class PersistentChannelFactory : IPersistentChannelFactory
- public PersistentChannelFactory(ConnectionConfiguration configuration, IEventBus eventBus)
- public IPersistentChannel CreatePersistentChannel(IPersistentConnection connection)
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(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
- public PublishNackedException()
- public PublishNackedException(string message)
- public PublishNackedException(string message, Exception inner)
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
- 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)
- 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, IMessageDeliveryModeStrategy messageDeliveryModeStrategy)
- public IDisposable Receive<T>(string queue, Action<T> onMessage)
- public IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- public IDisposable Receive<T>(string queue, Func<T, Task> onMessage)
- public IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- public IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers)
- public IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- public void Send<T>(string queue, T message)
- 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 MessageBasicProperties BasicProperties { get; set; }
- public MessageProperties BasicProperties { get; set; }
- public string Queue { get; set; }
public class MessageBasicProperties
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 string[] RoutingKeys { get; }
- public Binding(IBindable bindable, IExchange exchange, string[] routingKeys)
- public void Visit(ITopologyVisitor visitor)
- public IDictionary<string, object> Headers { get; }
- public string RoutingKey { get; }
- public Binding(IBindable bindable, IExchange exchange, string routingKey, IDictionary<string, object> headers)
public class DefaultExchange : Exchange
public class Exchange : IExchange, IBindable
- protected readonly IList<IBinding> bindings
- public IDictionary Arguments { get; }
- public bool AutoDelete { get; }
- public string ExchangeType { get; }
- protected Exchange(string name, string exchangeType)
- protected Exchange(string name, string exchangeType, bool autoDelete, IDictionary arguments)
- public static IExchange DeclareDirect(string exchangeName)
- public static IExchange DeclareDirect(string exchangeName, bool autoDelete, IDictionary arguments)
- public static IExchange DeclareFanout(string exchangeName)
- public static IExchange DeclareFanout(string exchangeName, bool autoDelete, IDictionary arguments)
- public static IExchange DeclareTopic(string exchangeName)
- public static IExchange DeclareTopic(string exchangeName, bool autoDelete, IDictionary arguments)
- public Exchange(string name)
- public virtual void BindTo(IExchange exchange, string[] routingKeys)
- public virtual void Visit(ITopologyVisitor visitor)
public static class ExchangeType
- public const string Header = "headers"
- public ExchangeType()
public interface IBindable
- void BindTo(IExchange exchange, string[] routingKeys)
public interface IBinding
- string[] RoutingKeys { get; }
- IDictionary<string, object> Headers { get; }
- string RoutingKey { get; }
public interface IQueue : IBindable
- bool IsSingleUse { get; }
- bool IsExclusive { get; }
- IQueue SetAsSingleUse()
public interface ITopology
public interface ITopologyVisitor
public class Queue : IQueue, IBindable
- public bool IsSingleUse { get; }
- public bool IsExclusive { get; }
- protected Queue(bool durable, bool exclusive, bool autoDelete, string name, IDictionary<string, object> arguements)
- protected Queue(bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
- public static IQueue Declare(bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
- public static IQueue Declare(bool durable, bool exclusive, bool autoDelete, string name, IDictionary<string, object> arguments)
- public static IQueue DeclareDurable(string queueName)
- public static IQueue DeclareDurable(string queueName, IDictionary<string, object> arguments)
- public static IQueue DeclareTransient(string queueName)
- public static IQueue DeclareTransient(string queueName, IDictionary<string, object> arguments)
- public static IQueue DeclareTransient()
- public void BindTo(IExchange exchange, string[] routingKeys)
- public IQueue SetAsSingleUse()
- public void Visit(ITopologyVisitor visitor)
- public Queue(string name, bool isExclusive)
public class TopologyBuilder : ITopologyVisitor

Sprache

public static class Parse
- public static Parser<IEnumerable<char>> CaseInsensitiveString(string s)
- public static Parser<char> CharCaseInsensitive(char c)

API Diff between 3.0.1 and 0.9.2.76

EasyNetQ

EasyNetQ.AmqpExceptions

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

Sprache