Class AbstractMessagingTemplate<D>

Inheritance

System.Object

AbstractMessageSendingTemplate<D>

AbstractMessageReceivingTemplate<D>

AbstractMessagingTemplate<D>

AbstractDestinationResolvingMessagingTemplate<D>

RabbitTemplate

Implements

IMessageSendingOperations<D>

IMessageReceivingOperations<D>

IMessageRequestReplyOperations<D>

Inherited Members

AbstractMessageReceivingTemplate<D>.DefaultReceiveDestination

AbstractMessageReceivingTemplate<D>.ThrowReceivedExceptions

AbstractMessageReceivingTemplate<D>.ReceiveAsync(CancellationToken)

AbstractMessageReceivingTemplate<D>.ReceiveAsync(D, CancellationToken)

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

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

AbstractMessageReceivingTemplate<D>.Receive()

AbstractMessageReceivingTemplate<D>.Receive(D)

AbstractMessageReceivingTemplate<D>.ReceiveAndConvert<T>()

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

AbstractMessageReceivingTemplate<D>.RequiredDefaultReceiveDestination

AbstractMessageReceivingTemplate<D>.DoReceiveAsync(D, CancellationToken)

AbstractMessageReceivingTemplate<D>.DoReceive(D)

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

AbstractMessageSendingTemplate<D>.CONVERSION_HINT_HEADER

AbstractMessageSendingTemplate<D>.DefaultSendDestination

AbstractMessageSendingTemplate<D>.MessageConverter

AbstractMessageSendingTemplate<D>.ConvertAndSendAsync(Object, CancellationToken)

AbstractMessageSendingTemplate<D>.ConvertAndSendAsync(D, Object, CancellationToken)

AbstractMessageSendingTemplate<D>.ConvertAndSendAsync(D, Object, IDictionary<String, Object>, CancellationToken)

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

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

AbstractMessageSendingTemplate<D>.ConvertAndSendAsync(D, Object, IDictionary<String, Object>, IMessagePostProcessor, CancellationToken)

AbstractMessageSendingTemplate<D>.SendAsync(IMessage, CancellationToken)

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

AbstractMessageSendingTemplate<D>.ConvertAndSend(Object)

AbstractMessageSendingTemplate<D>.ConvertAndSend(D, Object)

AbstractMessageSendingTemplate<D>.ConvertAndSend(D, Object, IDictionary<String, Object>)

AbstractMessageSendingTemplate<D>.ConvertAndSend(Object, IMessagePostProcessor)

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

AbstractMessageSendingTemplate<D>.ConvertAndSend(D, Object, IDictionary<String, Object>, IMessagePostProcessor)

AbstractMessageSendingTemplate<D>.Send(IMessage)

AbstractMessageSendingTemplate<D>.Send(D, IMessage)

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

AbstractMessageSendingTemplate<D>.DoSend(D, IMessage)

AbstractMessageSendingTemplate<D>.RequiredDefaultSendDestination

AbstractMessageSendingTemplate<D>.DoConvert(Object, IDictionary<String, Object>, IMessagePostProcessor)

AbstractMessageSendingTemplate<D>.ProcessHeadersToSend(IDictionary<String, Object>)

Namespace: Steeltoe.Messaging.Core

Assembly: Steeltoe.Messaging.MessagingBase.dll

Syntax

public abstract class AbstractMessagingTemplate<D> : AbstractMessageReceivingTemplate<D>, IMessageSendingOperations<D>, IMessageReceivingOperations<D>, IMessageRequestReplyOperations<D>

Type Parameters

Name	Description
D

Methods

ConvertSendAndReceive<T>(D, Object)

Declaration

public virtual T ConvertSendAndReceive<T>(D destination, object request)

Parameters

Type	Name	Description
D	destination
System.Object	request

Returns

Type	Description
T

Type Parameters

Name	Description
T

ConvertSendAndReceive<T>(D, Object, IDictionary<String, Object>)

Declaration

public virtual T ConvertSendAndReceive<T>(D destination, object request, IDictionary<string, object> headers)

Parameters

