Interface IRabbitTemplate

Namespace

Steeltoe.Messaging.RabbitMQ.Core

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public interface IRabbitTemplate : IServiceNameAware

Inherited Members

IServiceNameAware.ServiceName

Properties

ConnectionFactory

IConnectionFactory ConnectionFactory { get; }

Property Value

IConnectionFactory

Methods

ConvertAndSend(object, IMessagePostProcessor, CorrelationData)

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

Parameters

message object

messagePostProcessor IMessagePostProcessor

correlationData CorrelationData

ConvertAndSend(string, string, object)

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

Parameters

exchange string

routingKey string

message object

ConvertAndSend(string, string, object, CorrelationData)

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

Parameters

exchange string

routingKey string

message object

correlationData CorrelationData

ConvertAndSend(string, string, object, IMessagePostProcessor)

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

Parameters

exchange string

routingKey string

message object

messagePostProcessor IMessagePostProcessor

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

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

Parameters

exchange string

routingKey string

message object

messagePostProcessor IMessagePostProcessor

correlationData CorrelationData

ConvertSendAndReceive<T>(object, CorrelationData)

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

Parameters

message object

correlationData CorrelationData

Returns

T

Type Parameters

T

ConvertSendAndReceive<T>(object, IMessagePostProcessor, CorrelationData)

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

Parameters

message object

messagePostProcessor IMessagePostProcessor

correlationData CorrelationData

Returns

T

Type Parameters

T

ConvertSendAndReceive<T>(string, string, object)

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

Parameters

exchange string

routingKey string

message object

Returns

T

Type Parameters

T

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

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

Parameters

exchange string

routingKey string

message object

correlationData CorrelationData

Returns

T

Type Parameters

T

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

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

Parameters

exchange string

routingKey string

message object

messagePostProcessor IMessagePostProcessor

correlationData CorrelationData

Returns

T

Type Parameters

T

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

T Execute<T>(Func<IModel, T> channelCallback)

Parameters

channelCallback Func<IModel, T>

Returns

T

Type Parameters

T

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

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

Parameters

operationsCallback Func<IRabbitTemplate, T>

Returns

T

Type Parameters

T

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

T Invoke<T>(Func<IRabbitTemplate, T> operationsCallback, Action<object, BasicAckEventArgs> acks, Action<object, BasicNackEventArgs> nacks)

Parameters

operationsCallback Func<IRabbitTemplate, T>

acks Action<object, BasicAckEventArgs>

nacks Action<object, BasicNackEventArgs>

Returns

T

Type Parameters

T

Receive(int)

IMessage Receive(int timeoutMillis)

Parameters

timeoutMillis int

Returns

IMessage

Receive(string, int)

IMessage Receive(string queueName, int timeoutMillis)

Parameters

queueName string

timeoutMillis int

Returns

IMessage

ReceiveAndConvert<T>(int)

T ReceiveAndConvert<T>(int timeoutMillis)

Parameters

timeoutMillis int

Returns

T

Type Parameters

T

ReceiveAndConvert<T>(string, int)

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

Parameters

queueName string

timeoutMillis int

Returns

T

Type Parameters

T

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

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

Parameters

callback Func<R, S>

Returns

bool

Type Parameters

R

S

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

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

Parameters

callback Func<R, S>

replyToAddressCallback Func<IMessage, S, Address>

Returns

bool

Type Parameters

R

S

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

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

Parameters

callback Func<R, S>

replyExchange string

replyRoutingKey string

Returns

bool

Type Parameters

R

S

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

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

Parameters

queueName string

callback Func<R, S>

Returns

bool

Type Parameters

R

S

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

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

Parameters

queueName string

callback Func<R, S>

replyToAddressCallback Func<IMessage, S, Address>

Returns

bool

Type Parameters

R

S

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

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

Parameters

queueName string

callback Func<R, S>

replyExchange string

replyRoutingKey string

Returns

bool

Type Parameters

R

S

Send(string, string, IMessage)

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

Parameters

exchange string

routingKey string

message IMessage

Send(string, string, IMessage, CorrelationData)

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

Parameters

exchange string

routingKey string

message IMessage

correlationData CorrelationData

SendAndReceive(string, string, IMessage)

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

Parameters

exchange string

routingKey string

message IMessage

Returns

IMessage

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

Task SendAsync(string exchange, string routingKey, IMessage message, CorrelationData correlationData, CancellationToken cancellationToken = default)

Parameters

exchange string

routingKey string

message IMessage

correlationData CorrelationData

cancellationToken CancellationToken

Returns

Task

SendAsync(string, string, IMessage, CancellationToken)

Task SendAsync(string exchange, string routingKey, IMessage message, CancellationToken cancellationToken = default)

Parameters

exchange string

routingKey string

message IMessage

cancellationToken CancellationToken

Returns

Task

WaitForConfirms(int)

bool WaitForConfirms(int timeout)

Parameters

timeout int

Returns

bool

WaitForConfirmsOrDie(int)

void WaitForConfirmsOrDie(int timeout)

Parameters

timeout int