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

<PackageReference Include="EasyNetQ" Version="3.4.0-alpha0019" />

---

API Diff between 3.4.0-alpha0019 and 5.1.0-alpha0054

285 Additions 107 Removals

EasyNetQ

• public static class AdvancedBusExtensions
  • public static IExchange ExchangeDeclare(this IAdvancedBus bus, string name, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
  • public static IExchange ExchangeDeclare(this IAdvancedBus bus, string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • public static Task<IExchange> ExchangeDeclareAsync(this IAdvancedBus bus, string name, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
  • public static void ExchangeDeclarePassive(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
  • public static IExchange ExchangeDeclare(this IAdvancedBus bus, string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, string alternateExchange = null, bool delayed = false, CancellationToken cancellationToken = default)
  • public static IQueue QueueDeclare(this IAdvancedBus bus, string name, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • public static IQueue QueueDeclare(this IAdvancedBus bus, string name, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
  • public static IQueue QueueDeclare(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
  • public static Task<IQueue> QueueDeclareAsync(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
  • public static Task<IQueue> QueueDeclareAsync(this IAdvancedBus bus, string name, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
  • public static void QueueDeclarePassive(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
  • public static IQueue QueueDeclare(this IAdvancedBus bus, 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, CancellationToken cancellationToken = default)
• public class ConnectionConfiguration
  • public Uri AmqpConnectionString { get; set; }
  • public IList<IAuthMechanismFactory> AuthMechanisms { get; set; }
  • public Uri AMQPConnectionString { get; set; }
  • public IList<AuthMechanismFactory> AuthMechanisms { get; set; }
  • public int DispatcherQueueSize { get; set; }
• public class ConnectionFactoryInfo
  • public ConnectionFactory ConnectionFactory { get; }
  • public HostConfiguration HostConfiguration { get; }
  • public ConnectionFactoryInfo(ConnectionFactory connectionFactory, HostConfiguration hostConfiguration)
• public class ConnectionFactoryWrapper : IConnectionFactory
  • public virtual ConnectionConfiguration Configuration { get; }
  • public virtual HostConfiguration CurrentHost { get; }
  • public virtual bool Succeeded { get; }
  • public ConnectionFactoryWrapper(ConnectionConfiguration connectionConfiguration, IClusterHostSelectionStrategy<ConnectionFactoryInfo> clusterHostSelectionStrategy)
  • public virtual IConnection CreateConnection()
  • public virtual bool Next()
  • public virtual void Reset()
  • public virtual void Success()
• public static class ConventionsExtensions
• public static class DelayedExchangeExtensions
• public class EasyNetQException : Exception
  • public EasyNetQException(string format, object[] args)
  • public EasyNetQException(string format, string[] args)
  • protected EasyNetQException(SerializationInfo info, StreamingContext context)
• public class EasyNetQResponderException : EasyNetQException
  • public EasyNetQResponderException(string format, object[] args)
  • public EasyNetQResponderException(string format, string[] args)
  • protected EasyNetQResponderException(SerializationInfo info, StreamingContext context)
• public sealed class ExchangeDeclareConfiguration : IExchangeDeclareConfiguration
• public static class ExchangeDeclareConfigurationExtensions
• public interface IAdvancedBus : IDisposable
  • Task<IExchange> ExchangeDeclareAsync(string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • Task ExchangeDeclarePassiveAsync(string name, CancellationToken cancellationToken = default)
  • Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, string alternateExchange = null, bool delayed = false, CancellationToken cancellationToken = default)
  • Task<IQueue> QueueDeclareAsync(string name, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default, CancellationToken cancellationToken = default)
  • Task QueueDeclarePassiveAsync(string name, CancellationToken cancellationToken = default)
• public interface IClusterHostSelectionStrategy<T>
  • bool Succeeded { get; }
  • void Add(T item)
  • T Current()
  • bool Next()
  • void Reset()
  • void Success()
• public interface IConnectionFactory
  • ConnectionConfiguration Configuration { get; }
  • HostConfiguration CurrentHost { get; }
  • bool Succeeded { get; }
  • IConnection CreateConnection()
  • bool Next()
  • void Reset()
  • void Success()
• public interface IExchangeDeclareConfiguration
• public interface IPersistentConnection : IDisposable
  • void Initialize()
• public interface IQueueDeclareConfiguration
• public interface IPersistentConnectionFactory
  • IPersistentConnection CreateConnection()
• public interface ISerializer
  • T BytesToMessage<T>(byte[] bytes)
  • byte[] MessageToBytes(Type messageType, object message)
  • byte[] MessageToBytes<T>(T message)
• public class JsonSerializer : ISerializer
  • public T BytesToMessage<T>(byte[] bytes)
  • public byte[] MessageToBytes(Type messageType, object message)
  • public byte[] MessageToBytes<T>(T message)
• public class LegacyRpcConventions : Conventions
• public static class LegacyRpcConventionsExtensions
• public static class LinqExtensions
  • public static void Shuffle<T>(this IList<T> list)
• public class Message<T> : IMessage<T>, IMessage
  • public Message()
• public class OrderedClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
  • public virtual bool Succeeded { get; }
  • public OrderedClusterHostSelectionStrategy()
  • public virtual void Add(T item)
  • public virtual T Current()
  • public virtual IEnumerator<T> GetEnumerator()
  • public virtual bool Next()
  • public virtual void Reset()
  • public virtual void Success()
• public class PersistentConnection : IPersistentConnection, IDisposable
  • public PersistentConnection(ConnectionConfiguration connectionConfiguration, IConnectionFactory connectionFactory, IEventBus eventBus)
  • public PersistentConnection(IConnectionFactory connectionFactory, IEventBus eventBus)
• public class PersistentConnectionFactory : IPersistentConnectionFactory
  • public PersistentConnectionFactory(IConnectionFactory connectionFactory, IEventBus eventBus)
  • public IPersistentConnection CreateConnection()
• public static class PubSubExtensions
• public sealed class QueueDeclareConfiguration : IQueueDeclareConfiguration
• public static class QueueDeclareConfigurationExtensions
• public static class QueueMode
• public class RabbitAdvancedBus : IAdvancedBus, IDisposable
  • public RabbitAdvancedBus(IPersistentConnection connection, IConsumerFactory consumerFactory, IClientCommandDispatcher clientCommandDispatcher, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IServiceResolver container, ConnectionConfiguration connectionConfiguration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, AdvancedBusEventHandlers advancedBusEventHandlers)
  • 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 Task<IExchange> ExchangeDeclareAsync(string name, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • public Task ExchangeDeclarePassiveAsync(string name, CancellationToken cancellationToken = default)
  • public Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, string alternateExchange = null, bool delayed = false, CancellationToken cancellationToken = default)
  • public Task<IQueue> QueueDeclareAsync(string name, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
  • public Task QueueDeclarePassiveAsync(string name, CancellationToken cancellationToken = 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, CancellationToken cancellationToken = default)
• 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 RpcExtensions
• public static class SchedulerExtensions
• public static class SendReceiveExtensions

EasyNetQ.AmqpExceptions

• public static class AmqpExceptionGrammar
  • public static Parser<ushort> Number
  • public static Parser<T> MakeIntegerElementParser<T>(string key) where T : AmqpExceptionIntegerValueElement

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 class BasicConsumer : IBasicConsumer, IDisposable
  • public void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, ReadOnlyMemory<byte> body)
  • public void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)
• public class ConsumerCancellation : IDisposable
  • public sealed delegate ConsumerCancel : MulticastDelegate
  • public event ConsumerCancel ConsumerCancelled
  • public void OnCancel(object queue)
• public class ConsumerFactory : IConsumerFactory, IDisposable
  • public ConsumerFactory(IPersistentConnection connection, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
  • public IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
  • public IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
  • public ConsumerFactory(IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
  • public IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration)
  • public IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IPersistentConnection connection, IConsumerConfiguration configuration)
• public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
  • public DefaultConsumerErrorStrategy(IPersistentConnection connection, ISerializer serializer, IConventions conventions, ITypeNameSerializer typeNameSerializer, IErrorMessageSerializer errorMessageSerializer, ConnectionConfiguration connectionConfiguration)
  • protected IConnection Connection { get; }
  • public DefaultConsumerErrorStrategy(IConnectionFactory connectionFactory, ISerializer serializer, IConventions conventions, ITypeNameSerializer typeNameSerializer, IErrorMessageSerializer errorMessageSerializer)
  • protected void Connect()
• public class ExclusiveConsumer : IConsumer, IDisposable
  • public ExclusiveConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
  • public ExclusiveConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
• public interface IConsumerFactory : IDisposable
  • IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
  • IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
  • IConsumer CreateConsumer(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IPersistentConnection connection, IConsumerConfiguration configuration)
  • IConsumer CreateConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration)
• public interface IInternalConsumer : IDisposable
  • StartConsumingStatus StartConsuming(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
  • StartConsumingStatus StartConsuming(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
  • StartConsumingStatus StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
  • StartConsumingStatus StartConsuming(IPersistentConnection connection, ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
• public class InternalConsumer : IInternalConsumer, IDisposable
  • public InternalConsumer(IPersistentConnection connection, IHandlerRunner handlerRunner, IConsumerDispatcher consumerDispatcher, IConventions conventions, IEventBus eventBus)
  • public InternalConsumer(IHandlerRunner handlerRunner, IConsumerDispatcher consumerDispatcher, IConventions conventions, IEventBus eventBus)
  • public StartConsumingStatus StartConsuming(ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
  • public StartConsumingStatus StartConsuming(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
  • public StartConsumingStatus StartConsuming(IPersistentConnection connection, ICollection<Tuple<IQueue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task>>> queueConsumerPairs, IConsumerConfiguration configuration)
  • public StartConsumingStatus StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration)
• public class InternalConsumerFactory : IInternalConsumerFactory, IDisposable
  • public InternalConsumerFactory(IPersistentConnection connection, IHandlerRunner handlerRunner, IConventions conventions, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
  • public InternalConsumerFactory(IHandlerRunner handlerRunner, IConventions conventions, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
• public class PersistentConsumer : IConsumer, IDisposable
  • public PersistentConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
  • public PersistentConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
• public class TransientConsumer : IConsumer, IDisposable
  • public TransientConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)
  • public TransientConsumer(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, IPersistentConnection connection, IConsumerConfiguration configuration, IInternalConsumerFactory internalConsumerFactory, IEventBus eventBus)

EasyNetQ.DI

• public static class ConnectionFactoryFactory

EasyNetQ.FluentConfiguration

• public interface ISubscriptionConfiguration
  • ISubscriptionConfiguration WithQueueMode(string queueMode = "default")
• public class SubscriptionConfiguration : ISubscriptionConfiguration
  • public string QueueMode { get; }
  • public ISubscriptionConfiguration WithQueueMode(string queueMode)

EasyNetQ.Internals

• public sealed class AsyncCache<TKey, TValue>
• public sealed class ConcurrentSet<T> : IEnumerable<T>, IEnumerable
• public static class TaskHelpers
  • public static TaskCompletionSource<T> CreateTcs<T>()
  • public static void TrySetCanceledAsynchronously<T>(this TaskCompletionSource<T> source)
  • public static void TrySetExceptionAsynchronously<T>(this TaskCompletionSource<T> source, Exception exception)
  • public static void TrySetResultAsynchronously<T>(this TaskCompletionSource<T> source, T result)
• public static class Timers
  • public static IDisposable Start(Action callback, TimeSpan dueTime, TimeSpan period)
  • public static void RunOnce(TimerCallback callback, TimeSpan dueTime)
  • public static IDisposable Start(TimerCallback callback, TimeSpan dueTime, TimeSpan period)

EasyNetQ.Logging

• public static class LogExtensions
  • public static void Debug(this ILog logger, string message, object arg0)
  • public static void Debug(this ILog logger, string message, object arg0, object arg1)
  • public static void Debug(this ILog logger, string message, object arg0, object arg1, object arg2)
  • public static void Debug(this ILog logger, Exception exception, string message, object arg0)
  • public static void DebugException(this ILog logger, string message, Exception exception, object formatParam0)
  • public static void DebugException(this ILog logger, string message, Exception exception, object formatParam0, object formatParam1)
  • public static void DebugException(this ILog logger, string message, Exception exception, object formatParam0, object formatParam1, object formatParam2)
  • public static void DebugFormat(this ILog logger, string message, object arg0)
  • public static void DebugFormat(this ILog logger, string message, object arg0, object arg1)
  • public static void DebugFormat(this ILog logger, string message, object arg0, object arg1, object arg2)
  • public static void Info(this ILog logger, string message, object arg0)
  • public static void Info(this ILog logger, string message, object arg0, object arg1)
  • public static void Info(this ILog logger, string message, object arg0, object arg1, object arg2)
  • public static void Info(this ILog logger, Exception exception, string message, object arg0)
  • public static void Info(this ILog logger, Exception exception, string message, object arg0, object arg1)
  • public static void Info(this ILog logger, Exception exception, string message, object arg0, object arg1, object arg2)
  • public static void InfoFormat(this ILog logger, string message, object arg0)
  • public static void InfoFormat(this ILog logger, string message, object arg0, object arg1)
  • public static void InfoFormat(this ILog logger, string message, object arg0, object arg1, object arg2)
  • public static void Trace(this ILog logger, string message, object arg0)
  • public static void Trace(this ILog logger, string message, object arg0, object arg1)
  • public static void Trace(this ILog logger, string message, object arg0, object arg1, object arg2)
  • public static void Trace(this ILog logger, Exception exception, string message, object arg0)
  • public static void Trace(this ILog logger, Exception exception, string message, object arg0, object arg1)
  • public static void Trace(this ILog logger, Exception exception, string message, object arg0, object arg1, object arg2)
  • public static void TraceException(this ILog logger, string message, Exception exception, object formatParam0)
  • public static void TraceException(this ILog logger, string message, Exception exception, object formatParam0, object formatParam1)
  • public static void TraceException(this ILog logger, string message, Exception exception, object formatParam0, object formatParam1, object formatParam2)
  • public static void TraceFormat(this ILog logger, string message, object arg0)
  • public static void TraceFormat(this ILog logger, string message, object arg0, object arg1)
  • public static void TraceFormat(this ILog logger, string message, object arg0, object arg1, object arg2)

EasyNetQ.Logging.LogProviders

• public abstract class LogProviderBase : ILogProvider
  • protected static Type FindType(string typeName, string assemblyName)
  • protected static Type FindType(string typeName, IReadOnlyList<string> assemblyNames)

EasyNetQ.MessageVersioning

• public class VersionedExchangeDeclareStrategy : IExchangeDeclareStrategy
• public class VersionedPublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
  • public VersionedPublishExchangeDeclareStrategy(IConventions conventions, IAdvancedBus advancedBus)
  • public Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)
  • public Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)

EasyNetQ.MultipleExchange

• public class MultipleExchangeDeclareStrategy : IExchangeDeclareStrategy
• public class MultipleExchangePublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
  • public MultipleExchangePublishExchangeDeclareStrategy(IConventions conventions, IAdvancedBus advancedBus)
  • public Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
  • public Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)

EasyNetQ.Producer

• public class ClientCommandDispatcherFactory : IClientCommandDispatcherFactory
  • public ClientCommandDispatcherFactory(ConnectionConfiguration configuration, IPersistentChannelFactory persistentChannelFactory)
  • public IClientCommandDispatcher GetClientCommandDispatcher(IPersistentConnection connection)
• public class DefaultExchangeDeclareStrategy : IExchangeDeclareStrategy
• public class DefaultPubSub : IPubSub
  • public DefaultPubSub(ConnectionConfiguration connectionConfiguration, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IAdvancedBus advancedBus)
  • public DefaultPubSub(ConnectionConfiguration connectionConfiguration, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IAdvancedBus advancedBus)
• public class DefaultRpc : IRpc
  • protected struct ResponseSubscription
  • protected const string ExceptionMessageKey = "ExceptionMessage"
  • protected const string IsFaultedKey = "IsFaulted"
  • protected const string exceptionMessageKey = "ExceptionMessage"
  • protected const string isFaultedKey = "IsFaulted"
  • protected readonly IExchangeDeclareStrategy exchangeDeclareStrategy
  • protected readonly TimeSpan disablePeriodicSignaling
  • public DefaultRpc(ConnectionConfiguration connectionConfiguration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITimeoutStrategy timeoutStrategy, ITypeNameSerializer typeNameSerializer)
  • protected void DeRegisterResponseActions(Guid correlationId)
  • public void Dispose()
  • protected void RegisterResponseActions<TResponse>(Guid correlationId, TaskCompletionSource<TResponse> tcs)
  • protected readonly IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy
  • public DefaultRpc(ConnectionConfiguration connectionConfiguration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITimeoutStrategy timeoutStrategy, ITypeNameSerializer typeNameSerializer)
  • protected Task ExecuteResponder<TRequest, TResponse>(Func<TRequest, CancellationToken, 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)
  • protected virtual Task RequestPublishAsync<TRequest>(TRequest request, string routingKey, string returnQueueName, Guid correlationId, CancellationToken cancellationToken)
  • protected virtual void RequestPublish<TRequest>(TRequest request, string routingKey, string returnQueueName, Guid correlationId)
  • protected virtual Task<string> SubscribeToResponseAsync<TRequest, TResponse>(CancellationToken cancellationToken)
  • protected virtual string SubscribeToResponse<TRequest, TResponse>()
• public interface IExchangeDeclareStrategy
• public interface IClientCommandDispatcherFactory
  • IClientCommandDispatcher GetClientCommandDispatcher(IPersistentConnection connection)
• public interface IPublishExchangeDeclareStrategy
  • Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken = default)
  • Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken = default)
• public class PublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
  • public PublishExchangeDeclareStrategy(IConventions conventions, IAdvancedBus advancedBus)
  • public Task<IExchange> DeclareExchangeAsync(string exchangeName, string exchangeType, CancellationToken cancellationToken)
  • public Task<IExchange> DeclareExchangeAsync(Type messageType, string exchangeType, CancellationToken cancellationToken)
• public static class PublishExchangeDeclareStrategyExtensions
  • public static IExchange DeclareExchange(this IExchangeDeclareStrategy strategy, string exchangeName, string exchangeType, CancellationToken cancellationToken = default)
  • public static IExchange DeclareExchange(this IExchangeDeclareStrategy strategy, Type messageType, string exchangeType, CancellationToken cancellationToken = default)
  • public static IExchange DeclareExchange(this IPublishExchangeDeclareStrategy strategy, string exchangeName, string exchangeType, CancellationToken cancellationToken = default)
  • public static IExchange DeclareExchange(this IPublishExchangeDeclareStrategy strategy, Type messageType, string exchangeType, CancellationToken cancellationToken = default)
• public static class PubSubExtensions
  • public static void Publish<T>(this IPubSub pubSub, T message, CancellationToken cancellationToken = default)
  • public static void Publish<T>(this IPubSub pubSub, T message, Action<IPublishConfiguration> configure, CancellationToken cancellationToken = default)
  • public static void Publish<T>(this IPubSub pubSub, T message, string topic, CancellationToken cancellationToken = default)
  • public static Task PublishAsync<T>(this IPubSub pubSub, T message, CancellationToken cancellationToken = default)
  • public static Task PublishAsync<T>(this IPubSub pubSub, T message, string topic, CancellationToken cancellationToken = default)
  • public static ISubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, CancellationToken cancellationToken = default)
  • public static ISubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
  • public static ISubscriptionResult Subscribe<T>(IPubSub pubSub, string subscriptionId, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
  • public static ISubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<ISubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<ISubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<ISubscriptionResult> SubscribeAsync<T>(IPubSub pubSub, string subscriptionId, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
• public static class RpcExtensions
  • public static TResponse Request<TRequest, TResponse>(this IRpc rpc, TRequest request, CancellationToken cancellationToken = default)
  • public static TResponse Request<TRequest, TResponse>(this IRpc rpc, TRequest request, Action<IRequestConfiguration> configure, CancellationToken cancellationToken = default)
  • public static Task<TResponse> RequestAsync<TRequest, TResponse>(this IRpc rpc, TRequest request, CancellationToken cancellationToken = default)
  • public static IDisposable Respond<TRequest, TResponse>(this IRpc rpc, Func<TRequest, Task<TResponse>> responder, CancellationToken cancellationToken = default)
  • public static IDisposable Respond<TRequest, TResponse>(this IRpc rpc, Func<TRequest, TResponse> responder, CancellationToken cancellationToken = default)
  • public static IDisposable Respond<TRequest, TResponse>(this IRpc rpc, Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure, CancellationToken cancellationToken = default)
  • public static IDisposable Respond<TRequest, TResponse>(this IRpc rpc, Func<TRequest, CancellationToken, Task<TResponse>> responder, Action<IResponderConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> RespondAsync<TRequest, TResponse>(this IRpc rpc, Func<TRequest, Task<TResponse>> responder, CancellationToken cancellationToken = default)
• public static class SendReceiveExtensions
  • public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, CancellationToken cancellationToken = default)
  • public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
  • public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
  • public static IDisposable Receive<T>(this ISendReceive sendReceive, string queue, Func<T, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
  • public static IDisposable Receive(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, CancellationToken cancellationToken = default)
  • public static IDisposable Receive(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
  • public static AwaitableDisposable<IDisposable> ReceiveAsync(this ISendReceive sendReceive, string queue, Action<IReceiveRegistration> addHandlers, CancellationToken cancellationToken = default)
  • public static void Send<T>(this ISendReceive sendReceive, string queue, T message, CancellationToken cancellationToken = default)

EasyNetQ.Scheduling

• 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 static class SchedulerExtensions
  • public static void FuturePublish<T>(this IScheduler scheduler, T message, TimeSpan delay, string topic = null, CancellationToken cancellationToken = default)

EasyNetQ.Topology

• public class Binding : IBinding
  • public IDictionary<string, object> Arguments { get; }
  • public IDictionary<string, object> Headers { get; }
• public class Exchange : IExchange, IBindable
  • public IDictionary<string, object> Arguments { get; }
  • public bool IsAutoDelete { get; }
  • public bool IsDurable { get; }
  • public string Type { get; }
  • public Exchange(string name, string type = "direct", bool durable = true, bool autoDelete = false, IDictionary<string, object> arguments = null)
  • public Exchange(string name)
• public interface IBinding
  • IDictionary<string, object> Arguments { get; }
  • IDictionary<string, object> Headers { get; }
• public interface IExchange : IBindable
  • IDictionary<string, object> Arguments { get; }
  • bool IsAutoDelete { get; }
  • bool IsDurable { get; }
  • string Type { get; }
• public interface IQueue : IBindable
  • IDictionary<string, object> Arguments { get; }
  • bool IsAutoDelete { get; }
  • bool IsDurable { get; }
• public class Queue : IQueue, IBindable
  • public IDictionary<string, object> Arguments { get; }
  • public bool IsAutoDelete { get; }
  • public bool IsDurable { get; }
  • public Queue(string name, bool isDurable = true, bool isExclusive = false, bool isAutoDelete = false, IDictionary<string, object> arguments = null)
  • public Queue(string name, bool isExclusive)

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)