API Diff between 0.10.0.84 and 3.5.0-alpha0013
435 Additions
437 Removals
EasyNetQ
-
public class AdvancedBusEventHandlers
-
public static class AdvancedBusExtensions
-
public class BasicGetResult : IBasicGetResult
-
public class BasicGetResult<T> : IBasicGetResult<T>
-
public class AutoSubscriber
-
public static class BusExtensions
-
public class ComponentRegistration
-
public class ConcurrentHashSet<T> : ISet<T>, ICollection<T>, IEnumerable<T>, IEnumerable
-
public class ConnectionConfiguration : IConnectionConfiguration
-
public class ConnectionFactoryInfo
-
public class ConnectionFactoryWrapper : IConnectionFactory
-
public sealed delegate ConsumerTagConvention : MulticastDelegate
-
public class ConsumerAttribute : Attribute
-
public class ConsumerInfo
-
public class Conventions : IConventions
-
public class DefaultCorrelationIdGenerationStrategy : ICorrelationIdGenerationStrategy
-
public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
-
public class DefaultTypeNameSerializer : ITypeNameSerializer
-
public class DeliveryModeAttribute : Attribute
-
public class CorrelationIdGenerator
-
public class DefaultClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
-
public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
-
public class DefaultMessageDispatcher : IMessageDispatcher
-
public class DefaultServiceProvider : IServiceProvider, IServiceRegister
-
public class EasyNetQConsumer : DefaultBasicConsumer
-
public class EasyNetQException : Exception
-
public class EasyNetQResponderException : EasyNetQException
-
public class EasyNetQInvalidMessageTypeException : EasyNetQException
-
public sealed delegate ErrorExchangeNameConvention : MulticastDelegate
-
public sealed delegate ErrorQueueNameConvention : MulticastDelegate
-
public class EventBus : IEventBus
-
public static class Extensions
-
public class HostConfiguration : IHostConfiguration
-
public interface IAdvancedBus : IDisposable
- IServiceResolver Container { get; }
- IConventions Conventions { get; }
- event EventHandler<ConnectionBlockedEventArgs> Blocked
- event EventHandler Connected
- event EventHandler Disconnected
- event EventHandler<MessageReturnedEventArgs> MessageReturned
- 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)
- ISerializer Serializer { get; }
- SerializeType SerializeType { get; }
- event Action Connected
- event Action Disconnected
- IAdvancedPublishChannel OpenPublishChannel()
- IAdvancedPublishChannel OpenPublishChannel(Action<IChannelConfiguration> configure)
- void Subscribe<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
- void Subscribe(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
-
public interface IBasicGetResult
-
public interface IBasicGetResult<T>
-
public interface IAdvancedPublishChannel : IDisposable
- void Publish<T>(IExchange exchange, string routingKey, IMessage<T> message, Action<IAdvancedPublishConfiguration> configure)
- void Publish(IExchange exchange, string routingKey, MessageProperties properties, byte[] messageBody, Action<IAdvancedPublishConfiguration> configure)
- void Publish<T>(IExchange exchange, string routingKey, IMessage<T> message)
- void Publish(IExchange exchange, string routingKey, MessageProperties properties, byte[] messageBody)
-
public interface IBus : IDisposable
- IPubSub PubSub { get; }
- IRpc Rpc { get; }
- IScheduler Scheduler { get; }
- ISendReceive SendReceive { get; }
- bool IsConnected { get; }
- event Action Connected
- event Action Disconnected
- IPublishChannel OpenPublishChannel()
- IPublishChannel OpenPublishChannel(Action<IChannelConfiguration> configure)
- void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder)
- void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, IDictionary<string, object> arguments)
- void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder)
- void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, IDictionary<string, object> arguments)
- void Subscribe<T>(string subscriptionId, Action<T> onMessage)
- void Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration<T>> configure)
- void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration<T>> configure)
-
public interface IConnectionConfiguration
-
public interface IConnectionFactory
-
public interface IConsume<T>
-
public interface IConsumerErrorStrategy : IDisposable
-
public interface IConsumerFactory : IDisposable
-
public interface IConventions
-
public interface ICorrelationIdGenerationStrategy
-
public interface IEventBus
-
public interface IMessage
-
public interface IEasyNetQLogger
-
public interface IHostConfiguration
- string Host { get; }
- ushort Port { get; }
-
public interface IMessage<T>
-
public interface IMessageDeliveryModeStrategy
-
public interface IMessageSerializationStrategy
-
public interface IMessageDispatcher
- void Dispatch<TMessage, TConsumer>(TMessage message) where TConsumer : IConsume<TMessage>
-
public interface IPersistentConnection : IDisposable
-
public interface IPersistentConnectionFactory
-
public interface IPublishChannel : IDisposable
- IBus Bus { get; }
- void Publish<T>(T message)
- void Publish<T>(T message, Action<IPublishConfiguration<T>> configure)
- void Request<TRequest, TResponse>(TRequest request, Action<TResponse> onResponse)
- void Request<TRequest, TResponse>(TRequest request, Action<TResponse> onResponse, IDictionary<string, object> arguments)
- Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request)
- Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, IDictionary<string, object> arguments)
- Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, CancellationToken token)
- Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, IDictionary<string, object> arguments, CancellationToken token)
-
public interface IPublisherConfirms
-
public interface ISaga
-
public interface ISerializer
-
public interface ISubscriptionResult : IDisposable
-
public interface ITimeoutStrategy
-
public interface ITypeNameSerializer
-
public interface IServiceProvider
-
public interface IServiceRegister
-
public class JsonSerializer : ISerializer
-
public class LegacyTypeNameSerializer : ITypeNameSerializer
-
public static class LegacyTypeNamingExtensions
-
public static class LinqExtensions
-
public class Message<T> : IMessage<T>
-
public static class MessageDeliveryMode
-
public class MessageDeliveryModeStrategy : IMessageDeliveryModeStrategy
-
public static class MessageFactory
-
public class MessageNotAvailableException : Exception
-
public sealed delegate MessageCallback : MulticastDelegate
- public MessageCallback(object object, IntPtr method)
- public virtual IAsyncResult BeginInvoke(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body, AsyncCallback callback, object object)
- public virtual Task EndInvoke(IAsyncResult result)
- public virtual Task Invoke(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)
-
public class MessageProperties
-
public class MessageReceivedInfo
- public string Queue { get; set; }
- public MessageReceivedInfo(string consumerTag, ulong deliverTag, bool redelivered, string exchange, string routingKey, string queue)
-
public class MessageReturnedEventArgs : EventArgs
-
public class MessageReturnedInfo
-
public class OrderedClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
-
public class PersistentConnection : IPersistentConnection, IDisposable
-
public class PersistentConnectionFactory : IPersistentConnectionFactory
-
public class QueueAttribute : Attribute
-
public class QueueConsumerPair
-
public enum PostExceptionAckStrategy
-
public class PublisherConfirms : IPublisherConfirms
-
public class QueueingConsumerFactory : IConsumerFactory, IDisposable
-
public class RabbitAdvancedBus : IAdvancedBus, IDisposable
- public IServiceResolver Container { get; }
- public const bool NoAck = false
- public IPersistentConnection Connection { get; }
- public IConsumerFactory ConsumerFactory { get; }
- public Func<string> GetCorrelationId { 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, 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 IEasyNetQLogger Logger { get; }
- public virtual ISerializer Serializer { get; }
- public virtual SerializeType SerializeType { get; }
- public event Action Connected
- public event Action Disconnected
- public RabbitAdvancedBus(IConnectionConfiguration connectionConfiguration, IConnectionFactory connectionFactory, SerializeType serializeType, ISerializer serializer, IConsumerFactory consumerFactory, IEasyNetQLogger logger, Func<string> getCorrelationId, IConventions conventions)
- public 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 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 IAdvancedPublishChannel OpenPublishChannel()
- public virtual IAdvancedPublishChannel OpenPublishChannel(Action<IChannelConfiguration> configure)
- public virtual void Subscribe<T>(IQueue queue, Func<IMessage<T>, MessageReceivedInfo, Task> onMessage)
- public virtual void Subscribe(IQueue queue, Func<byte[], MessageProperties, MessageReceivedInfo, Task> onMessage)
-
public class RabbitAdvancedPublishChannel : IAdvancedPublishChannel, IDisposable
- public RabbitAdvancedPublishChannel(RabbitAdvancedBus advancedBus, Action<IChannelConfiguration> configure)
- public virtual void Dispose()
- public virtual void Publish<T>(IExchange exchange, string routingKey, IMessage<T> message, Action<IAdvancedPublishConfiguration> configure)
- public virtual void Publish(IExchange exchange, string routingKey, MessageProperties properties, byte[] messageBody, Action<IAdvancedPublishConfiguration> configure)
- public virtual void Publish<T>(IExchange exchange, string routingKey, IMessage<T> message)
- public virtual void Publish(IExchange exchange, string routingKey, MessageProperties properties, byte[] messageBody)
-
public class RabbitBus : IBus, IDisposable
- public IPubSub PubSub { get; }
- public IRpc Rpc { get; }
- public IScheduler Scheduler { get; }
- public ISendReceive SendReceive { get; }
- public RabbitBus(IAdvancedBus advanced, IPubSub pubSub, IRpc rpc, ISendReceive sendReceive, IScheduler scheduler)
- public IConventions Conventions { get; }
- public virtual bool IsConnected { get; }
- public IEasyNetQLogger Logger { get; }
- public SerializeType SerializeType { get; }
- public event Action Connected
- public event Action Disconnected
- public RabbitBus(SerializeType serializeType, IEasyNetQLogger logger, IConventions conventions, IAdvancedBus advancedBus)
- protected void OnConnected()
- protected void OnDisconnected()
- public virtual IPublishChannel OpenPublishChannel()
- public virtual IPublishChannel OpenPublishChannel(Action<IChannelConfiguration> configure)
- public virtual void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder)
- public virtual void Respond<TRequest, TResponse>(Func<TRequest, TResponse> responder, IDictionary<string, object> arguments)
- public virtual void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder)
- public virtual void RespondAsync<TRequest, TResponse>(Func<TRequest, Task<TResponse>> responder, IDictionary<string, object> arguments)
- public virtual void Subscribe<T>(string subscriptionId, Action<T> onMessage)
- public virtual void Subscribe<T>(string subscriptionId, Action<T> onMessage, Action<ISubscriptionConfiguration<T>> configure)
- public virtual void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage)
- public virtual void SubscribeAsync<T>(string subscriptionId, Func<T, Task> onMessage, Action<ISubscriptionConfiguration<T>> configure)
-
public static class RabbitHutch
- public static IBus CreateBus(string connectionString, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, ushort requestedHeartbeat, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(ConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory, Action<IServiceRegister> registerServices)
- public static void RegisterBus(IServiceRegister serviceRegister, Func<IServiceResolver, ConnectionConfiguration> connectionConfigurationFactory, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(string connectionString, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(string hostName, ushort hostPort, string virtualHost, string username, string password, ushort requestedHeartbeat, Action<IServiceRegister> registerServices)
- public static IBus CreateBus(IConnectionConfiguration connectionConfiguration, Action<IServiceRegister> registerServices)
- public static IBus CreateBus()
-
public class RandomClusterHostSelectionStrategy<T> : IClusterHostSelectionStrategy<T>, IEnumerable<T>, IEnumerable
-
public static class ReflectionHelpers
-
public class RabbitPublishChannel : IPublishChannel, IDisposable
- public IAdvancedBus AdvancedBus { get; }
- public IAdvancedPublishChannel AdvancedPublishChannel { get; }
- public virtual IBus Bus { get; }
- public RabbitPublishChannel(RabbitBus bus, Action<IChannelConfiguration> configure, IConventions conventions)
- public void Dispose()
- public virtual void Publish<T>(T message)
- public virtual void Publish<T>(T message, Action<IPublishConfiguration<T>> configure)
- public virtual void Request<TRequest, TResponse>(TRequest request, Action<TResponse> onResponse)
- public void Request<TRequest, TResponse>(TRequest request, Action<TResponse> onResponse, IDictionary<string, object> arguments)
- public Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request)
- public Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, IDictionary<string, object> arguments)
- public Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, CancellationToken token)
- public Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest request, IDictionary<string, object> arguments, CancellationToken token)
-
public sealed delegate RpcExchangeNameConvention : MulticastDelegate
-
public sealed delegate RpcReturnQueueNamingConvention : MulticastDelegate
-
public class SerializedMessage
-
public sealed class SubscriptionResult : ISubscriptionResult, IDisposable
-
public sealed delegate SerializeType : MulticastDelegate
-
public class SubscriptionAction
-
public class SubscriptionInfo
-
public sealed delegate SubsriberNameFromDelegate : MulticastDelegate
-
public sealed class TimeBudget
-
public class TimeoutSecondsAttribute : Attribute
-
public class TimeoutStrategy : ITimeoutStrategy
-
public class TypeNameSerializer
EasyNetQ.AmqpExceptions
EasyNetQ.AutoSubscribe
EasyNetQ.ConnectionString
EasyNetQ.Consumer
-
public static class AckStrategies
-
public sealed delegate AckStrategy : MulticastDelegate
-
public class Base64ErrorMessageSerializer : IErrorMessageSerializer
-
public class BasicConsumer : IBasicConsumer, IDisposable
-
public class ConsumerCancellation : IDisposable
-
public class ConsumerConfiguration : IConsumerConfiguration
-
public class ConsumerDispatcher : IConsumerDispatcher, IDisposable
-
public class ConsumerDispatcherFactory : IConsumerDispatcherFactory, IDisposable
-
public class ConsumerExecutionContext
-
public class ConsumerFactory : IConsumerFactory, IDisposable
-
public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
-
public class DefaultErrorMessageSerializer : IErrorMessageSerializer
-
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 IConsumer : IDisposable
-
public interface IConsumerConfiguration
-
public interface IConsumerDispatcher : IDisposable
-
public interface IConsumerDispatcherFactory : IDisposable
-
public interface IConsumerErrorStrategy : IDisposable
-
public interface IConsumerFactory : IDisposable
-
public interface IErrorMessageSerializer
-
public interface IHandlerCollection : IHandlerRegistration
-
public interface IHandlerCollectionFactory
-
public interface IHandlerRegistration
-
public interface IHandlerRunner : IDisposable
-
public interface IInternalConsumer : IDisposable
-
public interface IInternalConsumerFactory : IDisposable
-
public class InternalConsumer : IInternalConsumer, IDisposable
-
public class InternalConsumerFactory : IInternalConsumerFactory, IDisposable
-
public class PersistentConsumer : IConsumer, IDisposable
-
public class PersistentMultipleConsumer : IConsumer, IDisposable
-
public enum StartConsumingStatus
-
public class TransientConsumer : IConsumer, IDisposable
EasyNetQ.DI
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.Loggers
EasyNetQ.Logging
EasyNetQ.Logging.LogProviders
EasyNetQ.MessageVersioning
EasyNetQ.MultipleExchange
EasyNetQ.Producer
EasyNetQ.Scheduling
EasyNetQ.SystemMessages
EasyNetQ.Topology
-
public class Binding : IBinding, ITopology
-
public class DefaultExchange : Exchange
-
public class Exchange : IExchange, IBindable, ITopology
- protected readonly IList<IBinding> bindings
- public IDictionary Arguments { get; }
- public bool AutoDelete { get; }
- public string ExchangeType { get; }
- public Exchange(string name)
- protected Exchange(string name, string exchangeType)
- protected Exchange(string name, string exchangeType, bool autoDelete, IDictionary arguments)
- public static IExchange DeclareDirect(string exchangeName)
- public static IExchange DeclareDirect(string exchangeName, bool autoDelete, IDictionary arguments)
- public static IExchange DeclareFanout(string exchangeName)
- public static IExchange DeclareFanout(string exchangeName, bool autoDelete, IDictionary arguments)
- public static IExchange DeclareTopic(string exchangeName)
- public static IExchange DeclareTopic(string exchangeName, bool autoDelete, IDictionary arguments)
- public virtual void BindTo(IExchange exchange, string[] routingKeys)
- public virtual void Visit(ITopologyVisitor visitor)
-
public class ExchangeType
-
public interface IBindable : ITopology
-
public interface IBinding : ITopology
-
public interface IQueue : IBindable, ITopology
-
public interface ITopology
-
public interface ITopologyVisitor
- void CreateBinding(IBindable bindable, IExchange exchange, string[] routingKeys)
- void CreateExchange(string exchangeName, string exchangeType, bool autoDelete, IDictionary arguments)
- void CreateQueue(string queueName, bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
- string CreateQueue()
-
public class Queue : IQueue, IBindable, ITopology
- public bool IsExclusive { get; }
- public bool IsSingleUse { get; }
- public Queue(string name, bool isExclusive)
- protected Queue(bool durable, bool exclusive, bool autoDelete, string name, IDictionary<string, object> arguements)
- protected Queue(bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
- public static IQueue Declare(bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
- public static IQueue Declare(bool durable, bool exclusive, bool autoDelete, string name, IDictionary<string, object> arguments)
- public static IQueue DeclareDurable(string queueName)
- public static IQueue DeclareDurable(string queueName, IDictionary<string, object> arguments)
- public static IQueue DeclareTransient(string queueName)
- public static IQueue DeclareTransient(string queueName, IDictionary<string, object> arguments)
- public static IQueue DeclareTransient()
- public void BindTo(IExchange exchange, string[] routingKeys)
- public IQueue SetAsSingleUse()
- public void Visit(ITopologyVisitor visitor)
-
public class TopologyBuilder : ITopologyVisitor
- public TopologyBuilder(IModel model)
- public void CreateBinding(IBindable bindable, IExchange exchange, string[] routingKeys)
- public void CreateExchange(string exchangeName, string exchangeType, bool autoDelete, IDictionary arguments)
- public void CreateQueue(string queueName, bool durable, bool exclusive, bool autoDelete, IDictionary<string, object> arguments)
- public string CreateQueue()
Sprache
-
public static class Parse