X

Interface IRabbitTemplate

Namespace: Steeltoe.Messaging.RabbitMQ.Core
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
public interface IRabbitTemplate

Properties

| Edit this page View Source

ConnectionFactory

Declaration
IConnectionFactory ConnectionFactory { get; }
Property Value
Type Description
IConnectionFactory

Methods

| Edit this page View Source

ConvertAndSend(Object, IMessagePostProcessor, CorrelationData)

Declaration
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, String, Object)

Declaration
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
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
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
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

ConvertSendAndReceive<T>(Object, CorrelationData)

Declaration
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, CorrelationData)

Declaration
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, String, Object)

Declaration
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
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, CorrelationData)

Declaration
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

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

Declaration
T Execute<T>(Func<RabbitMQ.Client.IModel, T> channelCallback)
Parameters
Type Name Description
Func<RabbitMQ.Client.IModel, T> channelCallback
Returns
Type Description
T
Type Parameters
Name Description
T
| Edit this page View Source

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

Declaration
virtual T Invoke<T>(Func<IRabbitTemplate, T> operationsCallback)
Parameters
Type Name Description
Func<IRabbitTemplate, T> operationsCallback
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
T Invoke<T>(Func<IRabbitTemplate, T> operationsCallback, Action<object, BasicAckEventArgs> acks, Action<object, BasicNackEventArgs> nacks)
Parameters
Type Name Description
Func<IRabbitTemplate, T> operationsCallback
Action<System.Object, BasicAckEventArgs> acks
Action<System.Object, BasicNackEventArgs> nacks
Returns
Type Description
T
Type Parameters
Name Description
T
| Edit this page View Source

Receive(Int32)

Declaration
IMessage Receive(int timeoutMillis)
Parameters
Type Name Description
System.Int32 timeoutMillis
Returns
Type Description
IMessage
| Edit this page View Source

Receive(String, Int32)

Declaration
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<T>(Int32)

Declaration
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, Int32)

Declaration
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

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

Declaration
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
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
bool ReceiveAndReply<R, S>(Func<R, S> callback, string replyExchange, string replyRoutingKey)
Parameters
Type Name Description
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

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

Declaration
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
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
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

Send(String, String, IMessage)

Declaration
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
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(String, String, IMessage)

Declaration
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

SendAsync(String, String, IMessage, CancellationToken)

Declaration
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
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

WaitForConfirms(Int32)

Declaration
bool WaitForConfirms(int timeout)
Parameters
Type Name Description
System.Int32 timeout
Returns
Type Description
System.Boolean
| Edit this page View Source

WaitForConfirmsOrDie(Int32)

Declaration
void WaitForConfirmsOrDie(int timeout)
Parameters
Type Name Description
System.Int32 timeout