EasyNetQ by Mike Hadlow, Contributors (see GitHub repo)

<PackageReference Include="EasyNetQ" Version="0.57.2.431" />

---

API Diff between 0.57.2.431 and 4.0.5

291 Additions 274 Removals

EasyNetQ

• 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 ComponentRegistration
  • public ComponentRegistration()
  • public static void RegisterServices(IContainer container)
• public class ConnectionConfiguration
  • public IList<IAuthMechanismFactory> AuthMechanisms { get; set; }
  • public bool CancelOnHaFailover { get; set; }
  • public TimeSpan ConnectIntervalAttempt { get; set; }
  • public int DispatcherQueueSize { get; set; }
  • public string Name { get; set; }
• public class Conventions : IConventions
  • public RpcExchangeNameConvention RpcRequestExchangeNamingConvention { get; set; }
  • public RpcExchangeNameConvention RpcResponseExchangeNamingConvention { get; set; }
  • public RpcExchangeNameConvention RpcExchangeNamingConvention { get; set; }
• public static class ConventionsExtensions
• public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
  • public IMessage<T> DeserializeMessage<T>(MessageProperties properties, byte[] body)
• public class DefaultTypeNameSerializer : ITypeNameSerializer
• public class DefaultServiceProvider : IContainer, IServiceProvider, IServiceRegister
  • public DefaultServiceProvider()
  • public virtual IServiceRegister Register<TService>(Func<IServiceProvider, TService> serviceCreator)
  • public IServiceRegister Register<TService, TImplementation>() where TImplementation : TService
  • public virtual TService Resolve<TService>()
  • public object Resolve(Type serviceType)
• public class EasyNetQException : Exception
  • public EasyNetQException(string format, object[] args)
  • public EasyNetQException(string format, string[] args)
• public class EasyNetQInvalidMessageTypeException : EasyNetQException
  • public EasyNetQInvalidMessageTypeException()
  • public EasyNetQInvalidMessageTypeException(string message)
  • public EasyNetQInvalidMessageTypeException(string format, string[] args)
  • public EasyNetQInvalidMessageTypeException(string message, Exception inner)
  • protected EasyNetQInvalidMessageTypeException(SerializationInfo info, StreamingContext context)
• public class EasyNetQResponderException : EasyNetQException
  • public EasyNetQResponderException(string format, object[] args)
  • public EasyNetQResponderException(string format, string[] args)
• public sealed delegate ErrorQueueNameConvention : MulticastDelegate
  • public virtual IAsyncResult BeginInvoke(MessageReceivedInfo info, AsyncCallback callback, object object)
  • public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
  • public virtual string Invoke(MessageReceivedInfo info)
  • public virtual string Invoke()
• public class EventBus : IEventBus
  • public IDisposable Subscribe<TEvent>(Action<TEvent> eventHandler)
  • public CancelSubscription Subscribe<TEvent>(Action<TEvent> eventHandler)
• public static class Extensions
  • public static TimeSpan Double(this TimeSpan timeSpan)
  • public static string Trim(this string s, int start, int length)
  • public static void SafeDispose(this IDisposable disposable)
• public interface IAdvancedBus : IDisposable
  • IServiceResolver Container { get; }
  • IContainer Container { get; }
  • IBinding Bind(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
  • IBinding Bind(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers)
  • Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
  • Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers)
  • IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
  • Task<IQueue> QueueDeclareAsync()
• public interface IBus : IDisposable
  • void Publish<T>(T message, Action<IPublishConfiguration> configure)
  • Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure)
  • TResponse Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
  • Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
• public interface IContainer : IServiceProvider, IServiceRegister
• public interface IConventions
  • RpcExchangeNameConvention RpcRequestExchangeNamingConvention { get; set; }
  • RpcExchangeNameConvention RpcResponseExchangeNamingConvention { get; set; }
  • RpcExchangeNameConvention RpcExchangeNamingConvention { get; set; }
• public interface IEasyNetQLogger
  • void DebugWrite(string format, object[] args)
  • void ErrorWrite(string format, object[] args)
  • void ErrorWrite(Exception exception)
  • void InfoWrite(string format, object[] args)
• public interface IEventBus
  • IDisposable Subscribe<TEvent>(Action<TEvent> eventHandler)
  • CancelSubscription Subscribe<TEvent>(Action<TEvent> eventHandler)
