Class RabbitTemplate

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)

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)

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)

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)

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 RabbitTemplate : AbstractMessagingTemplate<RabbitDestination>, IRabbitTemplate, IMessageListener, IListenerContainerAware, IPublisherCallbackChannel.IListener

Constructors

| Edit this page View Source

RabbitTemplate(ILogger)

Declaration

public RabbitTemplate(ILogger logger = null)

Parameters

Type	Name	Description
ILogger	logger

| Edit this page View Source

RabbitTemplate(IOptionsMonitor<RabbitOptions>, IConnectionFactory, ILogger)

Declaration

public RabbitTemplate(IOptionsMonitor<RabbitOptions> optionsMonitor, IConnectionFactory connectionFactory, ILogger logger = null)

Parameters

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

| Edit this page View Source

RabbitTemplate(IOptionsMonitor<RabbitOptions>, IConnectionFactory, ISmartMessageConverter, ILogger)

Declaration

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

Parameters

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

| Edit this page View Source

RabbitTemplate(RabbitOptions, IConnectionFactory, ILogger)

Declaration

public RabbitTemplate(RabbitOptions options, IConnectionFactory connectionFactory, ILogger logger = null)

Parameters

Type	Name	Description
RabbitOptions	options
IConnectionFactory	connectionFactory
ILogger	logger

| Edit this page View Source

RabbitTemplate(RabbitOptions, IConnectionFactory, ISmartMessageConverter, ILogger)

Declaration

public RabbitTemplate(RabbitOptions options, IConnectionFactory connectionFactory, ISmartMessageConverter messageConverter, ILogger logger = null)

Parameters

Type	Name	Description
RabbitOptions	options
IConnectionFactory	connectionFactory
ISmartMessageConverter	messageConverter
ILogger	logger

| Edit this page View Source

RabbitTemplate(IConnectionFactory, ILogger)

Declaration

public RabbitTemplate(IConnectionFactory connectionFactory, ILogger logger = null)

Parameters

Type	Name	Description
IConnectionFactory	connectionFactory
ILogger	logger

Fields

| Edit this page View Source

_logger

Declaration

protected readonly ILogger _logger

Field Value

Type	Description
ILogger

| Edit this page View Source

DEFAULT_SERVICE_NAME

Declaration

public const string DEFAULT_SERVICE_NAME = null

Field Value

Type	Description
System.String

Properties

| Edit this page View Source

AfterReceivePostProcessors

Declaration

public virtual IList<IMessagePostProcessor> AfterReceivePostProcessors { get; }

Property Value

Type	Description
IList<IMessagePostProcessor>

| Edit this page View Source

BeforePublishPostProcessors

Declaration

public virtual IList<IMessagePostProcessor> BeforePublishPostProcessors { get; }

Property Value

Type	Description
IList<IMessagePostProcessor>

| Edit this page View Source

ConfirmCallback

Declaration

public virtual RabbitTemplate.IConfirmCallback ConfirmCallback { get; set; }

Property Value

Type	Description
RabbitTemplate.IConfirmCallback

| Edit this page View Source

ConnectionFactory

Declaration

public virtual IConnectionFactory ConnectionFactory { get; set; }

Property Value

Type	Description
IConnectionFactory

| Edit this page View Source

ContainerAckMode

Declaration

public virtual AcknowledgeMode ContainerAckMode { get; set; }

Property Value

Type	Description
AcknowledgeMode

| Edit this page View Source

CorrelationDataPostProcessor

Declaration

public virtual ICorrelationDataPostProcessor CorrelationDataPostProcessor { get; set; }

Property Value

Type	Description
ICorrelationDataPostProcessor

| Edit this page View Source

CorrelationKey

Declaration

