Class BatchingRabbitTemplate

Namespace

Steeltoe.Messaging.RabbitMQ.Core

Assembly

Steeltoe.Messaging.RabbitMQ.dll

[Obsolete("This feature will be removed in the next major version. See https://steeltoe.io/docs/v3/obsolete for details.")]
public class BatchingRabbitTemplate : RabbitTemplate, IMessageSendingOperations<RabbitDestination>, IMessageReceivingOperations<RabbitDestination>, IMessageRequestReplyOperations<RabbitDestination>, IRabbitTemplate, IServiceNameAware, IMessageListener, IListenerContainerAware, IPublisherCallbackChannel.IListener, IDisposable

Inheritance

object

AbstractMessageSendingTemplate<RabbitDestination>

AbstractMessageReceivingTemplate<RabbitDestination>

AbstractMessagingTemplate<RabbitDestination>

RabbitTemplate

BatchingRabbitTemplate

Implements

IMessageSendingOperations<RabbitDestination>

IMessageReceivingOperations<RabbitDestination>

IMessageRequestReplyOperations<RabbitDestination>

IRabbitTemplate

IServiceNameAware

IMessageListener

IListenerContainerAware

IPublisherCallbackChannel.IListener

IDisposable

Inherited Members

RabbitTemplate.DEFAULT_SERVICE_NAME

RabbitTemplate._logger

RabbitTemplate.ConnectionFactory

RabbitTemplate.IsChannelTransacted

RabbitTemplate.RoutingKey

RabbitTemplate.Exchange

RabbitTemplate.DefaultReceiveQueue

RabbitTemplate.ContainerAckMode

RabbitTemplate.Encoding

RabbitTemplate.ReplyAddress

RabbitTemplate.ReceiveTimeout

RabbitTemplate.ReplyTimeout

RabbitTemplate.MessagePropertiesConverter

RabbitTemplate.ConfirmCallback

RabbitTemplate.ReturnCallback

RabbitTemplate.Mandatory

RabbitTemplate.MandatoryExpression

RabbitTemplate.MandatoryExpressionString

RabbitTemplate.SendConnectionFactorySelectorExpression

RabbitTemplate.ReceiveConnectionFactorySelectorExpression

RabbitTemplate.CorrelationKey

RabbitTemplate.EvaluationContext

RabbitTemplate.RetryTemplate

RabbitTemplate.RecoveryCallback

RabbitTemplate.BeforePublishPostProcessors

RabbitTemplate.AfterReceivePostProcessors

RabbitTemplate.CorrelationDataPostProcessor

RabbitTemplate.UseTemporaryReplyQueues

RabbitTemplate.UseDirectReplyToContainer

RabbitTemplate.UserIdExpression

RabbitTemplate.UserIdExpressionString

RabbitTemplate.ServiceName

RabbitTemplate.UserCorrelationId

RabbitTemplate.UsePublisherConnection

RabbitTemplate.NoLocalReplyConsumer

RabbitTemplate.ReplyErrorHandler

RabbitTemplate.IsRunning

RabbitTemplate.UUID

RabbitTemplate.IsConfirmListener

RabbitTemplate.IsReturnListener

RabbitTemplate.Options

RabbitTemplate.SetBeforePublishPostProcessors(params IMessagePostProcessor[])

RabbitTemplate.AddBeforePublishPostProcessors(params IMessagePostProcessor[])

RabbitTemplate.RemoveBeforePublishPostProcessor(IMessagePostProcessor)

RabbitTemplate.SetAfterReceivePostProcessors(params IMessagePostProcessor[])

RabbitTemplate.AddAfterReceivePostProcessors(params IMessagePostProcessor[])

RabbitTemplate.RemoveAfterReceivePostProcessor(IMessagePostProcessor)

RabbitTemplate.HandleConfirm(PendingConfirm, bool)

RabbitTemplate.HandleReturn(int, string, string, string, IBasicProperties, byte[])

RabbitTemplate.Revoke(IModel)

RabbitTemplate.OnMessageBatch(List<IMessage>)

RabbitTemplate.OnMessage(IMessage)

RabbitTemplate.GetExpectedQueueNames()

RabbitTemplate.Send(string, IMessage)

RabbitTemplate.Send(string, string, IMessage)

RabbitTemplate.SendAsync(string, IMessage, CancellationToken)

RabbitTemplate.SendAsync(string, string, IMessage, CancellationToken)