Type	Name	Description
D	destination
System.Object	request
IDictionary<System.String, System.Object>	headers

Returns

Type	Description
T

Type Parameters

Name	Description
T

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

Declaration

public virtual T ConvertSendAndReceive<T>(D destination, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor)

Parameters

Type	Name	Description
D	destination
System.Object	request
IDictionary<System.String, System.Object>	headers
IMessagePostProcessor	requestPostProcessor

Returns

Type	Description
T

Type Parameters

Name	Description
T

ConvertSendAndReceive<T>(D, Object, IMessagePostProcessor)

Declaration

public virtual T ConvertSendAndReceive<T>(D destination, object request, IMessagePostProcessor requestPostProcessor)

Parameters

Type	Name	Description
D	destination
System.Object	request
IMessagePostProcessor	requestPostProcessor

Returns

Type	Description
T

Type Parameters

Name	Description
T

ConvertSendAndReceive<T>(Object)

Declaration

public virtual T ConvertSendAndReceive<T>(object request)

Parameters

Type	Name	Description
System.Object	request

Returns

Type	Description
T

Type Parameters

Name	Description
T

ConvertSendAndReceive<T>(Object, IMessagePostProcessor)

Declaration

public virtual T ConvertSendAndReceive<T>(object request, IMessagePostProcessor requestPostProcessor)

Parameters

Type	Name	Description
System.Object	request
IMessagePostProcessor	requestPostProcessor

Returns

Type	Description
T

Type Parameters

Name	Description
T

ConvertSendAndReceiveAsync<T>(D, Object, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(D destination, object request, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
System.Object	request
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

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

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(D destination, object request, IDictionary<string, object> headers, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
System.Object	request
IDictionary<System.String, System.Object>	headers
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

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

Declaration

public virtual async Task<T> ConvertSendAndReceiveAsync<T>(D destination, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
System.Object	request
IDictionary<System.String, System.Object>	headers
IMessagePostProcessor	requestPostProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

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

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(D destination, object request, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
System.Object	request
IMessagePostProcessor	requestPostProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

ConvertSendAndReceiveAsync<T>(Object, CancellationToken)

Declaration

public virtual Task<T> ConvertSendAndReceiveAsync<T>(object request, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	request
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

ConvertSendAndReceiveAsync<T>(Object, IMessagePostProcessor, CancellationToken)

Declaration

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

Parameters

Type	Name	Description
System.Object	request
IMessagePostProcessor	requestPostProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task<T>

Type Parameters

Name	Description
T

DoSendAndReceive(D, IMessage)

Declaration

protected abstract IMessage DoSendAndReceive(D destination, IMessage requestMessage)

Parameters

Type	Name	Description
D	destination
IMessage	requestMessage

Returns

Type	Description
IMessage

DoSendAndReceiveAsync(D, IMessage, CancellationToken)

Declaration

protected abstract Task<IMessage> DoSendAndReceiveAsync(D destination, IMessage requestMessage, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
IMessage	requestMessage
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

SendAndReceive(D, IMessage)

Declaration

public virtual IMessage SendAndReceive(D destination, IMessage requestMessage)

Parameters

Type	Name	Description
D	destination
IMessage	requestMessage

Returns

Type	Description
IMessage

SendAndReceive(IMessage)

Declaration

public virtual IMessage SendAndReceive(IMessage requestMessage)

Parameters

Type	Name	Description
IMessage	requestMessage

Returns

Type	Description
IMessage

SendAndReceiveAsync(D, IMessage, CancellationToken)

Declaration

public virtual Task<IMessage> SendAndReceiveAsync(D destination, IMessage requestMessage, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
IMessage	requestMessage
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

SendAndReceiveAsync(IMessage, CancellationToken)

Declaration

public virtual Task<IMessage> SendAndReceiveAsync(IMessage requestMessage, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
IMessage	requestMessage
CancellationToken	cancellationToken

Returns

Type	Description
Task<IMessage>

Implements

IMessageSendingOperations<D>

IMessageReceivingOperations<D>

IMessageRequestReplyOperations<D>