public virtual string CorrelationKey { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

DefaultReceiveQueue

Declaration

public virtual string DefaultReceiveQueue { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

Encoding

Declaration

public virtual Encoding Encoding { get; set; }

Property Value

Type	Description
Encoding

| Edit this page View Source

EvaluationContext

Declaration

public virtual IEvaluationContext EvaluationContext { get; set; }

Property Value

Type	Description
IEvaluationContext

| Edit this page View Source

Exchange

Declaration

public virtual string Exchange { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

IsChannelTransacted

Declaration

public virtual bool IsChannelTransacted { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

IsConfirmListener

Declaration

public virtual bool IsConfirmListener { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

IsReturnListener

Declaration

public virtual bool IsReturnListener { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

IsRunning

Declaration

public virtual bool IsRunning { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

Mandatory

Declaration

public virtual bool Mandatory { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

MandatoryExpression

Declaration

public virtual IExpression MandatoryExpression { get; set; }

Property Value

Type	Description
IExpression

| Edit this page View Source

MandatoryExpressionString

Declaration

public virtual string MandatoryExpressionString { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

MessagePropertiesConverter

Declaration

public virtual IMessageHeadersConverter MessagePropertiesConverter { get; set; }

Property Value

Type	Description
IMessageHeadersConverter

| Edit this page View Source

NoLocalReplyConsumer

Declaration

public virtual bool NoLocalReplyConsumer { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

Options

Declaration

protected RabbitOptions Options { get; }

Property Value

Type	Description
RabbitOptions

| Edit this page View Source

ReceiveConnectionFactorySelectorExpression

Declaration

public virtual IExpression ReceiveConnectionFactorySelectorExpression { get; set; }

Property Value

Type	Description
IExpression

| Edit this page View Source

ReceiveTimeout

Declaration

public virtual int ReceiveTimeout { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

RecoveryCallback

Declaration

public virtual IRecoveryCallback RecoveryCallback { get; set; }

Property Value

Type	Description
IRecoveryCallback

| Edit this page View Source

ReplyAddress

Declaration

public virtual string ReplyAddress { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

ReplyErrorHandler

Declaration

public virtual IErrorHandler ReplyErrorHandler { get; set; }

Property Value

Type	Description
IErrorHandler

| Edit this page View Source

ReplyTimeout

Declaration

public virtual int ReplyTimeout { get; set; }

Property Value

Type	Description
System.Int32

| Edit this page View Source

RetryTemplate

Declaration

public virtual IRetryOperation RetryTemplate { get; set; }

Property Value

Type	Description
IRetryOperation

| Edit this page View Source

ReturnCallback

Declaration

public virtual RabbitTemplate.IReturnCallback ReturnCallback { get; set; }

Property Value

Type	Description
RabbitTemplate.IReturnCallback

| Edit this page View Source

RoutingKey

Declaration

public virtual string RoutingKey { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

SendConnectionFactorySelectorExpression

Declaration

public virtual IExpression SendConnectionFactorySelectorExpression { get; set; }

Property Value

Type	Description
IExpression

| Edit this page View Source

ServiceName

Declaration

public virtual string ServiceName { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

UseDirectReplyToContainer

Declaration

public virtual bool UseDirectReplyToContainer { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

UsePublisherConnection

Declaration

public virtual bool UsePublisherConnection { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

UserCorrelationId

Declaration

public virtual bool UserCorrelationId { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

UserIdExpression

Declaration

public virtual IExpression UserIdExpression { get; set; }

Property Value

Type	Description
IExpression

| Edit this page View Source

UserIdExpressionString

Declaration

public virtual string UserIdExpressionString { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

UseTemporaryReplyQueues

Declaration

public virtual bool UseTemporaryReplyQueues { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

UUID

Declaration

public virtual string UUID { get; }

Property Value

Type	Description
System.String

Methods

| Edit this page View Source

AddAfterReceivePostProcessors(IMessagePostProcessor[])

Declaration

public virtual void AddAfterReceivePostProcessors(params IMessagePostProcessor[] afterReceivePostProcessors)

Parameters

Type	Name	Description
IMessagePostProcessor[]	afterReceivePostProcessors

| Edit this page View Source

AddBeforePublishPostProcessors(IMessagePostProcessor[])

Declaration

public virtual void AddBeforePublishPostProcessors(params IMessagePostProcessor[] beforePublishPostProcessors)

Parameters

Type	Name	Description
IMessagePostProcessor[]	beforePublishPostProcessors

| Edit this page View Source

AddListener(RabbitMQ.Client.IModel)

Declaration

public virtual void AddListener(RabbitMQ.Client.IModel channel)

Parameters

Type	Name	Description
RabbitMQ.Client.IModel	channel

| Edit this page View Source

ConvertAndSend(Object, IMessagePostProcessor)

Declaration

public virtual void ConvertAndSend(object message, IMessagePostProcessor messagePostProcessor)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor

| Edit this page View Source

ConvertAndSend(Object, IMessagePostProcessor, CorrelationData)

Declaration

public virtual void ConvertAndSend(object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData

| Edit this page View Source

ConvertAndSend(String, Object)

Declaration

public virtual void ConvertAndSend(string routingKey, object message)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message

| Edit this page View Source

ConvertAndSend(String, Object, CorrelationData)

Declaration

public virtual void ConvertAndSend(string routingKey, object message, CorrelationData correlationData)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
CorrelationData	correlationData

| Edit this page View Source

ConvertAndSend(String, Object, IMessagePostProcessor)

Declaration

public virtual void ConvertAndSend(string routingKey, object message, IMessagePostProcessor messagePostProcessor)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor

| Edit this page View Source

ConvertAndSend(String, Object, IMessagePostProcessor, CorrelationData)

Declaration

public virtual void ConvertAndSend(string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData

| Edit this page View Source

ConvertAndSend(String, String, Object)

Declaration

public virtual void ConvertAndSend(string exchange, string routingKey, object message)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message

| Edit this page View Source

ConvertAndSend(String, String, Object, CorrelationData)

Declaration

public virtual void ConvertAndSend(string exchange, string routingKey, object message, CorrelationData correlationData)

Parameters

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

| Edit this page View Source

ConvertAndSend(String, String, Object, IMessagePostProcessor)

Declaration

public virtual void ConvertAndSend(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor

| Edit this page View Source

ConvertAndSend(String, String, Object, IMessagePostProcessor, CorrelationData)

Declaration

public virtual void ConvertAndSend(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData

| Edit this page View Source

ConvertAndSendAsync(Object, IMessagePostProcessor, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(object message, IMessagePostProcessor messagePostProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(Object, IMessagePostProcessor, CorrelationData, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(String, Object, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(string routingKey, object message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(String, Object, CorrelationData, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(string routingKey, object message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(String, Object, IMessagePostProcessor, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(string routingKey, object message, IMessagePostProcessor messagePostProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(String, Object, IMessagePostProcessor, CorrelationData, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(String, String, Object, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(string exchange, string routingKey, object message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(String, String, Object, CorrelationData, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(string exchange, string routingKey, object message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(String, String, Object, IMessagePostProcessor, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(String, String, Object, IMessagePostProcessor, CorrelationData, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertMessageIfNecessary(Object)

Declaration

protected virtual IMessage ConvertMessageIfNecessary(object message)

Parameters

Type	Name	Description
System.Object	message

Returns

Type	Description
IMessage

| Edit this page View Source

ConvertRabbitAccessException(Exception)

Declaration

protected virtual Exception ConvertRabbitAccessException(Exception ex)

Parameters

Type	Name	Description
Exception	ex

Returns

Type	Description
Exception

| Edit this page View Source

ConvertSendAndReceive<T>(Object, CorrelationData)

Declaration

public virtual T ConvertSendAndReceive<T>(object message, CorrelationData correlationData)

Parameters

Type	Name	Description
System.Object	message
CorrelationData	correlationData

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(Object, IMessagePostProcessor)

Declaration

public virtual T ConvertSendAndReceive<T>(object message, IMessagePostProcessor messagePostProcessor)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(Object, IMessagePostProcessor, CorrelationData)

Declaration

public virtual T ConvertSendAndReceive<T>(object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(String, Object)

Declaration

public virtual T ConvertSendAndReceive<T>(string routingKey, object message)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(String, Object, CorrelationData)

Declaration

public virtual T ConvertSendAndReceive<T>(string routingKey, object message, CorrelationData correlationData)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
CorrelationData	correlationData

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(String, Object, IMessagePostProcessor)

Declaration

public virtual T ConvertSendAndReceive<T>(string routingKey, object message, IMessagePostProcessor messagePostProcessor)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(String, Object, IMessagePostProcessor, CorrelationData)

Declaration

public virtual T ConvertSendAndReceive<T>(string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(String, String, Object)

Declaration

public virtual T ConvertSendAndReceive<T>(string exchange, string routingKey, object message)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(String, String, Object, CorrelationData)

Declaration

public virtual T ConvertSendAndReceive<T>(string exchange, string routingKey, object message, CorrelationData correlationData)

Parameters

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

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(String, String, Object, IMessagePostProcessor)

Declaration

public virtual T ConvertSendAndReceive<T>(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceive<T>(String, String, Object, IMessagePostProcessor, CorrelationData)

Declaration

public virtual T ConvertSendAndReceive<T>(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsType(Object, CorrelationData, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(object message, CorrelationData correlationData, Type type)

Parameters

Type	Name	Description
System.Object	message
CorrelationData	correlationData
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(Object, IMessagePostProcessor, CorrelationData, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, Type type)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(Object, IMessagePostProcessor, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(object message, IMessagePostProcessor messagePostProcessor, Type type)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(Object, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(object message, Type type)

Parameters

Type	Name	Description
System.Object	message
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(String, Object, CorrelationData, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(string routingKey, object message, CorrelationData correlationData, Type type)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
CorrelationData	correlationData
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(String, Object, IMessagePostProcessor, CorrelationData, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, Type type)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(String, Object, IMessagePostProcessor, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(string routingKey, object message, IMessagePostProcessor messagePostProcessor, Type type)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(String, Object, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(string routingKey, object message, Type type)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(String, String, Object, CorrelationData, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(string exchange, string routingKey, object message, CorrelationData correlationData, Type type)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
CorrelationData	correlationData
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(String, String, Object, IMessagePostProcessor, CorrelationData, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, Type type)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(String, String, Object, IMessagePostProcessor, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, Type type)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsType(String, String, Object, Type)

Declaration

public virtual object ConvertSendAndReceiveAsType(string exchange, string routingKey, object message, Type type)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(Object, CorrelationData, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(object message, CorrelationData correlationData, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	message
CorrelationData	correlationData
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(Object, IMessagePostProcessor, CorrelationData, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(Object, IMessagePostProcessor, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(object message, IMessagePostProcessor messagePostProcessor, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(Object, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(object message, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	message
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(String, Object, CorrelationData, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(string routingKey, object message, CorrelationData correlationData, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
CorrelationData	correlationData
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(String, Object, IMessagePostProcessor, CorrelationData, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(String, Object, IMessagePostProcessor, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(string routingKey, object message, IMessagePostProcessor messagePostProcessor, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(String, Object, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(string routingKey, object message, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(String, String, Object, CorrelationData, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(string exchange, string routingKey, object message, CorrelationData correlationData, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
CorrelationData	correlationData
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(String, String, Object, IMessagePostProcessor, CorrelationData, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(String, String, Object, IMessagePostProcessor, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsTypeAsync(String, String, Object, Type, CancellationToken)

Declaration

public virtual Task<object> ConvertSendAndReceiveAsTypeAsync(string exchange, string routingKey, object message, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(Object, CorrelationData, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(object message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	message
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(Object, IMessagePostProcessor, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(object message, IMessagePostProcessor messagePostProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(Object, IMessagePostProcessor, CorrelationData, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(String, Object, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(string routingKey, object message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(String, Object, CorrelationData, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(string routingKey, object message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(String, Object, IMessagePostProcessor, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(string routingKey, object message, IMessagePostProcessor messagePostProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(String, Object, IMessagePostProcessor, CorrelationData, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(String, String, Object, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(string exchange, string routingKey, object message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(String, String, Object, CorrelationData, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(string exchange, string routingKey, object message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(String, String, Object, IMessagePostProcessor, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveAsync<T>(String, String, Object, IMessagePostProcessor, CorrelationData, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ConvertSendAndReceiveRaw(String, String, Object, IMessagePostProcessor, CorrelationData)

Declaration

protected IMessage ConvertSendAndReceiveRaw(string exchange, string routingKey, object message, IMessagePostProcessor messagePostProcessor, CorrelationData correlationData)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
System.Object	message
IMessagePostProcessor	messagePostProcessor
CorrelationData	correlationData

Returns

Type	Description
IMessage

| Edit this page View Source

CorrelationConvertAndSend(Object, CorrelationData)

Declaration

public virtual void CorrelationConvertAndSend(object message, CorrelationData correlationData)

Parameters

Type	Name	Description
System.Object	message
CorrelationData	correlationData

| Edit this page View Source

CreateConnection()

Declaration

protected virtual IConnection CreateConnection()

Returns

Type	Description
IConnection

| Edit this page View Source

DetermineConfirmsReturnsCapability(IConnectionFactory)

Declaration

public virtual void DetermineConfirmsReturnsCapability(IConnectionFactory connectionFactory)

Parameters

Type	Name	Description
IConnectionFactory	connectionFactory

| Edit this page View Source

Dispose()

Declaration

public virtual void Dispose()

| Edit this page View Source

DoReceive(RabbitDestination)

Declaration

protected override IMessage DoReceive(RabbitDestination destination)

Parameters

Type	Name	Description
RabbitDestination	destination

Returns

Type	Description
IMessage

Overrides

Steeltoe.Messaging.Core.AbstractMessageReceivingTemplate<Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination>.DoReceive(Steeltoe.Messaging.RabbitMQ.Core.RabbitDestination)

| Edit this page View Source

DoReceive(String, Int32, CancellationToken)

Declaration

protected virtual IMessage DoReceive(string queueName, int timeoutMillis, CancellationToken cancellationToken)

Parameters

Type	Name	Description
System.String	queueName
System.Int32	timeoutMillis
CancellationToken	cancellationToken

Returns

Type	Description
IMessage

| Edit this page View Source

DoReceiveAndConvert(String, Int32, Type, CancellationToken)

Declaration

protected virtual object DoReceiveAndConvert(string queueName, int timeoutMillis, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	queueName
System.Int32	timeoutMillis
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
System.Object

| Edit this page View Source

DoReceiveAsync(RabbitDestination, CancellationToken)

Declaration

protected override Task<IMessage> DoReceiveAsync(RabbitDestination destination, CancellationToken cancellationToken)

Parameters

Type	Name	Description
RabbitDestination	destination
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

DoReceiveNoWait(String, CancellationToken)

Declaration

protected virtual IMessage DoReceiveNoWait(string queueName, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	queueName
CancellationToken	cancellationToken

Returns

Type	Description
IMessage

| Edit this page View Source

DoSend(RabbitMQ.Client.IModel, String, String, IMessage, Boolean, CorrelationData, CancellationToken)

Declaration

protected virtual void DoSend(RabbitMQ.Client.IModel channel, string exchangeArg, string routingKeyArg, IMessage message, bool mandatory, CorrelationData correlationData, CancellationToken cancellationToken)

Parameters

Type	Name	Description
RabbitMQ.Client.IModel	channel
System.String	exchangeArg
System.String	routingKeyArg
IMessage	message
System.Boolean	mandatory
CorrelationData	correlationData
CancellationToken	cancellationToken

| Edit this page View Source

DoSend(RabbitDestination, IMessage)

Declaration

protected override void DoSend(RabbitDestination destination, IMessage message)

Parameters

Type	Name	Description
RabbitDestination	destination
IMessage	message

| Edit this page View Source

DoSendAndReceive(RabbitDestination, IMessage)

Declaration

protected override IMessage DoSendAndReceive(RabbitDestination destination, IMessage requestMessage)

Parameters

Type	Name	Description
RabbitDestination	destination
IMessage	requestMessage

Returns

Type	Description
IMessage

| Edit this page View Source

DoSendAndReceive(String, String, IMessage, CorrelationData, CancellationToken)

Declaration

protected virtual IMessage DoSendAndReceive(string exchange, string routingKey, IMessage message, CorrelationData correlationData, CancellationToken cancellationToken)

Parameters

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

Returns

Type	Description
IMessage

| Edit this page View Source

DoSendAndReceiveAsync(RabbitDestination, IMessage, CancellationToken)

Declaration

protected override Task<IMessage> DoSendAndReceiveAsync(RabbitDestination destination, IMessage requestMessage, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
RabbitDestination	destination
IMessage	requestMessage
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

DoSendAndReceiveWithDirect(String, String, IMessage, CorrelationData, CancellationToken)

Declaration

protected virtual IMessage DoSendAndReceiveWithDirect(string exchange, string routingKey, IMessage message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

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

Returns

Type	Description
IMessage

| Edit this page View Source

DoSendAndReceiveWithFixed(String, String, IMessage, CorrelationData, CancellationToken)

Declaration

protected virtual IMessage DoSendAndReceiveWithFixed(string exchange, string routingKey, IMessage message, CorrelationData correlationData, CancellationToken cancellationToken)

Parameters

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

Returns

Type	Description
IMessage

| Edit this page View Source

DoSendAndReceiveWithTemporary(String, String, IMessage, CorrelationData, CancellationToken)

Declaration

protected virtual IMessage DoSendAndReceiveWithTemporary(string exchange, string routingKey, IMessage message, CorrelationData correlationData, CancellationToken cancellationToken)

Parameters

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

Returns

Type	Description
IMessage

| Edit this page View Source

DoSendAsync(RabbitDestination, IMessage, CancellationToken)

Declaration

protected override Task DoSendAsync(RabbitDestination destination, IMessage message, CancellationToken cancellationToken)

Parameters

Type	Name	Description
RabbitDestination	destination
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

DoStart()

Declaration

protected virtual Task DoStart()

Returns

Type	Description
Task

| Edit this page View Source

DoStop()

Declaration

protected virtual Task DoStop()

Returns

Type	Description
Task

| Edit this page View Source

Execute(Action<RabbitMQ.Client.IModel>)

Declaration

public virtual void Execute(Action<RabbitMQ.Client.IModel> action)

Parameters

Type	Name	Description
Action<RabbitMQ.Client.IModel>	action

| Edit this page View Source

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

Declaration

public virtual T Execute<T>(Func<RabbitMQ.Client.IModel, T> action)

Parameters

Type	Name	Description
Func<RabbitMQ.Client.IModel, T>	action

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

GetDefaultExchange()

Declaration

protected virtual string GetDefaultExchange()

Returns

Type	Description
System.String

| Edit this page View Source

GetDefaultRoutingKey()

Declaration

protected virtual string GetDefaultRoutingKey()

Returns

Type	Description
System.String

| Edit this page View Source

GetExpectedQueueNames()

Declaration

public virtual List<string> GetExpectedQueueNames()

Returns

Type	Description
List<System.String>

| Edit this page View Source

GetTransactionalResourceHolder()

Declaration

protected virtual RabbitResourceHolder GetTransactionalResourceHolder()

Returns

Type	Description
RabbitResourceHolder

| Edit this page View Source

GetUnconfirmed(Int64)

Declaration

public virtual ICollection<CorrelationData> GetUnconfirmed(long age)

Parameters

Type	Name	Description
System.Int64	age

Returns

Type	Description
ICollection<CorrelationData>

| Edit this page View Source

GetUnconfirmedCount()

Declaration

public virtual int GetUnconfirmedCount()

Returns

Type	Description
System.Int32

| Edit this page View Source

HandleConfirm(PendingConfirm, Boolean)

Declaration

public virtual void HandleConfirm(PendingConfirm pendingConfirm, bool ack)

Parameters

Type	Name	Description
PendingConfirm	pendingConfirm
System.Boolean	ack

| Edit this page View Source

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

Declaration

public virtual void HandleReturn(int replyCode, string replyText, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties properties, byte[] body)

Parameters

Type	Name	Description
System.Int32	replyCode
System.String	replyText
System.String	exchange
System.String	routingKey
RabbitMQ.Client.IBasicProperties	properties
System.Byte[]	body

| Edit this page View Source

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

Declaration

public virtual T Invoke<T>(Func<IRabbitTemplate, T> rabbitOperations)

Parameters

Type	Name	Description
Func<IRabbitTemplate, T>	rabbitOperations

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

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

Declaration

public virtual T Invoke<T>(Func<IRabbitTemplate, T> rabbitOperations, Action<object, BasicAckEventArgs> acks, Action<object, BasicNackEventArgs> nacks)

Parameters

Type	Name	Description
Func<IRabbitTemplate, T>	rabbitOperations
Action<System.Object, BasicAckEventArgs>	acks
Action<System.Object, BasicNackEventArgs>	nacks

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

IsChannelLocallyTransacted(RabbitMQ.Client.IModel)

Declaration

protected virtual bool IsChannelLocallyTransacted(RabbitMQ.Client.IModel channel)

Parameters

Type	Name	Description
RabbitMQ.Client.IModel	channel

Returns

Type	Description
System.Boolean

| Edit this page View Source

IsMandatoryFor(IMessage)

Declaration

public virtual bool IsMandatoryFor(IMessage message)

Parameters

Type	Name	Description
IMessage	message

Returns

Type	Description
System.Boolean

| Edit this page View Source

OnMessage(IMessage)

Declaration

public virtual void OnMessage(IMessage message)

Parameters

Type	Name	Description
IMessage	message

| Edit this page View Source

OnMessageBatch(List<IMessage>)

Declaration

public virtual void OnMessageBatch(List<IMessage> messages)

Parameters

Type	Name	Description
List<IMessage>	messages

| Edit this page View Source

Receive(Int32)

Declaration

public virtual IMessage Receive(int timeoutMillis)

Parameters

Type	Name	Description
System.Int32	timeoutMillis

Returns

Type	Description
IMessage

| Edit this page View Source

Receive(String)

Declaration

public virtual IMessage Receive(string queueName)

Parameters

Type	Name	Description
System.String	queueName

Returns

Type	Description
IMessage

| Edit this page View Source

Receive(String, Int32)

Declaration

public virtual IMessage Receive(string queueName, int timeoutMillis)

Parameters

Type	Name	Description
System.String	queueName
System.Int32	timeoutMillis

Returns

Type	Description
IMessage

| Edit this page View Source

ReceiveAndConvert(Int32, Type)

Declaration

public virtual object ReceiveAndConvert(int timeoutMillis, Type type)

Parameters

Type	Name	Description
System.Int32	timeoutMillis
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ReceiveAndConvert(String, Int32, Type)

Declaration

public virtual object ReceiveAndConvert(string queueName, int timeoutMillis, Type type)

Parameters

Type	Name	Description
System.String	queueName
System.Int32	timeoutMillis
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ReceiveAndConvert(String, Type)

Declaration

public virtual object ReceiveAndConvert(string queueName, Type type)

Parameters

Type	Name	Description
System.String	queueName
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ReceiveAndConvert(Type)

Declaration

public virtual object ReceiveAndConvert(Type type)

Parameters

Type	Name	Description
Type	type

Returns

Type	Description
System.Object

| Edit this page View Source

ReceiveAndConvert<T>(Int32)

Declaration

public virtual T ReceiveAndConvert<T>(int timeoutMillis)

Parameters

Type	Name	Description
System.Int32	timeoutMillis

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ReceiveAndConvert<T>(String)

Declaration

public virtual T ReceiveAndConvert<T>(string queueName)

Parameters

Type	Name	Description
System.String	queueName

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ReceiveAndConvert<T>(String, Int32)

Declaration

public virtual T ReceiveAndConvert<T>(string queueName, int timeoutMillis)

Parameters

Type	Name	Description
System.String	queueName
System.Int32	timeoutMillis

Returns

Type	Description
T

Type Parameters

Name	Description
T

| Edit this page View Source

ReceiveAndConvertAsync(Int32, Type, CancellationToken)

Declaration

public virtual Task<object> ReceiveAndConvertAsync(int timeoutMillis, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Int32	timeoutMillis
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ReceiveAndConvertAsync(String, Int32, Type, CancellationToken)

Declaration

public virtual Task<object> ReceiveAndConvertAsync(string queueName, int timeoutMillis, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	queueName
System.Int32	timeoutMillis
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ReceiveAndConvertAsync(String, Type, CancellationToken)

Declaration

public virtual Task<object> ReceiveAndConvertAsync(string queueName, Type type, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	queueName
Type	type
CancellationToken	cancellationToken

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ReceiveAndConvertAsync(Type, CancellationToken)

Declaration

public virtual Task<object> ReceiveAndConvertAsync(Type type, CancellationToken cancellation = null)

Parameters

Type	Name	Description
Type	type
CancellationToken	cancellation

Returns

Type	Description
Task<System.Object>

| Edit this page View Source

ReceiveAndConvertAsync<T>(Int32, CancellationToken)

Declaration

public virtual Task<T> ReceiveAndConvertAsync<T>(int timeoutMillis, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Int32	timeoutMillis
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ReceiveAndConvertAsync<T>(String, CancellationToken)

Declaration

public virtual Task<T> ReceiveAndConvertAsync<T>(string queueName, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	queueName
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

ReceiveAndConvertAsync<T>(String, Int32, CancellationToken)

Declaration

public virtual Task<T> ReceiveAndConvertAsync<T>(string queueName, int timeoutMillis, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	queueName
System.Int32	timeoutMillis
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

| Edit this page View Source

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

Declaration

public virtual bool ReceiveAndReply<R, S>(Func<R, S> callback)

Parameters

Type	Name	Description
Func<R, S>	callback

Returns

Type	Description
System.Boolean

Type Parameters

Name	Description
R
S

| Edit this page View Source

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

Declaration

public virtual bool ReceiveAndReply<R, S>(Func<R, S> callback, Func<IMessage, S, Address> replyToAddressCallback)

Parameters

Type	Name	Description
Func<R, S>	callback
Func<IMessage, S, Address>	replyToAddressCallback

Returns

Type	Description
System.Boolean

Type Parameters

Name	Description
R
S

| Edit this page View Source

ReceiveAndReply<R, S>(Func<R, S>, String, String)

Declaration

public virtual bool ReceiveAndReply<R, S>(Func<R, S> callback, string exchange, string routingKey)

Parameters

Type	Name	Description
Func<R, S>	callback
System.String	exchange
System.String	routingKey

Returns

Type	Description
System.Boolean

Type Parameters

Name	Description
R
S

| Edit this page View Source

ReceiveAndReply<R, S>(String, Func<R, S>)

Declaration

public virtual bool ReceiveAndReply<R, S>(string queueName, Func<R, S> callback)

Parameters

Type	Name	Description
System.String	queueName
Func<R, S>	callback

Returns

Type	Description
System.Boolean

Type Parameters

Name	Description
R
S

| Edit this page View Source

ReceiveAndReply<R, S>(String, Func<R, S>, Func<IMessage, S, Address>)

Declaration

public virtual bool ReceiveAndReply<R, S>(string queueName, Func<R, S> callback, Func<IMessage, S, Address> replyToAddressCallback)

Parameters

Type	Name	Description
System.String	queueName
Func<R, S>	callback
Func<IMessage, S, Address>	replyToAddressCallback

Returns

Type	Description
System.Boolean

Type Parameters

Name	Description
R
S

| Edit this page View Source

ReceiveAndReply<R, S>(String, Func<R, S>, String, String)

Declaration

public virtual bool ReceiveAndReply<R, S>(string queueName, Func<R, S> callback, string replyExchange, string replyRoutingKey)

Parameters

Type	Name	Description
System.String	queueName
Func<R, S>	callback
System.String	replyExchange
System.String	replyRoutingKey

Returns

Type	Description
System.Boolean

Type Parameters

Name	Description
R
S

| Edit this page View Source

ReceiveAsync(Int32, CancellationToken)

Declaration

public virtual Task<IMessage> ReceiveAsync(int timeoutMillis, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Int32	timeoutMillis
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

ReceiveAsync(String, CancellationToken)

Declaration

public virtual Task<IMessage> ReceiveAsync(string queueName, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	queueName
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

ReceiveAsync(String, Int32, CancellationToken)

Declaration

public virtual Task<IMessage> ReceiveAsync(string queueName, int timeoutMillis, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	queueName
System.Int32	timeoutMillis
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

RemoveAfterReceivePostProcessor(IMessagePostProcessor)

Declaration

public virtual bool RemoveAfterReceivePostProcessor(IMessagePostProcessor afterReceivePostProcessor)

Parameters

Type	Name	Description
IMessagePostProcessor	afterReceivePostProcessor

Returns

Type	Description
System.Boolean

| Edit this page View Source

RemoveBeforePublishPostProcessor(IMessagePostProcessor)

Declaration

public virtual bool RemoveBeforePublishPostProcessor(IMessagePostProcessor beforePublishPostProcessor)

Parameters

Type	Name	Description
IMessagePostProcessor	beforePublishPostProcessor

Returns

Type	Description
System.Boolean

| Edit this page View Source

ReplyTimedOut(String)

Declaration

protected virtual void ReplyTimedOut(string correlationId)

Parameters

Type	Name	Description
System.String	correlationId

| Edit this page View Source

Revoke(RabbitMQ.Client.IModel)

Declaration

public virtual void Revoke(RabbitMQ.Client.IModel channel)

Parameters

Type	Name	Description
RabbitMQ.Client.IModel	channel

| Edit this page View Source

Send(String, IMessage)

Declaration

public virtual void Send(string routingKey, IMessage message)

Parameters

Type	Name	Description
System.String	routingKey
IMessage	message

| Edit this page View Source

Send(String, String, IMessage)

Declaration

public virtual void Send(string exchange, string routingKey, IMessage message)

Parameters

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

| Edit this page View Source

Send(String, String, IMessage, CorrelationData)

Declaration

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

Parameters

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

| Edit this page View Source

SendAndReceive(IMessage, CorrelationData)

Declaration

public virtual IMessage SendAndReceive(IMessage message, CorrelationData correlationData)

Parameters

Type	Name	Description
IMessage	message
CorrelationData	correlationData

Returns

Type	Description
IMessage

| Edit this page View Source

SendAndReceive(String, IMessage)

Declaration

public virtual IMessage SendAndReceive(string routingKey, IMessage message)

Parameters

Type	Name	Description
System.String	routingKey
IMessage	message

Returns

Type	Description
IMessage

| Edit this page View Source

SendAndReceive(String, IMessage, CorrelationData)

Declaration

public virtual IMessage SendAndReceive(string routingKey, IMessage message, CorrelationData correlationData)

Parameters

Type	Name	Description
System.String	routingKey
IMessage	message
CorrelationData	correlationData

Returns

Type	Description
IMessage

| Edit this page View Source

SendAndReceive(String, String, IMessage)

Declaration

public virtual IMessage SendAndReceive(string exchange, string routingKey, IMessage message)

Parameters

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

Returns

Type	Description
IMessage

| Edit this page View Source

SendAndReceive(String, String, IMessage, CorrelationData)

Declaration

public virtual IMessage SendAndReceive(string exchange, string routingKey, IMessage message, CorrelationData correlationData)

Parameters

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

Returns

Type	Description
IMessage

| Edit this page View Source

SendAndReceiveAsync(IMessage, CorrelationData, CancellationToken)

Declaration

public virtual Task<IMessage> SendAndReceiveAsync(IMessage message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
IMessage	message
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

SendAndReceiveAsync(String, IMessage, CancellationToken)

Declaration

public virtual Task<IMessage> SendAndReceiveAsync(string routingKey, IMessage message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

SendAndReceiveAsync(String, IMessage, CorrelationData, CancellationToken)

Declaration

public virtual Task<IMessage> SendAndReceiveAsync(string routingKey, IMessage message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
IMessage	message
CorrelationData	correlationData
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

SendAndReceiveAsync(String, String, IMessage, CancellationToken)

Declaration

public virtual Task<IMessage> SendAndReceiveAsync(string exchange, string routingKey, IMessage message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

SendAndReceiveAsync(String, String, IMessage, CorrelationData, CancellationToken)

Declaration

public virtual Task<IMessage> SendAndReceiveAsync(string exchange, string routingKey, IMessage message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

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

Returns

Type	Description
Task<IMessage>

| Edit this page View Source

SendAsync(String, IMessage, CancellationToken)

Declaration

public virtual Task SendAsync(string routingKey, IMessage message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	routingKey
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

SendAsync(String, String, IMessage, CancellationToken)

Declaration

public virtual Task SendAsync(string exchange, string routingKey, IMessage message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.String	exchange
System.String	routingKey
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

SendAsync(String, String, IMessage, CorrelationData, CancellationToken)

Declaration

public virtual Task SendAsync(string exchange, string routingKey, IMessage message, CorrelationData correlationData, CancellationToken cancellationToken = null)

Parameters

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

Returns

Type	Description
Task

| Edit this page View Source

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

Declaration

protected virtual void SendToRabbit(RabbitMQ.Client.IModel channel, string exchange, string routingKey, bool mandatory, IMessage message)

Parameters

Type	Name	Description
RabbitMQ.Client.IModel	channel
System.String	exchange
System.String	routingKey
System.Boolean	mandatory
IMessage	message

| Edit this page View Source

SetAfterReceivePostProcessors(IMessagePostProcessor[])

Declaration

public virtual void SetAfterReceivePostProcessors(params IMessagePostProcessor[] afterReceivePostProcessors)

Parameters

Type	Name	Description
IMessagePostProcessor[]	afterReceivePostProcessors

| Edit this page View Source

SetBeforePublishPostProcessors(IMessagePostProcessor[])

Declaration

public virtual void SetBeforePublishPostProcessors(params IMessagePostProcessor[] beforePublishPostProcessors)

Parameters

Type	Name	Description
IMessagePostProcessor[]	beforePublishPostProcessors

| Edit this page View Source

Start()

Declaration

public virtual async Task Start()

Returns

Type	Description
Task

| Edit this page View Source

Stop()

Declaration

public virtual async Task Stop()

Returns

Type	Description
Task

| Edit this page View Source

UseDirectReplyTo()

Declaration

protected virtual bool UseDirectReplyTo()

Returns

Type	Description
System.Boolean

| Edit this page View Source

WaitForConfirms(Int32)

Declaration

public virtual bool WaitForConfirms(int timeoutInMilliseconds)

Parameters

Type	Name	Description
System.Int32	timeoutInMilliseconds

Returns

Type	Description
System.Boolean

| Edit this page View Source

WaitForConfirmsOrDie(Int32)

Declaration

public virtual void WaitForConfirmsOrDie(int timeoutInMilliseconds)

Parameters

Type	Name	Description
System.Int32	timeoutInMilliseconds

Implements

IMessageSendingOperations<D>

IMessageReceivingOperations<D>

IMessageRequestReplyOperations<D>

IRabbitTemplate

IServiceNameAware

IMessageListener

IListenerContainerAware

IPublisherCallbackChannel.IListener

IDisposable