RabbitTemplate.SendAsync(string, string, IMessage, CorrelationData, CancellationToken)

RabbitTemplate.ConvertAndSend(object, IMessagePostProcessor)

RabbitTemplate.ConvertAndSend(object, IMessagePostProcessor, CorrelationData)

RabbitTemplate.ConvertAndSend(string, object)

RabbitTemplate.ConvertAndSend(string, object, CorrelationData)

RabbitTemplate.ConvertAndSend(string, object, IMessagePostProcessor)

RabbitTemplate.ConvertAndSend(string, object, IMessagePostProcessor, CorrelationData)

RabbitTemplate.ConvertAndSend(string, string, object)

RabbitTemplate.ConvertAndSend(string, string, object, CorrelationData)

RabbitTemplate.ConvertAndSend(string, string, object, IMessagePostProcessor)

RabbitTemplate.ConvertAndSend(string, string, object, IMessagePostProcessor, CorrelationData)

RabbitTemplate.ConvertAndSendAsync(object, IMessagePostProcessor, CancellationToken)

RabbitTemplate.ConvertAndSendAsync(object, IMessagePostProcessor, CorrelationData, CancellationToken)

RabbitTemplate.ConvertAndSendAsync(string, object, CancellationToken)

RabbitTemplate.ConvertAndSendAsync(string, object, CorrelationData, CancellationToken)

RabbitTemplate.ConvertAndSendAsync(string, object, IMessagePostProcessor, CancellationToken)

RabbitTemplate.ConvertAndSendAsync(string, object, IMessagePostProcessor, CorrelationData, CancellationToken)

RabbitTemplate.ConvertAndSendAsync(string, string, object, CancellationToken)

RabbitTemplate.ConvertAndSendAsync(string, string, object, CorrelationData, CancellationToken)

RabbitTemplate.ConvertAndSendAsync(string, string, object, IMessagePostProcessor, CancellationToken)

RabbitTemplate.ConvertAndSendAsync(string, string, object, IMessagePostProcessor, CorrelationData, CancellationToken)

RabbitTemplate.ReceiveAsync(string, CancellationToken)

RabbitTemplate.ReceiveAsync(int, CancellationToken)

RabbitTemplate.ReceiveAsync(string, int, CancellationToken)

RabbitTemplate.Receive(int)

RabbitTemplate.Receive(string)

RabbitTemplate.Receive(string, int)

RabbitTemplate.ReceiveAndConvert<T>(int)

RabbitTemplate.ReceiveAndConvert<T>(string)

RabbitTemplate.ReceiveAndConvert<T>(string, int)

RabbitTemplate.ReceiveAndConvert(Type)

RabbitTemplate.ReceiveAndConvert(string, Type)

RabbitTemplate.ReceiveAndConvert(int, Type)

RabbitTemplate.ReceiveAndConvert(string, int, Type)