• public interface IMessageSerializationStrategy
  • IMessage<T> DeserializeMessage<T>(MessageProperties properties, byte[] body)
• public interface IPersistentConnectionFactory
• public interface ISerializer
  • object BytesToMessage(Type messageType, byte[] bytes)
  • byte[] MessageToBytes(Type messageType, object message)
  • T BytesToMessage<T>(byte[] bytes)
  • object BytesToMessage(string typeName, byte[] bytes)
  • byte[] MessageToBytes<T>(T message)
• public interface IServiceProvider
  • TService Resolve<TService>()
• public interface IServiceRegister
  • IServiceRegister Register<TService>(Func<IServiceProvider, TService> serviceCreator)
  • IServiceRegister Register<TService, TImplementation>() where TImplementation : TService
• public class JsonSerializer : ISerializer
  • public JsonSerializer()
  • public JsonSerializer(JsonSerializerSettings serializerSettings)
  • public object BytesToMessage(Type messageType, byte[] bytes)
  • public byte[] MessageToBytes(Type messageType, object message)
  • public JsonSerializer(ITypeNameSerializer typeNameSerializer)
  • public T BytesToMessage<T>(byte[] bytes)
  • public object BytesToMessage(string typeName, byte[] bytes)
  • public byte[] MessageToBytes<T>(T message)
• public class LegacyRpcConventions : Conventions
• public static class LegacyRpcConventionsExtensions
• public class LegacyTypeNameSerializer : ITypeNameSerializer
• public static class LegacyTypeNamingExtensions
• public class Message<T> : IMessage<T>, IMessage
  • public Message()
  • public void SetProperties(MessageProperties properties)
• public class MessageNotAvailableException : Exception
  • protected MessageNotAvailableException(SerializationInfo info, StreamingContext context)
• public class PersistentConnection : IPersistentConnection, IDisposable
  • public PersistentConnection(IConnectionFactory connectionFactory, IEventBus eventBus)
  • public PersistentConnection(IConnectionFactory connectionFactory, IEasyNetQLogger logger, IEventBus eventBus)
  • public void OnConnected()
  • public void OnDisconnected()
• public class PersistentConnectionFactory : IPersistentConnectionFactory
• public class QueueConsumerPair
• public class RabbitAdvancedBus : IAdvancedBus, IDisposable
  • public IServiceResolver Container { get; }
  • public IContainer Container { get; }
  • 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 RabbitAdvancedBus(IConnectionFactory connectionFactory, IConsumerFactory consumerFactory, IEasyNetQLogger logger, IClientCommandDispatcherFactory clientCommandDispatcherFactory, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IContainer container, ConnectionConfiguration connectionConfiguration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, AdvancedBusEventHandlers advancedBusEventHandlers)
  • public virtual IBinding Bind(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
  • public virtual IBinding Bind(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers)
  • public Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers)
  • public Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers)
  • public IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
  • public virtual IQueue QueueDeclare()
  • public Task<IQueue> QueueDeclareAsync()
  • public virtual IQueue QueueDeclare()
• public class RabbitBus : IBus, IDisposable
  • public RabbitBus(IConventions conventions, IAdvancedBus advancedBus, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IRpc rpc, ISendReceive sendReceive, ConnectionConfiguration connectionConfiguration)
  • public RabbitBus(IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IRpc rpc, ISendReceive sendReceive, ConnectionConfiguration connectionConfiguration)
  • public virtual void Publish<T>(T message, Action<IPublishConfiguration> configure)
  • public virtual Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure)
  • public virtual TResponse Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
  • public virtual Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
