API Diff between 0.37.1.316 and 0.59.0.437
203 Additions
202 Removals
EasyNetQ
-
public class AdvancedBusEventHandlers
-
public class ConnectionConfiguration : IConnectionConfiguration
-
public class ConnectionFactoryInfo
-
public class ConnectionFactoryWrapper : IConnectionFactory
-
public class DefaultClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
-
public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
-
public class DeserializedMessage
-
public static class Extensions
-
public class HostConfiguration : IHostConfiguration
-
public interface IAdvancedBus : IDisposable
- IConventions Conventions { get; }
- event EventHandler<ConnectionBlockedEventArgs> Blocked
- event EventHandler Connected
- event EventHandler Disconnected
- event EventHandler<MessageReturnedEventArgs> MessageReturned
- event EventHandler Unblocked
- event Action Blocked
- event Action Connected
- event Action Disconnected
- event Action<byte[], MessageProperties, MessageReturnedInfo> MessageReturned
- event Action Unblocked
- IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)
- IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null, 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)
- IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
- Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
- 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)
- void Publish(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
- void Publish<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
- Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
- Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
- IQueue QueueDeclare(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int perQueueTtl = 2147483647, int expires = 2147483647, string deadLetterExchange = null)
- 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)
- Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int perQueueTtl = 2147483647, int expires = 2147483647, string deadLetterExchange = null)
-
public interface IBus : IDisposable
- event Action Connected
- event Action Disconnected
- void Publish<T>(T message, Action<IPublishConfiguration> configure)
- Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure)
- IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, Action<IResponderConfiguration> configure)
- IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
- Task SendAsync<T>(string queue, T message)
- ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage)
- ISubscriptionResult Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
- ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- ISubscriptionResult SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
- IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage)
- IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
- IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
-
public interface IConnectionConfiguration
-
public interface IConnectionFactory
-
public interface IMessage
-
public interface IHostConfiguration
- string Host { get; }
- ushort Port { get; }
-
public interface IMessage<T>
-
public interface IMessageDeliveryModeStrategy
-
public interface IMessageSerializationStrategy
-
public interface IPersistentConnection : IDisposable
-
public interface ISaga
-
public interface IScheduler
-
public interface ISubscriptionResult : IDisposable
-
public interface ITimeoutStrategy
-
public static class LinqExtensions
-
public static class Message
-
public class Message<T> : IMessage<T>
-
public static class MessageDeliveryMode
-
public class MessageDeliveryModeStrategy : IMessageDeliveryModeStrategy
-
public static class MessageFactory
-
public class MessageProperties
-
public class MessageReturnedEventArgs : EventArgs
-
public class OrderedClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
-
public class PersistentConnection : IPersistentConnection, IDisposable
-
public class RabbitAdvancedBus : IAdvancedBus, IDisposable
- public IConventions Conventions { get; }
- 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, IEasyNetQLogger logger, IClientCommandDispatcherFactory clientCommandDispatcherFactory, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IContainer container, ConnectionConfiguration connectionConfiguration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, AdvancedBusEventHandlers advancedBusEventHandlers)
- public event Action Blocked
- public event Action Connected
- public event Action Disconnected
- public event Action<byte[], MessageProperties, MessageReturnedInfo> MessageReturned
- public event Action Unblocked
- public RabbitAdvancedBus(IConnectionFactory connectionFactory, IConsumerFactory consumerFactory, IEasyNetQLogger logger, IClientCommandDispatcherFactory clientCommandDispatcherFactory, IPublisher publisher, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IContainer container, IConnectionConfiguration connectionConfiguration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy)
- public IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)
- public IDisposable Consume(IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- public virtual 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 IExchange ExchangeDeclare(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
- public Task<IExchange> ExchangeDeclareAsync(string name, string type, bool passive = false, bool durable = true, bool autoDelete = false, bool internal = false, string alternateExchange = null)
- protected void OnBlocked(ConnectionBlockedEvent args)
- protected void OnBlocked()
- public void Publish(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body)
- public void Publish<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message)
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, IMessage message)
- public virtual Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message)
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body)
- public virtual IQueue QueueDeclare(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int? perQueueMessageTtl = default, int? expires = default, int? maxPriority = default, string deadLetterExchange = null, string deadLetterRoutingKey = null, int? maxLength = default, int? maxLengthBytes = default)
- public void Publish(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
- public void Publish<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, bool immediate, MessageProperties messageProperties, byte[] body)
- public virtual Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, bool immediate, IMessage<T> message)
- public virtual IQueue QueueDeclare(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int perQueueTtl = 2147483647, int expires = 2147483647, string deadLetterExchange = null)
- 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 Task<IQueue> QueueDeclareAsync(string name, bool passive = false, bool durable = true, bool exclusive = false, bool autoDelete = false, int perQueueTtl = 2147483647, int expires = 2147483647, string deadLetterExchange = null)
-
public class RabbitBus : IBus, IDisposable
- public IConventions Conventions { get; }
- public RabbitBus(IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IRpc rpc, ISendReceive sendReceive, ConnectionConfiguration connectionConfiguration)
- public IEasyNetQLogger Logger { get; }
- public event Action Connected
- public event Action Disconnected
- public RabbitBus(IEasyNetQLogger logger, IConventions conventions, IAdvancedBus advancedBus, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IRpc rpc, ISendReceive sendReceive, IConnectionConfiguration connectionConfiguration)
- protected void OnConnected()
- protected void OnDisconnected()
- public virtual void Publish<T>(T message, Action<IPublishConfiguration> configure)
- public virtual Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure)
- public virtual IDisposable Receive<T>(string queue, Action<T> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Receive<T>(string queue, Func<T, Task> onMessage, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Receive(string queue, Action<IReceiveRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- public IDisposable Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, Action<IResponderConfiguration> configure)
- public IDisposable RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
- public virtual 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 virtual IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage)
- public virtual IDisposable Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure)
- public virtual IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- public virtual IDisposable SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration> configure)
-
public static class RabbitBusExtensions
- 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, string cancellationKey, T message)
- public static void FuturePublish<T>(this IBus bus, TimeSpan messageDelay, T message)
- public static Task FuturePublishAsync<T>(this IBus bus, DateTime futurePublishDate, T message)
- public static Task FuturePublishAsync<T>(this IBus bus, DateTime futurePublishDate, string cancellationKey, T message)
- public static Task FuturePublishAsync<T>(this IBus bus, TimeSpan messageDelay, T message)
-
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, AdvancedBusEventHandlers advancedBusEventHandlers)
- 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, 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 IBus CreateBus(IConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
- public static IBus CreateBus()
-
public static class ReflectionHelpers
-
public class Scheduler : IScheduler
- public Scheduler(IAdvancedBus advancedBus, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ISerializer serializer, ITypeNameSerializer typeNameSerializer)
- public void CancelFuturePublish(string cancellationKey)
- public Task CancelFuturePublishAsync(string cancellationKey)
- public void FuturePublish<T>(DateTime futurePublishDate, T message)
- public void FuturePublish<T>(DateTime futurePublishDate, string cancellationKey, T message)
- public void FuturePublish<T>(TimeSpan messageDelay, T message)
- public Task FuturePublishAsync<T>(DateTime futurePublishDate, T message)
- public Task FuturePublishAsync<T>(DateTime futurePublishDate, string cancellationKey, T message)
- public Task FuturePublishAsync<T>(TimeSpan messageDelay, T message)
-
public sealed delegate SubsriberNameFromDelegate : MulticastDelegate
-
public sealed class TimeBudget
-
public class TimeoutSecondsAttribute : Attribute
-
public class TimeoutStrategy : ITimeoutStrategy
-
public static class TaskHelpers
EasyNetQ.ConnectionString
EasyNetQ.Consumer
-
public class Base64ErrorMessageSerializer : IErrorMessageSerializer
-
public class ConsumerConfiguration : IConsumerConfiguration
-
public class ConsumerDispatcher : IConsumerDispatcher, IDisposable
-
public class ConsumerDispatcherFactory : IConsumerDispatcherFactory, IDisposable
-
public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
-
public class DefaultErrorMessageSerializer : IErrorMessageSerializer
-
public class ExclusiveConsumer : IConsumer, IDisposable
-
public class HandlerCollection : IHandlerCollection, IHandlerRegistration
-
public interface IConsumerConfiguration
-
public interface IErrorMessageSerializer
-
public interface IHandlerCollection : IHandlerRegistration
-
public interface IInternalConsumer : IDisposable
- StartConsumingStatus StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
- void StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
-
public class InternalConsumer : IBasicConsumer, IInternalConsumer, IDisposable
- public event EventHandler<ConsumerEventArgs> ConsumerCancelled
- public InternalConsumer(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConsumerDispatcher consumerDispatcher, IConventions conventions, ConnectionConfiguration connectionConfiguration, IEventBus eventBus)
- public event ConsumerCancelledEventHandler ConsumerCancelled
- public InternalConsumer(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConsumerDispatcher consumerDispatcher, IConventions conventions, IConnectionConfiguration connectionConfiguration, IEventBus eventBus)
- public void HandleModelShutdown(object model, ShutdownEventArgs reason)
- public StartConsumingStatus StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
- public void HandleModelShutdown(IModel model, ShutdownEventArgs reason)
- public void StartConsuming(IPersistentConnection connection, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, IConsumerConfiguration configuration)
-
public class InternalConsumerFactory : IInternalConsumerFactory, IDisposable
- public InternalConsumerFactory(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConventions conventions, ConnectionConfiguration connectionConfiguration, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
- public InternalConsumerFactory(IHandlerRunner handlerRunner, IEasyNetQLogger logger, IConventions conventions, IConnectionConfiguration connectionConfiguration, IConsumerDispatcherFactory consumerDispatcherFactory, IEventBus eventBus)
-
public enum StartConsumingStatus
-
public class SubscriptionResult : ISubscriptionResult, IDisposable
EasyNetQ.Events
EasyNetQ.FluentConfiguration
EasyNetQ.Interception
EasyNetQ.Internals
EasyNetQ.MessageVersioning
EasyNetQ.NonGeneric
-
public static class NonGenericExtensions
- 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)
- public static IDisposable Subscribe(this IBus bus, Type messageType, string subscriptionId, Action<object> onMessage)
- public static IDisposable Subscribe(this IBus bus, Type messageType, string subscriptionId, Action<object> onMessage, Action<ISubscriptionConfiguration> configure)
- public static IDisposable SubscribeAsync(this IBus bus, Type messageType, string subscriptionId, Func<object, Task> onMessage)
- public static IDisposable SubscribeAsync(this IBus bus, Type messageType, string subscriptionId, Func<object, Task> onMessage, Action<ISubscriptionConfiguration> configure)
EasyNetQ.Producer
-
public class ClientCommandDispatcher : IClientCommandDispatcher, IDisposable
-
public class ClientCommandDispatcherFactory : IClientCommandDispatcherFactory
-
public class ClientCommandDispatcherSingleton : IClientCommandDispatcher, IDisposable
-
public interface IClientCommandDispatcher : IDisposable
-
public interface IPublishConfirmationListener : IDisposable
-
public interface IPublishConfirmationWaiter
-
public interface IPublisher
-
public interface IResponderConfiguration
-
public interface IRpc
-
public interface ISendReceive
-
public class PersistentChannel : IPersistentChannel, IDisposable
-
public class PersistentChannelFactory : IPersistentChannelFactory
-
public class PublishConfirmationListener : IPublishConfirmationListener, IDisposable
-
public class PublishConfirmationWaiter : IPublishConfirmationWaiter
-
public abstract class PublisherBase : IPublisher
-
public class PublisherBasic : PublisherBase
-
public class PublisherConfirms : PublisherBase
-
public static class PublisherFactory
-
public class PublishInterruptedException : Exception
-
public class ResponderConfiguration : IResponderConfiguration
-
public class Rpc : IRpc
- protected const string exceptionMessageKey = "ExceptionMessage"
- protected const string isFaultedKey = "IsFaulted"
- protected const string ExceptionMessageKey = "ExceptionMessage"
- protected const string IsFaultedKey = "IsFaulted"
- protected readonly IConnectionConfiguration configuration
- public Rpc(ConnectionConfiguration connectionConfiguration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITimeoutStrategy timeoutStrategy, ITypeNameSerializer typeNameSerializer)
- public Rpc(IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IPublishExchangeDeclareStrategy publishExchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IConnectionConfiguration configuration)
- public virtual IDisposable Respond<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, Action<IResponderConfiguration> configure)
-
public class SendReceive : ISendReceive
EasyNetQ.Scheduling
EasyNetQ.SystemMessages
EasyNetQ.Topology