EasyNetQ by Mike Hadlow, Chris Edwards, A Hazelwood

<PackageReference Include="EasyNetQ" Version="0.10.0.84" />

---

API Diff between 0.10.0.84 and 0.9.0.42

54 Additions 11 Removals

EasyNetQ

• public class AutoSubscriber
  • protected const string DispatchMethodName = "Dispatch"
  • protected Func<Type, object> CreateConsumer { get; set; }
  • public IMessageDispatcher MessageDispatcher { get; set; }
  • protected virtual MethodInfo GetConsumeMethodFor(ConsumerInfo subscriptionInfo)
  • protected virtual ConsumerAttribute GetSubscriptionAttribute(MethodInfo consumeMethod)
  • protected virtual IEnumerable<KeyValuePair<Type, ConsumerInfo[]>> GetSubscriptionInfos(Type markerType, IEnumerable<Type> types)
  • protected virtual ConsumerAttribute GetSubscriptionAttribute(ConsumerInfo consumerInfo)
  • protected virtual IEnumerable<KeyValuePair<Type, ConsumerInfo[]>> GetSubscriptionInfos(IEnumerable<Type> types)
  • public virtual void Subscribe(Type markerType, Assembly[] assemblies)
• public class BinarySerializer : ISerializer
• public class ConnectionConfiguration : IConnectionConfiguration
  • public Uri AMQPConnectionString { get; set; }
• public class Conventions : IConventions
  • public ErrorExchangeNameConvention ErrorExchangeNamingConvention { get; set; }
  • public ErrorQueueNameConvention ErrorQueueNamingConvention { get; set; }
  • public RpcExchangeNameConvention RpcExchangeNamingConvention { get; set; }
  • public RpcRoutingKeyNamingConvention RpcRoutingKeyNamingConvention { get; set; }
• public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy, IDisposable
  • public const string EasyNetQErrorQueue = "EasyNetQ_Default_Error_Queue"
  • public const string ErrorExchangePrefix = "ErrorExchange_"
  • public DefaultConsumerErrorStrategy(IConnectionFactory connectionFactory, ISerializer serializer, IEasyNetQLogger logger)
  • public DefaultConsumerErrorStrategy(IConnectionFactory connectionFactory, ISerializer serializer, IEasyNetQLogger logger, IConventions conventions)
• public class DefaultMessageDispatcher : IMessageDispatcher
  • public DefaultMessageDispatcher()
  • public void Dispatch<TMessage, TConsumer>(TMessage message) where TConsumer : IConsume<TMessage>
• public sealed delegate ErrorExchangeNameConvention : MulticastDelegate
  • public ErrorExchangeNameConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(string originalRoutingKey, AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke(string originalRoutingKey)
• public sealed delegate ErrorQueueNameConvention : MulticastDelegate
  • public ErrorQueueNameConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke()
• public interface IConnectionConfiguration
  • Uri AMQPConnectionString { get; }
• public interface IConventions
  • ErrorExchangeNameConvention ErrorExchangeNamingConvention { get; set; }
  • ErrorQueueNameConvention ErrorQueueNamingConvention { get; set; }
  • RpcExchangeNameConvention RpcExchangeNamingConvention { get; set; }
  • RpcRoutingKeyNamingConvention RpcRoutingKeyNamingConvention { get; set; }
• public interface IMessageDispatcher
  • void Dispatch<TMessage, TConsumer>(TMessage message) where TConsumer : IConsume<TMessage>
• public interface IPublishChannel : IDisposable
  • 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 class PublisherConfirms : IPublisherConfirms
  • public int NumCallbacks { get; }
• public class QueueingConsumerFactory : IConsumerFactory, IDisposable
  • public Action SynchronisationAction { get; set; }
  • public void HandleMessageDelivery(BasicDeliverEventArgs basicDeliverEventArgs)
• public class RabbitBus : IBus, IDisposable
  • public const string RpcExchange = "easy_net_q_rpc"
• public class RabbitPublishChannel : IPublishChannel, IDisposable
  • public RabbitPublishChannel(RabbitBus bus, Action<IChannelConfiguration> configure)
  • public RabbitPublishChannel(RabbitBus bus, Action<IChannelConfiguration> configure, IConventions conventions)
  • 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 RpcExchangeNameConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke()
• public sealed delegate RpcRoutingKeyNamingConvention : MulticastDelegate
  • public RpcRoutingKeyNamingConvention(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(Type messageType, AsyncCallback callback, object object)
  • public virtual string EndInvoke(IAsyncResult result)
  • public virtual string Invoke(Type messageType)

EasyNetQ.ConnectionString

• public static class ConnectionStringGrammar
  • public static Parser<Uri> AMQP
  • public static Parser<Func<ConnectionConfiguration, ConnectionConfiguration>> AMQPAlone