Class BatchingRabbitTemplate

Inheritance

System.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(IMessagePostProcessor[])

RabbitTemplate.AddBeforePublishPostProcessors(IMessagePostProcessor[])

RabbitTemplate.RemoveBeforePublishPostProcessor(IMessagePostProcessor)

RabbitTemplate.SetAfterReceivePostProcessors(IMessagePostProcessor[])

RabbitTemplate.AddAfterReceivePostProcessors(IMessagePostProcessor[])

RabbitTemplate.RemoveAfterReceivePostProcessor(IMessagePostProcessor)

RabbitTemplate.HandleConfirm(PendingConfirm, Boolean)

RabbitTemplate.HandleReturn(Int32, String, String, String, RabbitMQ.Client.IBasicProperties, Byte[])

RabbitTemplate.Revoke(RabbitMQ.Client.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(Int32, CancellationToken)

RabbitTemplate.ReceiveAsync(String, Int32, CancellationToken)

RabbitTemplate.Receive(Int32)

RabbitTemplate.Receive(String)

RabbitTemplate.Receive(String, Int32)

RabbitTemplate.ReceiveAndConvert<T>(Int32)

RabbitTemplate.ReceiveAndConvert<T>(String)

RabbitTemplate.ReceiveAndConvert<T>(String, Int32)

RabbitTemplate.ReceiveAndConvert(Type)

RabbitTemplate.ReceiveAndConvert(String, Type)

RabbitTemplate.ReceiveAndConvert(Int32, Type)

RabbitTemplate.ReceiveAndConvert(String, Int32, Type)

RabbitTemplate.ReceiveAndConvertAsync<T>(Int32, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync<T>(String, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync<T>(String, Int32, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync(Type, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync(String, Type, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync(Int32, Type, CancellationToken)

RabbitTemplate.ReceiveAndConvertAsync(String, Int32, 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(Int64)

RabbitTemplate.GetUnconfirmedCount()

RabbitTemplate.Execute(Action<RabbitMQ.Client.IModel>)

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

RabbitTemplate.AddListener(RabbitMQ.Client.IModel)

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

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

RabbitTemplate.WaitForConfirms(Int32)

RabbitTemplate.WaitForConfirmsOrDie(Int32)

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, Int32, Type, CancellationToken)

RabbitTemplate.DoReceive(String, Int32, 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(RabbitMQ.Client.IModel, String, String, IMessage, Boolean, CorrelationData, CancellationToken)

RabbitTemplate.DoSend(RabbitDestination, IMessage)

RabbitTemplate.SendToRabbit(RabbitMQ.Client.IModel, String, String, Boolean, IMessage)

RabbitTemplate.IsChannelLocallyTransacted(RabbitMQ.Client.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)

Steeltoe.Messaging.Core.AbstractMessagingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.ConvertSendAndReceiveAsync<T>(Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination, System.Object, IDictionary<, >, CancellationToken)

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

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

Steeltoe.Messaging.Core.AbstractMessagingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.ConvertSendAndReceiveAsync<T>(Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination, System.Object, IDictionary<, >, Steeltoe.Messaging.Core.IMessagePostProcessor, CancellationToken)

AbstractMessagingTemplate<RabbitDestination>.SendAndReceiveAsync(IMessage, CancellationToken)

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

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

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

Steeltoe.Messaging.Core.AbstractMessagingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.ConvertSendAndReceive<T>(Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination, System.Object, IDictionary<, >)

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

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

Steeltoe.Messaging.Core.AbstractMessagingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.ConvertSendAndReceive<T>(Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination, System.Object, IDictionary<, >, Steeltoe.Messaging.Core.IMessagePostProcessor)

AbstractMessagingTemplate<RabbitDestination>.SendAndReceive(IMessage)

AbstractMessagingTemplate<RabbitDestination>.SendAndReceive(RabbitDestination, IMessage)

AbstractMessagingTemplate<RabbitDestination>.DoSendAndReceive(RabbitDestination, IMessage)

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

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)

Steeltoe.Messaging.Core.AbstractMessageSendingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.ConvertAndSendAsync(Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination, System.Object, IDictionary<, >, CancellationToken)

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

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

Steeltoe.Messaging.Core.AbstractMessageSendingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.ConvertAndSendAsync(Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination, System.Object, IDictionary<, >, Steeltoe.Messaging.Core.IMessagePostProcessor, CancellationToken)

AbstractMessageSendingTemplate<RabbitDestination>.SendAsync(IMessage, CancellationToken)

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

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSend(Object)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSend(RabbitDestination, Object)

Steeltoe.Messaging.Core.AbstractMessageSendingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.ConvertAndSend(Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination, System.Object, IDictionary<, >)

AbstractMessageSendingTemplate<RabbitDestination>.ConvertAndSend(Object, IMessagePostProcessor)

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

Steeltoe.Messaging.Core.AbstractMessageSendingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.ConvertAndSend(Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination, System.Object, IDictionary<, >, Steeltoe.Messaging.Core.IMessagePostProcessor)

AbstractMessageSendingTemplate<RabbitDestination>.Send(IMessage)

AbstractMessageSendingTemplate<RabbitDestination>.Send(RabbitDestination, IMessage)

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

AbstractMessageSendingTemplate<RabbitDestination>.DoSend(RabbitDestination, IMessage)

AbstractMessageSendingTemplate<RabbitDestination>.RequiredDefaultSendDestination

Steeltoe.Messaging.Core.AbstractMessageSendingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.DoConvert(System.Object, IDictionary<, >, Steeltoe.Messaging.Core.IMessagePostProcessor)

Steeltoe.Messaging.Core.AbstractMessageSendingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.ProcessHeadersToSend(IDictionary<, >)

Namespace: Steeltoe.Messaging.RabbitMQ.Core

Assembly: Steeltoe.Messaging.RabbitMQ.dll

Syntax

public class BatchingRabbitTemplate : RabbitTemplate, IRabbitTemplate, IMessageListener, IListenerContainerAware, IPublisherCallbackChannel.IListener

Constructors

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

Declaration

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

Parameters

Type	Name	Description
IOptionsMonitor<RabbitOptions>	optionsMonitor
IConnectionFactory	connectionFactory
ISmartMessageConverter	messageConverter
IBatchingStrategy	batchingStrategy
ILogger	logger

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

Declaration

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

Parameters

Type	Name	Description
IOptionsMonitor<RabbitOptions>	optionsMonitor
IConnectionFactory	connectionFactory
IBatchingStrategy	batchingStrategy
ILogger	logger

BatchingRabbitTemplate(IBatchingStrategy)

Declaration

public BatchingRabbitTemplate(IBatchingStrategy batchingStrategy)

Parameters

Type	Name	Description
IBatchingStrategy	batchingStrategy

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

Declaration

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

Parameters

Type	Name	Description
RabbitOptions	options
IConnectionFactory	connectionFactory
ISmartMessageConverter	messageConverter
IBatchingStrategy	batchingStrategy
ILogger	logger

BatchingRabbitTemplate(RabbitOptions, IConnectionFactory, IBatchingStrategy, ILogger)

Declaration

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

Parameters

Type	Name	Description
RabbitOptions	options
IConnectionFactory	connectionFactory
IBatchingStrategy	batchingStrategy
ILogger	logger

BatchingRabbitTemplate(IConnectionFactory, IBatchingStrategy)

Declaration

public BatchingRabbitTemplate(IConnectionFactory connectionFactory, IBatchingStrategy batchingStrategy)

Parameters

Type	Name	Description
IConnectionFactory	connectionFactory
IBatchingStrategy	batchingStrategy

Methods

Flush()

Declaration

public void Flush()

FlushAsync(CancellationToken)

Declaration

public async Task FlushAsync(CancellationToken cancellationToken)

Parameters

Type	Name	Description
CancellationToken	cancellationToken

Returns

Type	Description
Task

Send(String, String, IMessage, CorrelationData)

Declaration

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

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
IMessage	message
CorrelationData	correlationData

Overrides

RabbitTemplate.Send(String, String, IMessage, CorrelationData)

Implements

IMessageSendingOperations<D>

IMessageReceivingOperations<D>

IMessageRequestReplyOperations<D>

IRabbitTemplate

IServiceNameAware

IMessageListener

IListenerContainerAware

IPublisherCallbackChannel.IListener

IDisposable