API Diff between 8.0.0-beta10 and 3.5.0-alpha0025
992 Additions
453 Removals
EasyNetQ
-
public class AdvancedBusEventHandlers
-
public static class AdvancedBusExtensions
- public static IBinding Bind(this IAdvancedBus bus, IExchange source, IExchange destination, string routingKey, CancellationToken cancellationToken = default)
- public static IBinding Bind(this IAdvancedBus bus, IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
- public static IBinding Bind(this IAdvancedBus bus, IExchange exchange, IQueue queue, string routingKey, CancellationToken cancellationToken = default)
- public static IBinding Bind(this IAdvancedBus bus, IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
- public static IDisposable Consume<T>(this IAdvancedBus bus, IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage)
- public static IDisposable Consume<T>(this IAdvancedBus bus, IQueue queue, Action<IMessage<T>, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
- public static IDisposable Consume<T>(this IAdvancedBus bus, IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Action<IHandlerRegistration> addHandlers)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Action<byte[], MessageProperties, MessageReceivedInfo> onMessage, Action<IConsumerConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
- public static IDisposable Consume(this IAdvancedBus bus, IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage, Action<IConsumerConfiguration> configure)
- 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 void ExchangeDelete(this IAdvancedBus bus, IExchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public static IBasicGetResult<T> GetMessage<T>(this IAdvancedBus bus, IQueue queue, CancellationToken cancellationToken = default)
- public static IBasicGetResult GetMessage(this IAdvancedBus bus, IQueue queue, CancellationToken cancellationToken = default)
- public static uint GetMessagesCount(this IAdvancedBus bus, IQueue queue, CancellationToken cancellationToken = default)
- public static void Publish(this IAdvancedBus bus, IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body, CancellationToken cancellationToken = default)
- public static void Publish<T>(this IAdvancedBus bus, IExchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken = default)
- public static IQueue QueueDeclare(this IAdvancedBus bus, 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 static void QueueDelete(this IAdvancedBus bus, IQueue queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- public static void QueuePurge(this IAdvancedBus bus, IQueue queue, CancellationToken cancellationToken = default)
- public static void Unbind(this IAdvancedBus bus, IBinding binding, CancellationToken cancellationToken = default)
- public static Binding<Exchange> Bind(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, CancellationToken cancellationToken = default)
- public static Binding<Exchange> Bind(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Binding<Queue> Bind(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, CancellationToken cancellationToken = default)
- public static Binding<Queue> Bind(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Task<Binding<Queue>> BindAsync(this IAdvancedBus bus, Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Task<Binding<Exchange>> BindAsync(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static Task<Binding<Queue>> BindAsync(this IAdvancedBus bus, Exchange source, Queue queue, string routingKey, CancellationToken cancellationToken = default)
- public static Task<Binding<Exchange>> BindAsync(this IAdvancedBus bus, Exchange source, Exchange destination, string routingKey, CancellationToken cancellationToken = default)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, Task> handler)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume<T>(this IAdvancedBus bus, Queue queue, IMessageHandler<T> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<IHandlerRegistration> addHandlers)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<IHandlerRegistration> addHandlers, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Action<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task<AckStrategy>> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, Task<AckStrategy>> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, MessageHandler handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler, Action<ISimpleConsumeConfiguration> configure)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler)
- public static IDisposable Consume(this IAdvancedBus bus, Queue queue, MessageHandler handler, Action<ISimpleConsumeConfiguration> configure)
- public static Exchange ExchangeDeclare(this IAdvancedBus bus, string exchange, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
- public static Exchange ExchangeDeclare(this IAdvancedBus bus, string exchange, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public static Task<Exchange> ExchangeDeclareAsync(this IAdvancedBus bus, string exchange, string type, bool durable = true, bool autoDelete = false, CancellationToken cancellationToken = default)
- public static void ExchangeDeclarePassive(this IAdvancedBus bus, string exchange, CancellationToken cancellationToken = default)
- public static void ExchangeDelete(this IAdvancedBus bus, Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public static Task ExchangeDeleteAsync(this IAdvancedBus bus, Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public static void ExchangeUnbindAsync(this IAdvancedBus bus, string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static QueueStats GetQueueStats(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
- public static void Publish(this IAdvancedBus bus, ref Exchange exchange, string routingKey, bool mandatory, ref MessageProperties messageProperties, ref ReadOnlyMemory body, CancellationToken cancellationToken = default)
- public static void Publish(this IAdvancedBus bus, string exchange, string routingKey, bool mandatory, ref MessageProperties messageProperties, ref ReadOnlyMemory body, CancellationToken cancellationToken = default)
- public static Task PublishAsync(this IAdvancedBus bus, ref Exchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken = default)
- public static Task PublishAsync(this IAdvancedBus bus, ref Exchange exchange, string routingKey, bool mandatory, ref MessageProperties properties, ref ReadOnlyMemory body, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, string queue, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, string queue, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
- public static Queue QueueDeclare(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
- public static Task<Queue> QueueDeclareAsync(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
- public static Task<Queue> QueueDeclareAsync(this IAdvancedBus bus, string queue, bool durable, bool exclusive, bool autoDelete, CancellationToken cancellationToken = default)
- public static void QueueDeclarePassive(this IAdvancedBus bus, string queue, CancellationToken cancellationToken = default)
- public static void QueueDelete(this IAdvancedBus bus, string queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- public static void QueuePurge(this IAdvancedBus bus, string name, CancellationToken cancellationToken = default)
- public static void QueueUnbindAsync(this IAdvancedBus bus, string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- public static void Unbind(this IAdvancedBus bus, Binding<Queue> binding, CancellationToken cancellationToken = default)
- public static void Unbind(this IAdvancedBus bus, Binding<Exchange> binding, CancellationToken cancellationToken = default)
- public static Task UnbindAsync(this IAdvancedBus bus, Binding<Queue> binding, CancellationToken cancellationToken = default)
- public static Task UnbindAsync(this IAdvancedBus bus, Binding<Exchange> binding, CancellationToken cancellationToken = default)
-
public class BasicGetResult : IBasicGetResult
-
public class BasicGetResult<T> : IBasicGetResult<T>
-
public class BlockedEventArgs : EventArgs
-
public class ConnectedEventArgs : EventArgs
-
public class ConnectionConfiguration
-
public class ConnectionFactoryInfo
-
public class ConnectionFactoryWrapper : IConnectionFactory
-
public static class ConsumeConfigurationExtensions
- public static IConsumeConfiguration ForQueue(this IConsumeConfiguration configuration, ref Queue queue, MessageHandler handler)
- public static IConsumeConfiguration ForQueue(this IConsumeConfiguration configuration, ref Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler)
- public static IConsumeConfiguration ForQueue(this IConsumeConfiguration configuration, ref Queue queue, Func<ReadOnlyMemory<byte>, MessageProperties, MessageReceivedInfo, CancellationToken, Task> handler, Action<IPerQueueConsumeConfiguration> configure)
- public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, IMessageHandler<T> handler)
- public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, IMessageHandler<T> handler, Action<IPerQueueConsumeConfiguration> configure)
- public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> handler)
- public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> handler, Action<IPerQueueConsumeConfiguration> configure)
- public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler)
- public static IConsumeConfiguration ForQueue<T>(this IConsumeConfiguration configuration, ref Queue queue, Action<IMessage<T>, MessageReceivedInfo> handler, Action<IPerQueueConsumeConfiguration> configure)
-
public struct ConsumedMessage : IEquatable<ConsumedMessage>
-
public class Conventions : IConventions
-
public static class ConventionsExtensions
-
public class DeadLetterExchangeAndMessageTtlScheduler : IScheduler
-
public static class DeadLetterStrategy
-
public class DefaultExchangeDeclareStrategy : IExchangeDeclareStrategy
-
public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
-
public class DefaultPubSub : IPubSub
- public DefaultPubSub(ConnectionConfiguration configuration, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, IAdvancedBus advancedBus)
- public virtual Task PublishAsync<T>(T message, Action<IPublishConfiguration> configure, CancellationToken cancellationToken)
- public virtual AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken)
-
public class DefaultRpc : IRpc, IDisposable
- protected struct ResponseAction
- protected struct ResponseSubscription
- protected struct RpcKey : IEquatable<RpcKey>
- protected const string ExceptionMessageKey = "ExceptionMessage"
- protected const string IsFaultedKey = "IsFaulted"
- protected readonly IAdvancedBus advancedBus
- protected readonly IConventions conventions
- protected readonly IExchangeDeclareStrategy exchangeDeclareStrategy
- protected readonly IMessageDeliveryModeStrategy messageDeliveryModeStrategy
- public DefaultRpc(ILogger<DefaultRpc> logger, ConnectionConfiguration configuration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITypeNameSerializer typeNameSerializer, ICorrelationIdGenerationStrategy correlationIdGenerationStrategy)
- protected void DeRegisterResponseActions(string correlationId)
- public void Dispose()
- protected void RegisterResponseActions<TResponse>(string correlationId, TaskCompletionSource<TResponse> tcs)
- public virtual Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, Action<IRequestConfiguration> configure, CancellationToken cancellationToken = default)
- protected virtual Task RequestPublishAsync<TRequest>(TRequest request, string routingKey, string returnQueueName, string correlationId, TimeSpan expiration, byte? priority, bool mandatory, IDictionary<string, object> headers, CancellationToken cancellationToken)
- public virtual AwaitableDisposable<IDisposable> RespondAsync<TRequest, TResponse>(Func<TRequest, CancellationToken, Task<TResponse>> responder, Action<IResponderConfiguration> configure, CancellationToken cancellationToken = default)
- protected virtual Task<string> SubscribeToResponseAsync<TRequest, TResponse>(CancellationToken cancellationToken)
-
public class DefaultSendReceive : ISendReceive
-
public class DefaultTypeNameSerializer : ITypeNameSerializer
-
public static class DelayedExchangeExtensions
-
public class DelayedExchangeScheduler : IScheduler
-
public class DisconnectedEventArgs : EventArgs
-
public class EasyNetQException : Exception
-
public class EasyNetQResponderException : EasyNetQException
-
public sealed delegate ErrorExchangeRoutingKeyConvention : MulticastDelegate
-
public sealed delegate ErrorExchangeTypeConvention : MulticastDelegate
-
public sealed delegate ErrorQueueTypeConvention : MulticastDelegate
-
public sealed class EventBus : IEventBus
-
public sealed class ExchangeAttribute : Attribute
-
public static class ExchangeDeclareConfigurationExtensions
-
public static class Extensions
-
public static class ExchangeType
- public const string Direct = "direct"
- public const string Fanout = "fanout"
- public const string = "headers"
- public const string Topic = "topic"
-
public class HostConfiguration
-
public interface IAdvancedBus
- IServiceResolver Container { get; }
- IConventions Conventions { get; }
- event EventHandler<ConnectionBlockedEventArgs> Blocked
- event EventHandler Connected
- event EventHandler Disconnected
- event EventHandler<BlockedEventArgs> Blocked
- event EventHandler<ConnectedEventArgs> Connected
- event EventHandler<DisconnectedEventArgs> Disconnected
- event EventHandler Unblocked
- Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, CancellationToken cancellationToken = default)
- Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
- Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, CancellationToken cancellationToken = default)
- Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken = default)
- IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
- IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure)
- IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure)
- 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 ExchangeDeleteAsync(IExchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- Task<IBasicGetResult<T>> GetMessageAsync<T>(IQueue queue, CancellationToken cancellationToken = default)
- Task<IBasicGetResult> GetMessageAsync(IQueue queue, CancellationToken cancellationToken = default)
- Task<uint> GetMessagesCountAsync(IQueue queue, CancellationToken cancellationToken = default)
- Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken = default)
- Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken = default)
- Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body, 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<IQueue> QueueDeclareAsync(CancellationToken cancellationToken = default)
- Task QueueDeleteAsync(IQueue queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- Task QueuePurgeAsync(IQueue queue, CancellationToken cancellationToken = default)
- Task UnbindAsync(IBinding binding, CancellationToken cancellationToken = default)
- event EventHandler<UnblockedEventArgs> Unblocked
- Task ConnectAsync(CancellationToken cancellationToken = default)
- IDisposable Consume(Action<IConsumeConfiguration> configure)
- IPullingConsumer<PullResult> CreatePullingConsumer(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, bool autoAck = true)
- IPullingConsumer<PullResult<T>> CreatePullingConsumer<T>(Queue& modreq(System.Runtime.InteropServices.InAttribute) queue, bool autoAck = true)
- Task ExchangeBindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task<Exchange> ExchangeDeclareAsync(string exchange, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- Task ExchangeDeclarePassiveAsync(string exchange, CancellationToken cancellationToken = default)
- Task ExchangeDeleteAsync(string exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- Task ExchangeUnbindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task<QueueStats> GetQueueStatsAsync(string queue, CancellationToken cancellationToken = default)
- Task PublishAsync(string exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken = default)
- Task PublishAsync(string exchange, string routingKey, bool mandatory, MessageProperties properties, ReadOnlyMemory<byte> body, CancellationToken cancellationToken = default)
- Task QueueBindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task<Queue> QueueDeclareAsync(string queue, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- Task<Queue> QueueDeclareAsync(CancellationToken cancellationToken = default)
- Task QueueDeclarePassiveAsync(string queue, CancellationToken cancellationToken = default)
- Task QueueDeleteAsync(string queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- Task QueuePurgeAsync(string queue, CancellationToken cancellationToken = default)
- Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
-
public interface IBasicGetResult
-
public interface IBasicGetResult<T>
-
public interface IBus
-
public interface IClusterHostSelectionStrategy<T>
-
public interface IConnectionFactory
-
public interface IConsumeConfiguration
-
public interface IConventions
-
public interface IEventBus
-
public interface IExchangeDeclareConfiguration
-
public interface IExchangeDeclareStrategy
-
public interface IFuturePublishConfiguration
-
public interface IMessageSerializationStrategy
-
public interface IPersistentConnection : IDisposable
-
public interface IPersistentConnectionFactory
-
public interface IPerQueueConsumeConfiguration
-
public interface IPublishConfiguration
-
public interface IPubSub
-
public interface IPullingConsumer<TPullResult> : IDisposable where TPullResult : IPullResult
-
public interface IPullingConsumerFactory
-
public interface IPullResult : IDisposable
-
public interface IQueueDeclareConfiguration
-
public interface IReceiveConfiguration
-
public interface IReceiveRegistration
-
public interface IRequestConfiguration
-
public interface IResponderConfiguration
-
public interface IRpc
-
public interface IScheduler
-
public interface ISendConfiguration
-
public interface ISendReceive
-
public interface ISerializer
-
public interface ISubscriptionResult : IDisposable
-
public interface ITimeoutStrategy
-
public interface ISimpleConsumeConfiguration
-
public interface ISubscriptionConfiguration
-
public interface ITypeNameSerializer
-
public class JsonSerializer : ISerializer
-
public static class LegacyRpcConventionsExtensions
-
public class LegacyTypeNameSerializer : ITypeNameSerializer
-
public static class LegacyTypeNamingExtensions
-
public static class LinqExtensions
-
public class Message<T> : IMessage<T>, IMessage
-
public static class MessageFactory
-
public class MessageNotAvailableException : Exception
-
public struct MessageProperties : IEquatable<MessageProperties>
-
public static class MessagePropertiesExtensions
-
public struct MessageReceivedInfo : IEquatable<MessageReceivedInfo>
-
public class MessageReturnedEventArgs : EventArgs
-
public class OrderedClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
-
public class PersistentConnection : IPersistentConnection, IDisposable
-
public class PersistentConnectionFactory : IPersistentConnectionFactory
-
public static class NonGenericPubSubExtensions
- public static void Publish(this IPubSub pubSub, object message, Type messageType, CancellationToken cancellationToken = default)
- public static void Publish(this IPubSub pubSub, object message, Type messageType, Action<IPublishConfiguration> configure, CancellationToken cancellationToken = default)
- public static void Publish(this IPubSub pubSub, object message, Type messageType, string topic, CancellationToken cancellationToken = default)
- public static Task PublishAsync(this IPubSub pubSub, object message, Type messageType, CancellationToken cancellationToken = default)
- public static Task PublishAsync(this IPubSub pubSub, object message, Type messageType, string topic, CancellationToken cancellationToken = default)
- public static Task PublishAsync(this IPubSub pubSub, object message, Type messageType, Action<IPublishConfiguration> configure, CancellationToken cancellationToken = default)
- public static SubscriptionResult Subscribe(this IPubSub pubSub, string subscriptionId, Type messageType, Func<object, Type, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<SubscriptionResult> SubscribeAsync(this IPubSub pubSub, string subscriptionId, Type messageType, Func<object, Type, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
-
public static class NonGenericRpcExtensions
- public static object Request(this IRpc rpc, object request, Type requestType, Type responseType, CancellationToken cancellationToken = default)
- public static object Request(this IRpc rpc, object request, Type requestType, Type responseType, Action<IRequestConfiguration> configure, CancellationToken cancellationToken = default)
- public static Task<object> RequestAsync(this IRpc rpc, object request, Type requestType, Type responseType, CancellationToken cancellationToken = default)
- public static Task<object> RequestAsync(this IRpc rpc, object request, Type requestType, Type responseType, Action<IRequestConfiguration> configure, CancellationToken cancellationToken = default)
-
public static class NonGenericSchedulerExtensions
- public static void FuturePublish(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, string topic, CancellationToken cancellationToken = default)
- public static void FuturePublish(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, CancellationToken cancellationToken = default)
- public static void FuturePublish(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
- public static Task FuturePublishAsync(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, CancellationToken cancellationToken = default)
- public static Task FuturePublishAsync(this IScheduler scheduler, object message, Type messageType, TimeSpan delay, Action<IFuturePublishConfiguration> configure, CancellationToken cancellationToken = default)
-
public static class NonGenericSendReceiveExtensions
- public static void Send(this ISendReceive sendReceive, string queue, object message, Type messageType, CancellationToken cancellationToken = default)
- public static void Send(this ISendReceive sendReceive, string queue, object message, Type messageType, Action<ISendConfiguration> configure, CancellationToken cancellationToken = default)
- public static Task SendAsync(this ISendReceive sendReceive, string queue, object message, Type messageType, CancellationToken cancellationToken = default)
- public static Task SendAsync(this ISendReceive sendReceive, string queue, object message, Type messageType, Action<ISendConfiguration> configure, CancellationToken cancellationToken = default)
-
public static class OverflowType
-
public static class PerQueueConsumeConfigurationExtensions
-
public struct ProducedMessage : IEquatable<ProducedMessage>
-
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 SubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, CancellationToken cancellationToken = default)
- public static SubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
- public static SubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
- public static SubscriptionResult Subscribe<T>(this IPubSub pubSub, string subscriptionId, Func<T, CancellationToken, Task> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration> configure, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<SubscriptionResult> SubscribeAsync<T>(this IPubSub pubSub, string subscriptionId, Func<T, Task> onMessage, CancellationToken cancellationToken = default)
-
public struct PullBatchResult<TPullResult> : IDisposable where TPullResult : IPullResult
-
public class PullingConsumer : IPullingConsumer<PullResult>, IDisposable
-
public class PullingConsumer<T> : IPullingConsumer<PullResult<T>>, IDisposable
-
public static class PullingConsumerExtensions
- public static Task AckAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, ulong deliveryTag, CancellationToken cancellationToken = default) where TPullResult : IPullResult
- public static Task AckBatchAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, ulong deliveryTag, CancellationToken cancellationToken = default) where TPullResult : IPullResult
- public static Task<PullBatchResult<TPullResult>> PullBatchAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, int batchSize, CancellationToken cancellationToken = default) where TPullResult : IPullResult
- public static Task RejectAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, ulong deliveryTag, bool requeue = false, CancellationToken cancellationToken = default) where TPullResult : IPullResult
- public static Task RejectBatchAsync<TPullResult>(this IPullingConsumer<TPullResult> consumer, ulong deliveryTag, bool requeue = false, CancellationToken cancellationToken = default) where TPullResult : IPullResult
-
public class PullingConsumerFactory : IPullingConsumerFactory
-
public struct PullingConsumerOptions
-
public struct PullResult : IPullResult, IDisposable
-
public struct PullResult<T> : IPullResult, IDisposable
-
public sealed class QueueAttribute : Attribute
-
public class QueueConsumerPair
-
public static class QueueDeclareConfigurationExtensions
- public static IQueueDeclareConfiguration WithDeadLetterExchange(this IQueueDeclareConfiguration configuration, Exchange deadLetterExchange)
- public static IQueueDeclareConfiguration WithDeadLetterRoutingKey(this IQueueDeclareConfiguration configuration, string deadLetterRoutingKey)
- public static IQueueDeclareConfiguration WithDeadLetterStrategy(this IQueueDeclareConfiguration configuration, string deadLetterStrategy = "at-most-once")
- public static IQueueDeclareConfiguration WithExpires(this IQueueDeclareConfiguration configuration, TimeSpan expires)
- public static IQueueDeclareConfiguration WithMaxLength(this IQueueDeclareConfiguration configuration, int maxLength)
- public static IQueueDeclareConfiguration WithMaxLengthBytes(this IQueueDeclareConfiguration configuration, int maxLengthBytes)
- public static IQueueDeclareConfiguration WithMaxPriority(this IQueueDeclareConfiguration configuration, int maxPriority)
- public static IQueueDeclareConfiguration WithMessageTtl(this IQueueDeclareConfiguration configuration, TimeSpan messageTtl)
- public static IQueueDeclareConfiguration WithOverflowType(this IQueueDeclareConfiguration configuration, string overflowType = "drop-head")
- public static IQueueDeclareConfiguration WithQueueMasterLocator(this IQueueDeclareConfiguration configuration, string queueMasterLocator = "min-masters")
- public static IQueueDeclareConfiguration WithQueueMode(this IQueueDeclareConfiguration configuration, string queueMode = "default")
- public static IQueueDeclareConfiguration WithQueueType(this IQueueDeclareConfiguration configuration, string queueType = "classic")
- public static IQueueDeclareConfiguration WithSingleActiveConsumer(this IQueueDeclareConfiguration configuration, bool singleActiveConsumer = true)
-
public static class QueueMasterLocator
-
public static class QueueMode
- public const string Default = "default"
- public const string Lazy = "lazy"
-
public struct QueueStats
-
public static class QueueType
- public const string Classic = "classic"
- public const string Quorum = "quorum"
- public const string Stream = "stream"
-
public sealed delegate QueueTypeConvention : MulticastDelegate
-
public class RabbitAdvancedBus : IAdvancedBus, IDisposable
- public IServiceResolver Container { get; }
- public IConventions Conventions { get; }
- public event EventHandler<ConnectionBlockedEventArgs> Blocked
- public event EventHandler Connected
- public event EventHandler Disconnected
- public event EventHandler<BlockedEventArgs> Blocked
- public event EventHandler<ConnectedEventArgs> Connected
- public event EventHandler<DisconnectedEventArgs> Disconnected
- public event EventHandler Unblocked
- public RabbitAdvancedBus(IConnectionFactory connectionFactory, IConsumerFactory consumerFactory, IClientCommandDispatcherFactory clientCommandDispatcherFactory, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IServiceResolver container, ConnectionConfiguration connectionConfiguration, IProduceConsumeInterceptor produceConsumeInterceptor, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, AdvancedBusEventHandlers advancedBusEventHandlers, IPersistentConnectionFactory persistentConnectionFactory)
- public Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, CancellationToken cancellationToken)
- public Task<IBinding> BindAsync(IExchange exchange, IQueue queue, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken)
- public Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, CancellationToken cancellationToken)
- public Task<IBinding> BindAsync(IExchange source, IExchange destination, string routingKey, IDictionary<string, object> headers, CancellationToken cancellationToken)
- public IDisposable Consume(IEnumerable<QueueConsumerPair> queueConsumerPairs, Action<IConsumerConfiguration> configure)
- public IDisposable Consume<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure)
- public IDisposable Consume(IQueue queue, Action<IHandlerRegistration> addHandlers, Action<IConsumerConfiguration> configure)
- public virtual IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, CancellationToken, Task> onMessage, Action<IConsumerConfiguration> configure)
- public event EventHandler<UnblockedEventArgs> Unblocked
- public RabbitAdvancedBus(ILogger<RabbitAdvancedBus> logger, IProducerConnection producerConnection, IConsumerConnection consumerConnection, IConsumerFactory consumerFactory, IPersistentChannelDispatcher persistentChannelDispatcher, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, ConnectionConfiguration configuration, ProducePipelineBuilder producePipelineBuilder, ConsumePipelineBuilder consumePipelineBuilder, IServiceResolver serviceResolver, IMessageSerializationStrategy messageSerializationStrategy, IPullingConsumerFactory pullingConsumerFactory, AdvancedBusEventHandlers advancedBusEventHandlers)
- public Task ConnectAsync(CancellationToken cancellationToken = default)
- public IDisposable Consume(Action<IConsumeConfiguration> configure)
- public IPullingConsumer<PullResult> CreatePullingConsumer(ref Queue queue, bool autoAck = true)
- public IPullingConsumer<PullResult<T>> CreatePullingConsumer<T>(ref Queue queue, bool autoAck = true)
- 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 virtual Task ExchangeDeleteAsync(IExchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public Task<IBasicGetResult<T>> GetMessageAsync<T>(IQueue queue, CancellationToken cancellationToken)
- public Task<IBasicGetResult> GetMessageAsync(IQueue queue, CancellationToken cancellationToken)
- public Task<uint> GetMessagesCountAsync(IQueue queue, CancellationToken cancellationToken)
- protected void OnBlocked(ConnectionBlockedEvent args)
- protected void OnConnected()
- protected void OnDisconnected()
- protected void OnMessageReturned(ReturnedMessageEvent args)
- protected void OnUnblocked()
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken)
- public virtual Task PublishAsync<T>(IExchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken)
- public virtual Task PublishAsync(IExchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, byte[] body, CancellationToken cancellationToken)
- public Task<IQueue> QueueDeclareAsync(CancellationToken cancellationToken)
- 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 virtual Task QueueDeleteAsync(IQueue queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- public virtual Task QueuePurgeAsync(IQueue queue, CancellationToken cancellationToken)
- public virtual Task UnbindAsync(IBinding binding, CancellationToken cancellationToken)
- public virtual Task ExchangeBindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public Task<Exchange> ExchangeDeclareAsync(string exchange, Action<IExchangeDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public Task ExchangeDeclarePassiveAsync(string exchange, CancellationToken cancellationToken = default)
- public virtual Task ExchangeDeleteAsync(string exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public virtual Task ExchangeUnbindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public Task<QueueStats> GetQueueStatsAsync(string queue, CancellationToken cancellationToken)
- public virtual Task PublishAsync(string exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken)
- public virtual Task PublishAsync(string exchange, string routingKey, bool mandatory, MessageProperties properties, ReadOnlyMemory<byte> body, CancellationToken cancellationToken)
- public virtual Task QueueBindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public Task<Queue> QueueDeclareAsync(CancellationToken cancellationToken)
- public Task<Queue> QueueDeclareAsync(string queue, Action<IQueueDeclareConfiguration> configure, CancellationToken cancellationToken = default)
- public Task QueueDeclarePassiveAsync(string queue, CancellationToken cancellationToken = default)
- public virtual Task QueueDeleteAsync(string queue, bool ifUnused = false, bool ifEmpty = false, CancellationToken cancellationToken = default)
- public virtual Task QueuePurgeAsync(string queue, CancellationToken cancellationToken)
- public virtual Task QueueUnbindAsync(string queue, string exchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
-
public class RabbitBus : IBus
-
public static class RabbitHutch
- public static IBus CreateBus(string connectionString)
- 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 SelfHostedBus CreateBus(string connectionString)
- public static SelfHostedBus CreateBus(string connectionString, Action<IServiceRegister> registerServices)
- public static SelfHostedBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, TimeSpan requestedHeartbeat, Action<IServiceRegister> registerServices)
- public static SelfHostedBus CreateBus(ConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
- public static SelfHostedBus CreateBus(Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory, Action<IServiceRegister> registerServices)
-
public class RandomClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
-
public static class ReflectionHelpers
-
public static class ReceiveRegistrationExtensions
-
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, TResponse> responder, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<IDisposable> RespondAsync<TRequest, TResponse>(this IRpc rpc, Func<TRequest, Task<TResponse>> responder, CancellationToken cancellationToken = default)
-
public sealed delegate RpcReturnQueueNamingConvention : MulticastDelegate
-
public static class SchedulerExtensions
- public static void FuturePublish<T>(this IScheduler scheduler, T message, TimeSpan delay, string topic, CancellationToken cancellationToken = default)
- public static void FuturePublish<T>(this IScheduler scheduler, T message, TimeSpan delay, CancellationToken cancellationToken = default)
- public static Task FuturePublishAsync<T>(this IScheduler scheduler, T message, TimeSpan delay, CancellationToken cancellationToken = default)
-
public sealed class SelfHostedBus : IBus, IDisposable
-
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<IReceiveConfiguration> 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<IReceiveConfiguration> 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<IReceiveConfiguration> configure, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Func<T, CancellationToken, Task> onMessage, CancellationToken cancellationToken = default)
- public static AwaitableDisposable<IDisposable> ReceiveAsync<T>(this ISendReceive sendReceive, string queue, Func<T, CancellationToken, Task> onMessage, Action<IReceiveConfiguration> 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<IReceiveConfiguration> 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<T>(this ISendReceive sendReceive, string queue, Func<T, Task> onMessage, Action<IReceiveConfiguration> configure, 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)
- public static void Send<T>(this ISendReceive sendReceive, string queue, T message, Action<ISendConfiguration> configure, CancellationToken cancellationToken = default)
- public static Task SendAsync<T>(this ISendReceive sendReceive, string queue, T message, CancellationToken cancellationToken = default)
-
public struct SerializedMessage : IDisposable
-
public static class ServiceRegisterExtensions
-
public static class SimpleConsumeConfigurationExtensions
-
public struct SubscriptionResult : IDisposable
-
public sealed class TimeBudget
-
public class TimeoutSecondsAttribute : Attribute
-
public class TimeoutStrategy : ITimeoutStrategy
-
public sealed delegate TEventHandler<TEvent> : MulticastDelegate where TEvent : struct
- public TEventHandler(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(TEvent& modreq(System.Runtime.InteropServices.InAttribute) event, AsyncCallback callback, object object)
- public virtual void EndInvoke(TEvent& modreq(System.Runtime.InteropServices.InAttribute) event, IAsyncResult result)
- public virtual void Invoke(TEvent& modreq(System.Runtime.InteropServices.InAttribute) event)
-
public class UnblockedEventArgs : EventArgs
EasyNetQ.AmqpExceptions
EasyNetQ.AutoSubscribe
EasyNetQ.ChannelDispatcher
EasyNetQ.ConnectionString
EasyNetQ.Consumer
-
public class BasicConsumer : IBasicConsumer, IDisposable
-
public class ConsumerCancellation : IDisposable
-
public struct ConsumeContext : IEquatable<ConsumeContext>
- public ReadOnlyMemory<byte> Body { get; set; }
- public CancellationToken CancellationToken { get; set; }
- public MessageProperties Properties { get; set; }
- public MessageReceivedInfo ReceivedInfo { get; set; }
- public IServiceResolver ServiceResolver { get; set; }
- public ConsumeContext(ref MessageReceivedInfo ReceivedInfo, ref MessageProperties Properties, ref ReadOnlyMemory Body, ref IServiceResolver ServiceResolver, ref CancellationToken CancellationToken)
- public static bool op_Equality(ConsumeContext left, ConsumeContext right)
- public static bool op_Inequality(ConsumeContext left, ConsumeContext right)
- public void Deconstruct(out MessageReceivedInfo ReceivedInfo, out MessageProperties Properties, out ReadOnlyMemory Body, out IServiceResolver ServiceResolver, out CancellationToken CancellationToken)
- public bool Equals(ConsumeContext other)
-
public sealed delegate ConsumeDelegate : MulticastDelegate
-
public sealed class ConsumePipelineBuilder
-
public class Consumer : IConsumer, IDisposable
-
public class ConsumerConfiguration
-
public class ConsumerDispatcher : IConsumerDispatcher, IDisposable
-
public class ConsumerDispatcherFactory : IConsumerDispatcherFactory, IDisposable
-
public class ConsumerExecutionContext
-
public sealed class ConsumerConnection : PersistentConnection, IConsumerConnection, IPersistentConnection, IDisposable
-
public class ConsumerFactory : IConsumerFactory, IDisposable
- 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 ConsumerFactory(ILogger<Consumer> logger, IEventBus eventBus, IInternalConsumerFactory internalConsumerFactory)
- public IConsumer CreateConsumer(ConsumerConfiguration configuration)
-
public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
-
public class DefaultConsumeErrorStrategy : IConsumeErrorStrategy
-
public class ExclusiveConsumer : IConsumer, IDisposable
-
public class HandlerCollection : IHandlerCollection, IHandlerRegistration
-
public class HandlerCollectionFactory : IHandlerCollectionFactory
-
public class HandlerCollectionPerQueueFactory : IHandlerCollectionFactory
-
public static class HandlerRegistrationExtensions
-
public class HandlerRunner : IHandlerRunner, IDisposable
-
public interface IConsumeErrorStrategy
-
public interface IConsumer : IDisposable
-
public interface IConsumerConfiguration
-
public interface IConsumerDispatcher : IDisposable
-
public interface IConsumerDispatcherFactory : IDisposable
-
public interface IConsumerErrorStrategy : IDisposable
-
public interface IConsumerConnection : IPersistentConnection, IDisposable
-
public interface IConsumerFactory : IDisposable
- 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)
- IConsumer CreateConsumer(ConsumerConfiguration configuration)
-
public interface IHandlerCollection : IHandlerRegistration
-
public interface IHandlerCollectionFactory
-
public interface IHandlerRegistration
-
public interface IHandlerRunner : IDisposable
-
public interface IInternalConsumer : IDisposable
- event Action<IInternalConsumer> Cancelled
- 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)
- event EventHandler<InternalConsumerCancelledEventArgs> Cancelled
- InternalConsumerStatus StartConsuming(bool firstStart = true)
- void StopConsuming()
-
public interface IInternalConsumerFactory
-
public sealed delegate IMessageHandler : MulticastDelegate
-
public sealed delegate IMessageHandler<T> : MulticastDelegate
-
public class InternalConsumer : IInternalConsumer, IDisposable
- public IModel Model { get; }
- public event Action<IInternalConsumer> Cancelled
- public InternalConsumer(IHandlerRunner handlerRunner, IConsumerDispatcher consumerDispatcher, IConventions conventions, IEventBus eventBus)
- public event EventHandler<InternalConsumerCancelledEventArgs> Cancelled
- public InternalConsumer(IServiceResolver serviceResolver, ILogger<InternalConsumer> logger, ConsumerConfiguration configuration, IConsumerConnection connection, IEventBus eventBus)
- 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 InternalConsumerStatus StartConsuming(bool firstStart)
- public void StopConsuming()
-
public class InternalConsumerCancelledEventArgs : EventArgs
-
public class InternalConsumerFactory : IInternalConsumerFactory
-
public class PersistentConsumer : IConsumer, IDisposable
-
public class PersistentMultipleConsumer : IConsumer, IDisposable
-
public enum StartConsumingStatus
-
public class TransientConsumer : IConsumer, IDisposable
-
public struct InternalConsumerStatus
-
public sealed delegate MessageHandler : MulticastDelegate
-
public class PerQueueConsumerConfiguration
-
public sealed class SimpleConsumeErrorStrategy : IConsumeErrorStrategy
EasyNetQ.DI
-
public class DefaultServiceContainer : IServiceRegister
-
public static class DefaultServicesRegistration
-
public struct AsyncServiceResolverScope : IServiceResolverScope, IServiceResolver, IDisposable, IAsyncDisposable
-
public interface IServiceRegister
- IServiceRegister Register<TService, TImplementation>(Lifetime lifetime = 1) where TImplementation : TService
- IServiceRegister Register<TService>(TService instance)
- IServiceRegister Register<TService>(Func<IServiceResolver, TService> factory, Lifetime lifetime = 1)
- IServiceRegister Register(Type serviceType, Type implementationType, Lifetime lifetime = 1)
- IServiceRegister Register(Type serviceType, Func<IServiceResolver, object> implementationFactory, Lifetime lifetime = 1)
- IServiceRegister Register(Type serviceType, object implementationInstance)
- IServiceRegister TryRegister(Type serviceType, Type implementationType, Lifetime lifetime = 1)
- IServiceRegister TryRegister(Type serviceType, Func<IServiceResolver, object> implementationFactory, Lifetime lifetime = 1)
- IServiceRegister TryRegister(Type serviceType, object implementationInstance)
-
public static class ServiceRegisterExtensions
- public static IServiceRegister Register<TService>(this IServiceRegister services, Lifetime lifetime = 1)
- public static IServiceRegister Register<TService, TImplementation>(this IServiceRegister services, Lifetime lifetime = 1) where TImplementation : TService
- public static IServiceRegister Register<TService>(this IServiceRegister services, Func<IServiceResolver, TService> implementationFactory, Lifetime lifetime = 1)
- public static IServiceRegister Register<TService, TImplementation>(this IServiceRegister services, Func<IServiceResolver, TImplementation> implementationFactory, Lifetime lifetime = 1) where TImplementation : TService
- public static IServiceRegister Register<TService>(this IServiceRegister services, TService implementationInstance)
- public static IServiceRegister TryRegister<TService, TImplementation>(this IServiceRegister services, Lifetime lifetime = 1)
- public static IServiceRegister TryRegister<TService, TImplementation>(this IServiceRegister services, Func<IServiceResolver, TImplementation> implementationFactory, Lifetime lifetime = 1) where TImplementation : TService
- public static IServiceRegister TryRegister<TService>(this IServiceRegister services, Func<IServiceResolver, TService> implementationFactory, Lifetime lifetime = 1)
- public static IServiceRegister TryRegister<TService>(this IServiceRegister services, TService implementationInstance)
EasyNetQ.Events
EasyNetQ.FluentConfiguration
EasyNetQ.Interception
EasyNetQ.Internals
EasyNetQ.LightInject
-
public class AssemblyScanner : IAssemblyScanner
-
public class : ITypeExtractor
-
public class : ICompositionRootAttributeExtractor
-
public class CompositionRootExecutor : ICompositionRootExecutor
-
public class CompositionRootTypeAttribute : Attribute
-
public class : ITypeExtractor
-
public class : 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
-
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
-
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.Logging
-
public class ConsoleLogProvider : ILogProvider
-
public interface ILog
-
public interface ILogProvider
-
public static class LogExtensions
-
public sealed delegate Logger : MulticastDelegate
-
public sealed class ConsoleLogger<TCategoryName> : ILogger<TCategoryName>, ILogger
-
public interface ILogger
-
public interface ILogger<TCategoryName> : ILogger
-
public static class LoggerExtensions
- public static void Debug(this ILogger logger, Func<string> messageFunc)
- public static void Debug(this ILogger logger, string message)
- public static void Debug(this ILogger logger, string message, object[] args)
- public static void Debug(this ILogger logger, Exception exception, string message, object[] args)
- public static void DebugException(this ILogger logger, string message, Exception exception)
- public static void DebugException(this ILogger logger, string message, Exception exception, object[] args)
- public static void DebugFormat(this ILogger logger, string message, object[] args)
- public static void Error(this ILogger logger, Func<string> messageFunc)
- public static void Error(this ILogger logger, string message)
- public static void Error(this ILogger logger, string message, object[] args)
- public static void Error(this ILogger logger, Exception exception, string message, object[] args)
- public static void ErrorException(this ILogger logger, string message, Exception exception, object[] args)
- public static void ErrorFormat(this ILogger logger, string message, object[] args)
- public static void Fatal(this ILogger logger, Func<string> messageFunc)
- public static void Fatal(this ILogger logger, string message)
- public static void Fatal(this ILogger logger, string message, object[] args)
- public static void Fatal(this ILogger logger, Exception exception, string message, object[] args)
- public static void FatalException(this ILogger logger, string message, Exception exception, object[] args)
- public static void FatalFormat(this ILogger logger, string message, object[] args)
- public static void Info(this ILogger logger, Func<string> messageFunc)
- public static void Info(this ILogger logger, string message)
- public static void Info(this ILogger logger, string message, object[] args)
- public static void Info(this ILogger logger, Exception exception, string message, object[] args)
- public static void InfoException(this ILogger logger, string message, Exception exception, object[] args)
- public static void InfoFormat(this ILogger logger, string message, object[] args)
- public static bool IsDebugEnabled(this ILogger logger)
- public static bool IsErrorEnabled(this ILogger logger)
- public static bool IsFatalEnabled(this ILogger logger)
- public static bool IsInfoEnabled(this ILogger logger)
- public static bool IsTraceEnabled(this ILogger logger)
- public static bool IsWarnEnabled(this ILogger logger)
- public static void Trace(this ILogger logger, Func<string> messageFunc)
- public static void Trace(this ILogger logger, string message)
- public static void Trace(this ILogger logger, string message, object[] args)
- public static void Trace(this ILogger logger, Exception exception, string message, object[] args)
- public static void TraceException(this ILogger logger, string message, Exception exception, object[] args)
- public static void TraceFormat(this ILogger logger, string message, object[] args)
- public static void Warn(this ILogger logger, Func<string> messageFunc)
- public static void Warn(this ILogger logger, string message)
- public static void Warn(this ILogger logger, string message, object[] args)
- public static void Warn(this ILogger logger, Exception exception, string message, object[] args)
- public static void WarnException(this ILogger logger, string message, Exception exception, object[] args)
- public static void WarnFormat(this ILogger logger, string message, object[] args)
-
public static class LogProvider
-
public sealed class NoopLogger<TCategoryName> : ILogger<TCategoryName>, ILogger
EasyNetQ.Logging.LogProviders
EasyNetQ.MessageVersioning
EasyNetQ.MultipleExchange
EasyNetQ.Persistent
EasyNetQ.Producer
-
public class ClientCommandDispatcher : IClientCommandDispatcher, IDisposable
-
public class ClientCommandDispatcherFactory : IClientCommandDispatcherFactory
-
public class ClientCommandDispatcherSingleton : IClientCommandDispatcher, IDisposable
-
public class DefaultPubSub : IPubSub
-
public class DefaultRpc : IRpc, IDisposable
-
public class DefaultSendReceive : ISendReceive
-
public interface IClientCommandDispatcher : IDisposable
-
public interface IClientCommandDispatcherFactory
-
public interface IPersistentChannel : IDisposable
-
public interface IPersistentChannelFactory
-
public interface IProducerConnection : IPersistentConnection, IDisposable
-
public interface IPublishConfirmationListener : IDisposable
-
public interface IPublishConfirmationWaiter
-
public interface IPublishExchangeDeclareStrategy
-
public interface IPubSub
-
public interface IReceiveRegistration
-
public interface IResponderConfiguration
-
public interface IRpc : IDisposable
-
public interface ISendReceive
-
public class PersistentChannel : IPersistentChannel, IDisposable
-
public class PersistentChannelFactory : IPersistentChannelFactory
-
public interface IPublishPendingConfirmation
-
public struct ProduceContext : IEquatable<ProduceContext>
- public ReadOnlyMemory<byte> Body { get; set; }
- public CancellationToken CancellationToken { get; set; }
- public string Exchange { get; set; }
- public bool Mandatory { get; set; }
- public MessageProperties Properties { get; set; }
- public string RoutingKey { get; set; }
- public IServiceResolver ServiceResolver { get; set; }
- public ProduceContext(ref string Exchange, ref string RoutingKey, ref bool Mandatory, ref MessageProperties Properties, ref ReadOnlyMemory Body, ref IServiceResolver ServiceResolver, ref CancellationToken CancellationToken)
- public static bool op_Equality(ProduceContext left, ProduceContext right)
- public static bool op_Inequality(ProduceContext left, ProduceContext right)
- public void Deconstruct(out string Exchange, out string RoutingKey, out bool Mandatory, out MessageProperties Properties, out ReadOnlyMemory Body, out IServiceResolver ServiceResolver, out CancellationToken CancellationToken)
- public bool Equals(ProduceContext other)
-
public sealed delegate ProduceDelegate : MulticastDelegate
-
public sealed class ProducePipelineBuilder
-
public sealed class ProducerConnection : PersistentConnection, IProducerConnection, IPersistentConnection, IDisposable
-
public class PublishConfirmationListener : IPublishConfirmationListener, IDisposable
-
public class PublishConfirmationWaiter : IPublishConfirmationWaiter
-
public class PublishExchangeDeclareStrategy : IPublishExchangeDeclareStrategy
-
public static class PublishExchangeDeclareStrategyExtensions
-
public class PublishInterruptedException : Exception
-
public class PublishNackedException : Exception
-
public static class PubSubExtensions
-
public static class ReceiveRegistrationExtensions
-
public class ResponderConfiguration : IResponderConfiguration
-
public static class RpcExtensions
-
public static class SendReceiveExtensions
-
public class PublishReturnedException : Exception
EasyNetQ.Scheduling
EasyNetQ.SystemMessages
EasyNetQ.Topology
Sprache