RabbitTemplate.ReceiveAndConvertAsync<T>(int, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync<T>(string, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync<T>(string, int, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync(Type, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync(string, Type, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync(int, Type, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync(string, int, Type, CancellationToken)

RabbitTemplate.ReceiveAndReply<R, S>(Func<R, S>)

RabbitTemplate.ReceiveAndReply<R, S>(string, Func<R, S>)

RabbitTemplate.ReceiveAndReply<R, S>(Func<R, S>, string, string)

RabbitTemplate.ReceiveAndReply<R, S>(string, Func<R, S>, string, string)

RabbitTemplate.ReceiveAndReply<R, S>(Func<R, S>, Func<IMessage, S, Address>)

RabbitTemplate.ReceiveAndReply<R, S>(string, Func<R, S>, Func<IMessage, S, Address>)

RabbitTemplate.SendAndReceive(IMessage, CorrelationData)

RabbitTemplate.SendAndReceive(string, IMessage)

RabbitTemplate.SendAndReceive(string, IMessage, CorrelationData)

RabbitTemplate.SendAndReceive(string, string, IMessage)

RabbitTemplate.SendAndReceive(string, string, IMessage, CorrelationData)

RabbitTemplate.SendAndReceiveAsync(IMessage, CorrelationData, CancellationToken)

RabbitTemplate.SendAndReceiveAsync(string, IMessage, CancellationToken)

RabbitTemplate.SendAndReceiveAsync(string, IMessage, CorrelationData, CancellationToken)

RabbitTemplate.SendAndReceiveAsync(string, string, IMessage, CancellationToken)

RabbitTemplate.SendAndReceiveAsync(string, string, IMessage, CorrelationData, CancellationToken)

RabbitTemplate.ConvertSendAndReceive<T>(object, CorrelationData)

RabbitTemplate.ConvertSendAndReceive<T>(object, IMessagePostProcessor)

RabbitTemplate.ConvertSendAndReceive<T>(object, IMessagePostProcessor, CorrelationData)

RabbitTemplate.ConvertSendAndReceive<T>(string, object)

RabbitTemplate.ConvertSendAndReceive<T>(string, object, CorrelationData)

RabbitTemplate.ConvertSendAndReceive<T>(string, object, IMessagePostProcessor)

RabbitTemplate.ConvertSendAndReceive<T>(string, object, IMessagePostProcessor, CorrelationData)

RabbitTemplate.ConvertSendAndReceive<T>(string, string, object)

RabbitTemplate.ConvertSendAndReceive<T>(string, string, object, CorrelationData)

RabbitTemplate.ConvertSendAndReceive<T>(string, string, object, IMessagePostProcessor)

RabbitTemplate.ConvertSendAndReceive<T>(string, string, object, IMessagePostProcessor, CorrelationData)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(object, CorrelationData, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(object, IMessagePostProcessor, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(object, IMessagePostProcessor, CorrelationData, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(string, object, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(string, object, CorrelationData, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(string, object, IMessagePostProcessor, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(string, object, IMessagePostProcessor, CorrelationData, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(string, string, object, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(string, string, object, CorrelationData, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(string, string, object, IMessagePostProcessor, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsync<T>(string, string, object, IMessagePostProcessor, CorrelationData, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsType(object, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(object, CorrelationData, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(object, IMessagePostProcessor, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(object, IMessagePostProcessor, CorrelationData, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(string, object, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(string, object, CorrelationData, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(string, object, IMessagePostProcessor, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(string, object, IMessagePostProcessor, CorrelationData, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(string, string, object, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(string, string, object, CorrelationData, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(string, string, object, IMessagePostProcessor, Type)

RabbitTemplate.ConvertSendAndReceiveAsType(string, string, object, IMessagePostProcessor, CorrelationData, Type)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(object, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(object, CorrelationData, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(object, IMessagePostProcessor, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(object, IMessagePostProcessor, CorrelationData, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(string, object, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(string, object, CorrelationData, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(string, object, IMessagePostProcessor, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(string, object, IMessagePostProcessor, CorrelationData, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(string, string, object, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(string, string, object, CorrelationData, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(string, string, object, IMessagePostProcessor, Type, CancellationToken)

RabbitTemplate.ConvertSendAndReceiveAsTypeAsync(string, string, object, IMessagePostProcessor, CorrelationData, Type, CancellationToken)

RabbitTemplate.CorrelationConvertAndSend(object, CorrelationData)

RabbitTemplate.GetUnconfirmed(long)

RabbitTemplate.GetUnconfirmedCount()

RabbitTemplate.Execute(Action<IModel>)

RabbitTemplate.Execute<T>(Func<IModel, T>)

RabbitTemplate.AddListener(IModel)

RabbitTemplate.Invoke<T>(Func<IRabbitTemplate, T>)

RabbitTemplate.Invoke<T>(Func<IRabbitTemplate, T>, Action<object, BasicAckEventArgs>, Action<object, BasicNackEventArgs>)

RabbitTemplate.WaitForConfirms(int)

RabbitTemplate.WaitForConfirmsOrDie(int)

RabbitTemplate.DetermineConfirmsReturnsCapability(IConnectionFactory)

RabbitTemplate.IsMandatoryFor(IMessage)

RabbitTemplate.Dispose()

RabbitTemplate.Start()

RabbitTemplate.Stop()

RabbitTemplate.ConvertMessageIfNecessary(object)

RabbitTemplate.DoSendAndReceiveWithTemporary(string, string, IMessage, CorrelationData, CancellationToken)

RabbitTemplate.DoReceiveAndConvert(string, int, Type, CancellationToken)

RabbitTemplate.DoReceive(string, int, CancellationToken)

RabbitTemplate.DoReceive(RabbitDestination)

RabbitTemplate.DoReceiveAsync(RabbitDestination, CancellationToken)

RabbitTemplate.DoSendAsync(RabbitDestination, IMessage, CancellationToken)

RabbitTemplate.DoSendAndReceiveAsync(RabbitDestination, IMessage, CancellationToken)

RabbitTemplate.DoSendAndReceive(RabbitDestination, IMessage)

RabbitTemplate.DoSendAndReceive(string, string, IMessage, CorrelationData, CancellationToken)

RabbitTemplate.DoSendAndReceiveWithFixed(string, string, IMessage, CorrelationData, CancellationToken)

RabbitTemplate.DoSendAndReceiveWithDirect(string, string, IMessage, CorrelationData, CancellationToken)

RabbitTemplate.DoReceiveNoWait(string, CancellationToken)

RabbitTemplate.DoSend(IModel, string, string, IMessage, bool, CorrelationData, CancellationToken)

RabbitTemplate.DoSend(RabbitDestination, IMessage)

RabbitTemplate.SendToRabbit(IModel, string, string, bool, IMessage)

RabbitTemplate.IsChannelLocallyTransacted(IModel)

RabbitTemplate.CreateConnection()

RabbitTemplate.GetTransactionalResourceHolder()

RabbitTemplate.ConvertRabbitAccessException(Exception)

RabbitTemplate.ConvertSendAndReceiveRaw(string, string, object, IMessagePostProcessor, CorrelationData)

RabbitTemplate.GetDefaultExchange()

RabbitTemplate.GetDefaultRoutingKey()

RabbitTemplate.UseDirectReplyTo()

RabbitTemplate.ReplyTimedOut(string)

RabbitTemplate.DoStart()

RabbitTemplate.DoStop()

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceiveAsync<T>(object, CancellationToken)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceiveAsync<T>(RabbitDestination, object, CancellationToken)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceiveAsync<T>(RabbitDestination, object, IDictionary<string, object>, CancellationToken)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceiveAsync<T>(object, IMessagePostProcessor, CancellationToken)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceiveAsync<T>(RabbitDestination, object, IMessagePostProcessor, CancellationToken)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceiveAsync<T>(RabbitDestination, object, IDictionary<string, object>, IMessagePostProcessor, CancellationToken)

AbstractMessagingTemplate<RabbitDestination>.SendAndReceiveAsync(IMessage, CancellationToken)

AbstractMessagingTemplate<RabbitDestination>.SendAndReceiveAsync(RabbitDestination, IMessage, CancellationToken)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceive<T>(object)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceive<T>(RabbitDestination, object)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceive<T>(RabbitDestination, object, IDictionary<string, object>)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceive<T>(object, IMessagePostProcessor)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceive<T>(RabbitDestination, object, IMessagePostProcessor)

AbstractMessagingTemplate<RabbitDestination>.ConvertSendAndReceive<T>(RabbitDestination, object, IDictionary<string, object>, IMessagePostProcessor)

AbstractMessagingTemplate<RabbitDestination>.SendAndReceive(IMessage)

AbstractMessagingTemplate<RabbitDestination>.SendAndReceive(RabbitDestination, IMessage)

AbstractMessageReceivingTemplate<RabbitDestination>.DefaultReceiveDestination

AbstractMessageReceivingTemplate<RabbitDestination>.ThrowReceivedExceptions

AbstractMessageReceivingTemplate<RabbitDestination>.ReceiveAsync(CancellationToken)

AbstractMessageReceivingTemplate<RabbitDestination>.ReceiveAsync(RabbitDestination, CancellationToken)

AbstractMessageReceivingTemplate<RabbitDestination>.ReceiveAndConvertAsync<T>(CancellationToken)

AbstractMessageReceivingTemplate<RabbitDestination>.ReceiveAndConvertAsync<T>(RabbitDestination, CancellationToken)

AbstractMessageReceivingTemplate<RabbitDestination>.Receive()

AbstractMessageReceivingTemplate<RabbitDestination>.Receive(RabbitDestination)

AbstractMessageReceivingTemplate<RabbitDestination>.ReceiveAndConvert<T>()

AbstractMessageReceivingTemplate<RabbitDestination>.ReceiveAndConvert<T>(RabbitDestination)

AbstractMessageReceivingTemplate<RabbitDestination>.RequiredDefaultReceiveDestination

AbstractMessageReceivingTemplate<RabbitDestination>.DoConvert<T>(IMessage)

AbstractMessageSendingTemplate<RabbitDestination>.CONVERSION_HINT_HEADER

AbstractMessageSendingTemplate<RabbitDestination>.DefaultSendDestination

AbstractMessageSendingTemplate<RabbitDestination>.MessageConverter

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSendAsync(object, CancellationToken)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSendAsync(RabbitDestination, object, CancellationToken)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSendAsync(RabbitDestination, object, IDictionary<string, object>, CancellationToken)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSendAsync(object, IMessagePostProcessor, CancellationToken)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSendAsync(RabbitDestination, object, IMessagePostProcessor, CancellationToken)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSendAsync(RabbitDestination, object, IDictionary<string, object>, IMessagePostProcessor, CancellationToken)

AbstractMessageSendingTemplate<RabbitDestination>.SendAsync(IMessage, CancellationToken)

AbstractMessageSendingTemplate<RabbitDestination>.SendAsync(RabbitDestination, IMessage, CancellationToken)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSend(object)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSend(RabbitDestination, object)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSend(RabbitDestination, object, IDictionary<string, object>)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSend(object, IMessagePostProcessor)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSend(RabbitDestination, object, IMessagePostProcessor)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSend(RabbitDestination, object, IDictionary<string, object>, IMessagePostProcessor)

AbstractMessageSendingTemplate<RabbitDestination>.Send(IMessage)

AbstractMessageSendingTemplate<RabbitDestination>.Send(RabbitDestination, IMessage)

AbstractMessageSendingTemplate<RabbitDestination>.RequiredDefaultSendDestination

AbstractMessageSendingTemplate<RabbitDestination>.DoConvert(object, IDictionary<string, object>, IMessagePostProcessor)

AbstractMessageSendingTemplate<RabbitDestination>.ProcessHeadersToSend(IDictionary<string, object>)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

BatchingRabbitTemplate(IOptionsMonitor<RabbitOptions>, IConnectionFactory, ISmartMessageConverter, IBatchingStrategy, ILogger)

public BatchingRabbitTemplate(IOptionsMonitor<RabbitOptions> optionsMonitor, IConnectionFactory connectionFactory, ISmartMessageConverter messageConverter, IBatchingStrategy batchingStrategy, ILogger logger = null)

Parameters

optionsMonitor IOptionsMonitor<RabbitOptions>

connectionFactory IConnectionFactory

messageConverter ISmartMessageConverter

batchingStrategy IBatchingStrategy

logger ILogger

BatchingRabbitTemplate(IOptionsMonitor<RabbitOptions>, IConnectionFactory, IBatchingStrategy, ILogger)

public BatchingRabbitTemplate(IOptionsMonitor<RabbitOptions> optionsMonitor, IConnectionFactory connectionFactory, IBatchingStrategy batchingStrategy, ILogger logger = null)

Parameters

optionsMonitor IOptionsMonitor<RabbitOptions>

connectionFactory IConnectionFactory

batchingStrategy IBatchingStrategy

logger ILogger

BatchingRabbitTemplate(IBatchingStrategy)

public BatchingRabbitTemplate(IBatchingStrategy batchingStrategy)

Parameters

batchingStrategy IBatchingStrategy

BatchingRabbitTemplate(RabbitOptions, IConnectionFactory, ISmartMessageConverter, IBatchingStrategy, ILogger)

public BatchingRabbitTemplate(RabbitOptions options, IConnectionFactory connectionFactory, ISmartMessageConverter messageConverter, IBatchingStrategy batchingStrategy, ILogger logger = null)

Parameters

options RabbitOptions

connectionFactory IConnectionFactory

messageConverter ISmartMessageConverter

batchingStrategy IBatchingStrategy

logger ILogger

BatchingRabbitTemplate(RabbitOptions, IConnectionFactory, IBatchingStrategy, ILogger)

public BatchingRabbitTemplate(RabbitOptions options, IConnectionFactory connectionFactory, IBatchingStrategy batchingStrategy, ILogger logger = null)

Parameters

options RabbitOptions

connectionFactory IConnectionFactory

batchingStrategy IBatchingStrategy

logger ILogger

BatchingRabbitTemplate(IConnectionFactory, IBatchingStrategy)

public BatchingRabbitTemplate(IConnectionFactory connectionFactory, IBatchingStrategy batchingStrategy)

Parameters

connectionFactory IConnectionFactory

batchingStrategy IBatchingStrategy

Methods

Flush()

public void Flush()

FlushAsync(CancellationToken)

public Task FlushAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

Send(string, string, IMessage, CorrelationData)

public override void Send(string exchange, string routingKey, IMessage message, CorrelationData correlationData)

Parameters

exchange string

routingKey string

message IMessage

correlationData CorrelationData