API Diff between 8.0.0-beta10 and 7.5.4
202 Additions
96 Removals
EasyNetQ
-
public static class AdvancedBusExtensions
- 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 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)
- public static Task ExchangeDeleteAsync(this IAdvancedBus bus, Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public static void Publish(this IAdvancedBus bus, Exchange exchange, string routingKey, bool mandatory, MessageProperties messageProperties, ReadOnlyMemory<byte> body, CancellationToken cancellationToken = default)
- public static void Publish<T>(this IAdvancedBus bus, Exchange exchange, string routingKey, bool mandatory, IMessage<T> message, 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 struct ConsumedMessage : IEquatable<ConsumedMessage>
-
public class Conventions : IConventions
-
public class DeadLetterExchangeAndMessageTtlScheduler : IScheduler
-
public class DefaultExchangeDeclareStrategy : IExchangeDeclareStrategy
-
public class DefaultMessageSerializationStrategy : IMessageSerializationStrategy
-
public class DefaultPubSub : IPubSub
-
public class DefaultRpc : IRpc, IDisposable
- protected readonly IExchangeDeclareStrategy exchangeDeclareStrategy
- protected readonly IExchangeDeclareStrategy exchangeDeclareStrategy
- public DefaultRpc(ILogger<DefaultRpc> logger, ConnectionConfiguration configuration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITypeNameSerializer typeNameSerializer, ICorrelationIdGenerationStrategy correlationIdGenerationStrategy)
- public DefaultRpc(ILogger<DefaultRpc> logger, ConnectionConfiguration configuration, IAdvancedBus advancedBus, IEventBus eventBus, IConventions conventions, IExchangeDeclareStrategy exchangeDeclareStrategy, IMessageDeliveryModeStrategy messageDeliveryModeStrategy, ITypeNameSerializer typeNameSerializer, ICorrelationIdGenerationStrategy correlationIdGenerationStrategy)
-
public class DefaultTypeNameSerializer : ITypeNameSerializer
-
public static class DelayedExchangeExtensions
-
public sealed delegate ErrorExchangeRoutingKeyConvention : MulticastDelegate
-
public sealed delegate ErrorExchangeTypeConvention : MulticastDelegate
-
public sealed delegate ErrorQueueTypeConvention : MulticastDelegate
-
public sealed class ExchangeAttribute : Attribute
-
public static class ExchangeDeclareConfigurationExtensions
-
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; }
- Task<Binding<Queue>> BindAsync(Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task<Binding<Exchange>> BindAsync(Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task ExchangeBindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken = default)
- Task ExchangeDeleteAsync(Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- Task ExchangeDeleteAsync(string exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken = default)
- Task PublishAsync<T>(Exchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken = default)
- Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, MessageProperties properties, ReadOnlyMemory<byte> body, 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)
-
public interface IConventions
-
public interface IExchangeDeclareStrategy
-
public interface IMessageSerializationStrategy
-
public interface ITypeNameSerializer
-
public class LegacyTypeNameSerializer : ITypeNameSerializer
-
public class Message<T> : IMessage<T>, IMessage
-
public static class MessageFactory
-
public struct MessageProperties : IEquatable<MessageProperties>
-
public static class MessagePropertiesExtensions
-
public struct MessageReceivedInfo : IEquatable<MessageReceivedInfo>
-
public class MessageReturnedEventArgs : EventArgs
-
public struct ProducedMessage : IEquatable<ProducedMessage>
-
public struct PullResult : IPullResult, IDisposable
-
public sealed class QueueAttribute : Attribute
-
public static class QueueType
- public const string Stream = "stream"
-
public class RabbitAdvancedBus : IAdvancedBus, IDisposable
- public IServiceResolver Container { get; }
- public IConventions Conventions { get; }
- public RabbitAdvancedBus(ILogger<RabbitAdvancedBus> logger, IProducerConnection producerConnection, IConsumerConnection consumerConnection, IConsumerFactory consumerFactory, IPersistentChannelDispatcher persistentChannelDispatcher, IPublishConfirmationListener confirmationListener, IEventBus eventBus, IHandlerCollectionFactory handlerCollectionFactory, IServiceResolver container, ConnectionConfiguration configuration, IEnumerable<IProduceConsumeInterceptor> produceConsumeInterceptors, IMessageSerializationStrategy messageSerializationStrategy, IConventions conventions, IPullingConsumerFactory pullingConsumerFactory, AdvancedBusEventHandlers advancedBusEventHandlers, IConsumeScopeProvider consumeScopeProvider)
- public Task<Binding<Queue>> BindAsync(Exchange exchange, Queue queue, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public Task<Binding<Exchange>> BindAsync(Exchange source, Exchange destination, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- 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 virtual Task ExchangeBindAsync(string destinationExchange, string sourceExchange, string routingKey, IDictionary<string, object> arguments, CancellationToken cancellationToken)
- public virtual Task ExchangeDeleteAsync(Exchange exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public virtual Task ExchangeDeleteAsync(string exchange, bool ifUnused = false, CancellationToken cancellationToken = default)
- public virtual Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, IMessage message, CancellationToken cancellationToken)
- public virtual Task PublishAsync<T>(Exchange exchange, string routingKey, bool mandatory, IMessage<T> message, CancellationToken cancellationToken)
- public virtual Task PublishAsync(Exchange exchange, string routingKey, bool mandatory, MessageProperties properties, ReadOnlyMemory<byte> body, 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 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, TimeSpan 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 static class RpcExtensions
-
public sealed class SelfHostedBus : IBus, IDisposable
-
public struct SerializedMessage : IDisposable
-
public static class ServiceRegisterExtensions
EasyNetQ.ChannelDispatcher
EasyNetQ.Consumer
-
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 struct ConsumerExecutionContext
-
public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
-
public class DefaultConsumeErrorStrategy : IConsumeErrorStrategy
-
public class HandlerCollection : IHandlerCollection, IHandlerRegistration
-
public class HandlerRunner : IHandlerRunner, IDisposable
-
public interface IConsumeErrorStrategy
-
public interface IConsumerErrorStrategy : IDisposable
-
public interface IHandlerCollection : IHandlerRegistration
-
public interface IHandlerRunner : IDisposable
-
public class InternalConsumer : IInternalConsumer, IDisposable
-
public class InternalConsumerFactory : IInternalConsumerFactory
-
public class PerQueueConsumerConfiguration
- public ConsumeDelegate ConsumeDelegate { get; }
- public MessageHandler Handler { get; }
- public PerQueueConsumerConfiguration(bool autoAck, string consumerTag, bool isExclusive, IDictionary<string, object> arguments, MessageHandler handler)
- public PerQueueConsumerConfiguration(bool autoAck, string consumerTag, bool isExclusive, IDictionary<string, object> arguments, ConsumeDelegate consumeDelegate)
-
public class SimpleConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
-
public sealed class SimpleConsumeErrorStrategy : IConsumeErrorStrategy
EasyNetQ.DI
EasyNetQ.Events
EasyNetQ.Internals
EasyNetQ.Logging
EasyNetQ.MessageVersioning
EasyNetQ.Persistent
-
public struct ActionBasedPersistentChannelAction : IPersistentChannelAction<bool>
-
public interface IPersistentChannel : IDisposable
-
public class PersistentChannel : IPersistentChannel, IDisposable
- public PersistentChannel(ref PersistentChannelOptions options, IPersistentConnection connection, IEventBus eventBus)
- public PersistentChannel(ref PersistentChannelOptions options, IPersistentConnection connection, IEventBus eventBus, ILogger<PersistentChannel> logger)
- public PersistentChannel(ref PersistentChannelOptions options, ILogger<PersistentChannel> logger, IPersistentConnection connection, IEventBus eventBus)
- public Task<TResult> InvokeChannelActionAsync<TResult, TChannelAction>(TChannelAction channelAction, CancellationToken cancellationToken = default) where TChannelAction : struct, IPersistentChannelAction<TResult>
- public ValueTask<TResult> InvokeChannelActionAsync<TResult, TChannelAction>(TChannelAction channelAction, CancellationToken cancellationToken = default) where TChannelAction : struct, IPersistentChannelAction<TResult>
-
public class PersistentChannelFactory : IPersistentChannelFactory
EasyNetQ.Producer
-
public class DefaultExchangeDeclareStrategy : IExchangeDeclareStrategy
-
public interface IExchangeDeclareStrategy
-
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
EasyNetQ.SystemMessages
EasyNetQ.Topology