• public static class RabbitHutch
  • public static IBus CreateBus()
  • public static IBus CreateBus(Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(AdvancedBusEventHandlers advancedBusEventHandlers, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(AdvancedBusEventHandlers advancedBusEventHandlers)
  • public static IBus CreateBus(string connectionString, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, ushort requestedHeartbeat, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(ConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory, Action<IServiceRegister> registerServices)
  • public static void RegisterBus(IServiceRegister serviceRegister, Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(string connectionString, AdvancedBusEventHandlers advancedBusEventHandlers)
  • public static IBus CreateBus(string connectionString, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(string connectionString, AdvancedBusEventHandlers advancedBusEventHandlers, 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(string hostName, ushort hostPort, string virtualHost, string username, string password, ushort requestedHeartbeat, AdvancedBusEventHandlers advancedBusEventHandlers, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(ConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
  • public static IBus CreateBus(ConnectionConfiguration connectionConfiguration, AdvancedBusEventHandlers advancedBusEventHandlers, Action<IServiceRegister> registerServices)
  • public static void SetContainerFactory(Func<IContainer> createContainer)
• public static class ReflectionHelpers
  • public static T CreateInstance<T>()
  • public static object CreateInstance(Type objectType, object arg)
  • public static object CreateInstance(Type objectType, object firstArg, object secondArg)
• public sealed delegate RpcExchangeNameConvention : MulticastDelegate
  • public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
  • public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
  • public virtual string Invoke(Type messageType)
  • public virtual string Invoke()
• public sealed class TimeBudget
  • public static TimeBudget Infinite()
  • public static TimeSpan op_Implicit(TimeBudget source)
  • public static TimeBudget Start(TimeSpan budget)
  • public TimeBudget(TimeSpan budget, TimeSpan precision)
  • public TimeBudget(TimeSpan budget)
  • public TimeSpan GetRemainingTime()
  • public TimeBudget Start()
• public class TypeNameSerializer : ITypeNameSerializer
  • public TypeNameSerializer()
  • public Type DeSerialize(string typeName)
  • public string Serialize(Type type)

EasyNetQ.AmqpExceptions

• public class AmapExceptionPreface
  • public string Text { get; }
  • public AmapExceptionPreface(string text)
• public class AmqpException
  • public AmqpExceptionPreface Preface { get; }
  • public AmqpException(AmqpExceptionPreface preface, IList<IAmqpExceptionElement> elements)
  • public AmapExceptionPreface Preface { get; }
  • public AmqpException(AmapExceptionPreface preface, IList<IAmqpExceptionElement> elements)
• public static class AmqpExceptionGrammar
  • public static Parser<ushort> Number
  • public static Parser<T> MakeIntegerElementParser<T>(string key) where T : AmqpExceptionIntegerValueElement
• public class AmqpExceptionPreface

EasyNetQ.AutoSubscribe

• public class AutoSubscriber
  • protected const string ConsumeAsyncMethodName = "ConsumeAsync"
  • protected const string SubscribeAsyncMethodName = "SubscribeAsync"
  • protected const string SubscribeMethodName = "Subscribe"
  • protected virtual bool IsValidMarkerType(Type markerType)
• public class AutoSubscriberConsumerInfo
  • public Type ConcreteType { get; }
  • public MethodInfo ConsumeMethod { get; }
  • public Type InterfaceType { get; }
  • public Type MessageType { get; }
  • public readonly Type ConcreteType
  • public readonly Type InterfaceType
  • public readonly Type MessageType
• public class DefaultAutoSubscriberMessageDispatcher : IAutoSubscriberMessageDispatcher
  • public DefaultAutoSubscriberMessageDispatcher(IServiceResolver resolver)
• public interface IConsumeAsync<T>
  • Task ConsumeAsync(T message)
  • Task Consume(T message)
• public class SubscriptionConfigurationAttribute : Attribute
  • public bool CancelOnHaFailover { get; set; }

EasyNetQ.ConnectionString

• public static class ConnectionStringGrammar
  • public static IEnumerable<Func<ConnectionConfiguration, ConnectionConfiguration>> ParseConnectionString(string connectionString)
  • public static Parser<Uri> AMQP
  • public static Parser<Func<ConnectionConfiguration, ConnectionConfiguration>> AMQPAlone
  • public static Parser<bool> Bool
  • public static Parser<IEnumerable<Func<ConnectionConfiguration, ConnectionConfiguration>>> ConnectionStringBuilder
  • public static Parser<HostConfiguration> Host
  • public static Parser<IEnumerable<HostConfiguration>> Hosts
  • public static Parser<ushort> Number
  • public static Parser<Func<ConnectionConfiguration, ConnectionConfiguration>> Part
  • public static Parser<string> Text
  • public static Parser<Func<ConnectionConfiguration, ConnectionConfiguration>> BuildKeyValueParser<T>(string keyName, Parser<T> valueParser, Expression<Func<ConnectionConfiguration, T>> getter)
  • public static IEnumerable<T> Cons<T>(this T head, IEnumerable<T> rest)
  • public static Action<ConnectionConfiguration, T> CreateSetter<T>(Expression<Func<ConnectionConfiguration, T>> getter)
  • public static Action<TContaining, TProperty> CreateSetter<TContaining, TProperty>(Expression<Func<TContaining, TProperty>> getter)
  • public static Parser<IEnumerable<T>> ListDelimitedBy<T>(this Parser<T> parser, char delimiter)

EasyNetQ.Consumer

• public static class AckStrategies
  • public static AckStrategy Nothing
• public class Base64ErrorMessageSerializer : IErrorMessageSerializer
• public class BasicConsumer : IBasicConsumer, IDisposable
• public class ConsumerConfiguration : IConsumerConfiguration
  • public bool CancelOnHaFailover { get; }
  • public IConsumerConfiguration WithCancelOnHaFailover(bool cancelOnHaFailover = true)
• public class ConsumerDispatcher : IConsumerDispatcher, IDisposable
  • public ConsumerDispatcher(ConnectionConfiguration configuration)
  • public ConsumerDispatcher(ConnectionConfiguration configuration, IEasyNetQLogger logger)
• public class ConsumerDispatcherFactory : IConsumerDispatcherFactory, IDisposable
  • public ConsumerDispatcherFactory(ConnectionConfiguration configuration)
  • public ConsumerDispatcherFactory(ConnectionConfiguration configuration, IEasyNetQLogger logger)
• public class ConsumerExecutionContext
  • public IBasicConsumer Consumer { get; }
  • public ConsumerExecutionContext(Func<byte[], MessageProperties, MessageReceivedInfo, Task> userHandler, MessageReceivedInfo info, MessageProperties properties, byte[] body)
  • public ConsumerExecutionContext(Func<byte[], MessageProperties, MessageReceivedInfo, Task> userHandler, MessageReceivedInfo info, MessageProperties properties, byte[] body, IBasicConsumer consumer)
• public class ConsumerFactory : IConsumerFactory, IDisposable
  • public IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, Task>>> queueConsumerPairs, IPersistentConnection connection, IConsumerConfiguration configuration)
• public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
  • public DefaultConsumerErrorStrategy(IConnectionFactory connectionFactory, ISerializer serializer, IConventions conventions, ITypeNameSerializer typeNameSerializer, IErrorMessageSerializer errorMessageSerializer)
  • protected void Connect()
  • public DefaultConsumerErrorStrategy(IConnectionFactory connectionFactory, ISerializer serializer, IEasyNetQLogger logger, IConventions conventions, ITypeNameSerializer typeNameSerializer)
• public class DefaultErrorMessageSerializer : IErrorMessageSerializer
• public class HandlerCollection : IHandlerCollection, IHandlerRegistration
  • public HandlerCollection()
  • public HandlerCollection(IEasyNetQLogger logger)
• public class HandlerCollectionFactory : IHandlerCollectionFactory
  • public HandlerCollectionFactory()
  • public IHandlerCollection CreateHandlerCollection(IQueue queue)
  • public HandlerCollectionFactory(IEasyNetQLogger logger)
  • public IHandlerCollection CreateHandlerCollection()
• public class HandlerCollectionPerQueueFactory : IHandlerCollectionFactory
• public class HandlerRunner : IHandlerRunner, IDisposable
  • public HandlerRunner(IConsumerErrorStrategy consumerErrorStrategy)
  • public HandlerRunner(IEasyNetQLogger logger, IConsumerErrorStrategy consumerErrorStrategy, IEventBus eventBus)
  • public virtual Task<AckStrategy> InvokeUserMessageHandlerAsync(ConsumerExecutionContext context)
  • public void InvokeUserMessageHandler(ConsumerExecutionContext context)
• public interface IConsumerConfiguration
  • bool CancelOnHaFailover { get; }
  • IConsumerConfiguration WithCancelOnHaFailover(bool cancelOnHaFailover = true)
• public interface IConsumerFactory : IDisposable
  • IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, Task>>> queueConsumerPairs, IPersistentConnection connection, IConsumerConfiguration configuration)
• public interface IErrorMessageSerializer
• public interface IHandlerCollectionFactory
  • IHandlerCollection CreateHandlerCollection(IQueue queue)
  • IHandlerCollection CreateHandlerCollection()
• public interface IHandlerRunner : IDisposable
  • Task<AckStrategy> InvokeUserMessageHandlerAsync(ConsumerExecutionContext context)
  • void InvokeUserMessageHandler(ConsumerExecutionContext context)
• public interface IInternalConsumer : IDisposable
  • StartConsumingStatus StartConsuming(IPersistentConnection connection, ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
• public class InternalConsumer : IBasicConsumer, IInternalConsumer, IDisposable
  • public string ConsumerTag { get; }
  • public InternalConsumer(IHandlerRunner handlerRunner, IConsumerDispatcher consumerDispatcher, IConventions conventions, IEventBus eventBus)
  • public event EventHandler<ConsumerEventArgs> ConsumerCancelled
  • public InternalConsumer(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConsumerDispatcher consumerDispatcher, IConventions conventions, ConnectionConfiguration connectionConfiguration, IEventBus eventBus)
  • public StartConsumingStatus StartConsuming(IPersistentConnection connection, ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
  • 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 InternalConsumerFactory : IInternalConsumerFactory, IDisposable
  • public InternalConsumerFactory(IHandlerRunner handlerRunner, IConventions conventions, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
  • public InternalConsumerFactory(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConventions conventions, ConnectionConfiguration connectionConfiguration, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
• public class PersistentMultipleConsumer : IConsumer, IDisposable

EasyNetQ.DI

• public class DefaultServiceContainer : IServiceRegister
• public static class DefaultServicesRegistration
• public interface IServiceRegister
• public interface IServiceResolver
• public interface IServiceResolverScope : IServiceResolver, IDisposable
• public enum Lifetime
• public class ServiceResolverScope : IServiceResolverScope, IServiceResolver, IDisposable

EasyNetQ.Events

• public enum AckResult
  • Nothing = 3
• public class StartConsumingFailedEvent
• public class StartConsumingSucceededEvent

EasyNetQ.FluentConfiguration

• public interface IPublishConfiguration
• public interface IRequestConfiguration
• public interface ISubscriptionConfiguration
  • ISubscriptionConfiguration AsExclusive(bool isExclusive = true)
  • ISubscriptionConfiguration AsExclusive()
  • ISubscriptionConfiguration WithDurable(bool durable = true)
  • ISubscriptionConfiguration WithCancelOnHaFailover(bool cancelOnHaFailover = true)
  • ISubscriptionConfiguration WithMaxLength(int maxLength)
  • ISubscriptionConfiguration WithMaxLengthBytes(int maxLengthBytes)
  • ISubscriptionConfiguration WithMaxPriority(byte priority)
  • ISubscriptionConfiguration WithQueueName(string queueName)
• public class PublishConfiguration : IPublishConfiguration
• public class RequestConfiguration : IRequestConfiguration
• public class SubscriptionConfiguration : ISubscriptionConfiguration
  • public bool Durable { get; }
  • public bool CancelOnHaFailover { get; }
  • public int? MaxLength { get; }
  • public int? MaxLengthBytes { get; }
  • public byte? MaxPriority { get; }
  • public string QueueName { get; }
  • public ISubscriptionConfiguration AsExclusive(bool isExclusive = true)
  • public ISubscriptionConfiguration AsExclusive()
  • public ISubscriptionConfiguration WithDurable(bool durable = true)
  • public ISubscriptionConfiguration WithCancelOnHaFailover(bool cancelOnHaFailover = true)
  • public ISubscriptionConfiguration WithMaxLength(int maxLength)
  • public ISubscriptionConfiguration WithMaxLengthBytes(int maxLengthBytes)
  • public ISubscriptionConfiguration WithMaxPriority(byte priority)
  • public ISubscriptionConfiguration WithQueueName(string queueName)

EasyNetQ.Interception

• public static class InterceptionExtensions
  • public static IServiceRegister EnableInterception(this IServiceRegister serviceRegister, Action<IInterceptorRegistrator> configure)
  • public static IServiceRegister EnableInterception(this IServiceRegister serviceRegister, Action<IInterceptorRegistrator> configure)
• public class InterceptorRegistrator : IInterceptorRegistrator
  • public InterceptorRegistrator(IServiceRegister serviceRegister)
  • public InterceptorRegistrator(IServiceRegister serviceRegister)
  • public IServiceRegister Register()
  • public IServiceRegister Register()

EasyNetQ.Internals

• public class AsyncLock
• public class AsyncSemaphore
  • public int Available { get; }
  • public AsyncSemaphore(int initial)
  • public void Release()
  • public void Wait()
  • public Task WaitAsync()
• public static class TaskHelpers
  • public static readonly Task Completed
  • public static Task Delay(TimeSpan delay, CancellationToken cancellation)
  • public static Task FromException(Exception ex)
  • public static Task<T> FromResult<T>(T result)
  • public static void TrySetCanceledSafe<T>(this TaskCompletionSource<T> source)
  • public static void TrySetExceptionSafe<T>(this TaskCompletionSource<T> source, Exception exception)
  • public static void TrySetResultSafe<T>(this TaskCompletionSource<T> source, T result)
  • public static Task<Task> WhenAny(Task[] tasks)
• public static class Timers

EasyNetQ.LightInject

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

EasyNetQ.Loggers

• public class ConsoleLogger : IEasyNetQLogger
  • public bool Debug { get; set; }
  • public bool Error { get; set; }
  • public bool Info { get; set; }
  • public ConsoleLogger()
  • public void DebugWrite(string format, object[] args)
  • public void ErrorWrite(string format, object[] args)
  • public void ErrorWrite(Exception exception)
  • public void InfoWrite(string format, object[] args)
  • public void SafeConsoleWrite(string format, object[] args)
• public class DelegateLogger : IEasyNetQLogger
  • public Action<string, object[]> DebugWriteDelegate { get; set; }
  • public Action<string, object[]> DefaultWrite { get; set; }
  • public Action<string, object[]> ErrorWriteDelegate { get; set; }
  • public Action<string, object[]> InfoWriteDelegate { get; set; }
  • public DelegateLogger()
  • public void DebugWrite(string format, object[] args)
  • public void ErrorWrite(string format, object[] args)
  • public void ErrorWrite(Exception exception)
  • public void InfoWrite(string format, object[] args)
• public class NullLogger : IEasyNetQLogger
  • public NullLogger()
  • public void DebugWrite(string format, object[] args)
  • public void ErrorWrite(string format, object[] args)
  • public void ErrorWrite(Exception exception)
  • public void InfoWrite(string format, object[] args)

EasyNetQ.Logging

• public class ConsoleLogProvider : ILogProvider
• public interface ILog
• public interface ILogProvider
• public static class LogExtensions
• public sealed delegate Logger : MulticastDelegate
• public enum LogLevel
• public static class LogProvider

EasyNetQ.Logging.LogProviders

• public class LibLogException : Exception
• public abstract class LogProviderBase : ILogProvider

EasyNetQ.MessageVersioning

• public class MessageType
  • public Type Type { get; set; }
  • public string TypeString { get; set; }
  • public MessageType()
• public class MessageTypeProperty
  • public Type GetMessageType()
  • public MessageType GetMessageType()
• public static class MessageVersioningExtensions
  • public static IServiceRegister EnableMessageVersioning(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableMessageVersioning(this IServiceRegister serviceRegister)
• public class VersionedExchangeDeclareStrategy : IExchangeDeclareStrategy
• public class VersionedMessageSerializationStrategy : IMessageSerializationStrategy
  • public IMessage<T> DeserializeMessage<T>(MessageProperties properties, byte[] body)
• public class VersionedPublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
  • public VersionedPublishExchangeDeclareStrategy()
  • public IExchange DeclareExchange(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
  • public IExchange DeclareExchange(IAdvancedBus advancedBus, Type messageType, string exchangeType)
  • public Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
  • public Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, Type messageType, string exchangeType)

EasyNetQ.MultipleExchange

• public class MultipleExchangeDeclareStrategy : IExchangeDeclareStrategy
• public static class MultipleExchangeExtension

EasyNetQ.Producer

• public class DefaultExchangeDeclareStrategy : IExchangeDeclareStrategy
• public interface IExchangeDeclareStrategy
• public interface IPublishExchangeDeclareStrategy
  • IExchange DeclareExchange(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
  • IExchange DeclareExchange(IAdvancedBus advancedBus, Type messageType, string exchangeType)
  • Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
  • Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, Type messageType, string exchangeType)
• public interface IResponderConfiguration
  • IResponderConfiguration WithQueueName(string queueName)
• public interface IRpc
  • Task<TResponse> Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
  • Task<TResponse> Request<TRequest, TResponse>(TRequest request)
• public class PersistentChannel : IPersistentChannel, IDisposable
  • public PersistentChannel(IPersistentConnection connection, ConnectionConfiguration configuration, IEventBus eventBus)
  • public PersistentChannel(IPersistentConnection connection, IEasyNetQLogger logger, ConnectionConfiguration configuration, IEventBus eventBus)
• public class PersistentChannelFactory : IPersistentChannelFactory
  • public PersistentChannelFactory(ConnectionConfiguration configuration, IEventBus eventBus)
  • public PersistentChannelFactory(IEasyNetQLogger logger, ConnectionConfiguration configuration, IEventBus eventBus)
• public class PublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
  • public PublishExchangeDeclareStrategy()
  • public IExchange DeclareExchange(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
  • public IExchange DeclareExchange(IAdvancedBus advancedBus, Type messageType, string exchangeType)
  • public Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, string exchangeName, string exchangeType)
  • public Task<IExchange> DeclareExchangeAsync(IAdvancedBus advancedBus, Type messageType, string exchangeType)
• public class PublishInterruptedException : Exception
  • protected PublishInterruptedException(SerializationInfo info, StreamingContext context)
• public class PublishNackedException : Exception
  • protected PublishNackedException(SerializationInfo info, StreamingContext context)
• public class ResponderConfiguration : IResponderConfiguration
  • public string QueueName { get; }
  • public IResponderConfiguration WithQueueName(string queueName)
• public class Rpc : IRpc
  • protected struct ResponseQueueWithCancellation
  • protected readonly IExchangeDeclareStrategy exchangeDeclareStrategy
  • public Rpc(ConnectionConfiguration connectionConfiguration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITimeoutStrategy timeoutStrategy, ITypeNameSerializer typeNameSerializer)
  • protected readonly IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy
  • public Rpc(ConnectionConfiguration connectionConfiguration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITimeoutStrategy timeoutStrategy, ITypeNameSerializer typeNameSerializer)
  • public virtual Task<TResponse> Request<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure)
  • public virtual Task<TResponse> Request<TRequest, TResponse>(TRequest request)

EasyNetQ.Scheduling

• public static class BusExtensions
  • 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 topic, string cancellationKey, 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, string topic)
  • 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, string topic)
• public class DeadLetterExchangeAndMessageTtlScheduler : IScheduler
  • public void FuturePublish<T>(DateTime futurePublishDate, T message, string topic, 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 topic, string cancellationKey = null)
  • public Task FuturePublishAsync<T>(TimeSpan messageDelay, T message, string topic, string cancellationKey = null)
• public class DelayedExchangeScheduler : IScheduler
  • public void FuturePublish<T>(DateTime futurePublishDate, T message, string topic, 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 topic, 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, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IMessageSerializationStrategy messageSerializationStrategy)
  • public ExternalScheduler(IAdvancedBus advancedBus, IConventions conventions, ITypeNameSerializer typeNameSerializer, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IMessageSerializationStrategy messageSerializationStrategy)
  • public void FuturePublish<T>(DateTime futurePublishDate, T message, string topic, 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 topic, string cancellationKey = null)
  • public Task FuturePublishAsync<T>(TimeSpan messageDelay, T message, string topic, string cancellationKey = null)
• public interface IScheduler
  • void FuturePublish<T>(DateTime futurePublishDate, T message, string topic, string cancellationKey = null)
  • void FuturePublish<T>(TimeSpan messageDelay, T message, string topic, string cancellationKey = null)
  • Task FuturePublishAsync<T>(DateTime futurePublishDate, T message, string topic, 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)
  • public static IServiceRegister EnableDeadLetterExchangeAndMessageTtlScheduler(this IServiceRegister serviceRegister)
  • public static IServiceRegister EnableDelayedExchangeScheduler(this IServiceRegister serviceRegister)

EasyNetQ.SystemMessages

• public class Error
  • public string Queue { get; set; }

EasyNetQ.Topology

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

Sprache

• public interface IFailure<T> : IResult<T>
  • IEnumerable<string> Expectations { get; }
  • Input FailedInput { get; }
  • string Message { get; }
• public class Input
  • public bool AtEnd { get; }
  • public int Column { get; }
  • public char Current { get; }
  • public int Line { get; }
  • public int Position { get; }
  • public string Source { get; set; }
  • public Input(string source)
  • public Input Advance()
• public interface IResult<T>
• public interface ISuccess<T> : IResult<T>
  • Input Remainder { get; }
  • T Result { get; }
• public static class Parse
  • public static readonly Parser<char> AnyChar
  • public static readonly Parser<string> Decimal
  • public static readonly Parser<char> Digit
  • public static readonly Parser<char> Letter
  • public static readonly Parser<char> LetterOrDigit
  • public static readonly Parser<char> Lower
  • public static readonly Parser<string> Number
  • public static readonly Parser<char> Numeric
  • public static readonly Parser<char> Upper
  • public static readonly Parser<char> WhiteSpace
  • public static Parser<IEnumerable<T>> AtLeastOnce<T>(this Parser<T> parser)
  • public static Parser<IEnumerable<char>> CaseInsensitiveString(string s)
  • public static Parser<T> ChainOperator<T, TOp>(Parser<TOp> op, Parser<T> operand, Func<TOp, T, T, T> apply)
  • public static Parser<T> ChainRightOperator<T, TOp>(Parser<TOp> op, Parser<T> operand, Func<TOp, T, T, T> apply)
  • public static Parser<char> Char(Predicate<char> predicate, string description)
  • public static Parser<char> Char(char c)
  • public static Parser<char> CharCaseInsensitive(char c)
  • public static Parser<char> CharExcept(Predicate<char> predicate, string description)
  • public static Parser<char> CharExcept(char c)
  • public static Parser<IEnumerable<T>> Concat<T>(this Parser<IEnumerable<T>> first, Parser<IEnumerable<T>> second)
  • public static Parser<T> End<T>(this Parser<T> parser)
  • public static Parser<T> Except<T, U>(this Parser<T> parser, Parser<U> except)
  • public static Parser<IEnumerable<T>> Many<T>(this Parser<T> parser)
  • public static Parser<T> Named<T>(this Parser<T> parser, string name)
  • public static Parser<IEnumerable<T>> Once<T>(this Parser<T> parser)
  • public static Parser<T> Or<T>(this Parser<T> first, Parser<T> second)
  • public static Parser<T> Ref<T>(Func<Parser<T>> reference)
  • public static Parser<T> Return<T>(T value)
  • public static Parser<U> Return<T, U>(this Parser<T> parser, U value)
  • public static Parser<U> Select<T, U>(this Parser<T> parser, Func<T, U> convert)
  • public static Parser<V> SelectMany<T, U, V>(this Parser<T> parser, Func<T, Parser<U>> selector, Func<T, U, V> projector)
  • public static Parser<IEnumerable<char>> String(string s)
  • public static Parser<string> Text(this Parser<IEnumerable<char>> characters)
  • public static Parser<U> Then<T, U>(this Parser<T> first, Func<T, Parser<U>> second)
  • public static Parser<T> Token<T>(this Parser<T> parser)
  • public static Parser<IEnumerable<T>> Until<T, U>(this Parser<T> parser, Parser<U> until)
  • public static Parser<T> Where<T>(this Parser<T> parser, Func<T, bool> predicate)
  • public static Parser<IEnumerable<T>> XMany<T>(this Parser<T> parser)
  • public static Parser<T> XOr<T>(this Parser<T> first, Parser<T> second)
• public class ParseException : Exception
  • public ParseException(string message)
• public sealed delegate Parser<T> : MulticastDelegate
  • public Parser(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(Input input, AsyncCallback callback, object object)
  • public virtual IResult<T> EndInvoke(IAsyncResult result)
  • public virtual IResult<T> Invoke(Input input)
• public static class ParserExtensions
  • public static T Parse<T>(this Parser<T> parser, string input)
  • public static IResult<T> TryParse<T>(this Parser<T> parser, string input)