X

Class AbstractDestinationResolvingMessagingTemplate<D>

Inheritance
System.Object
AbstractMessageSendingTemplate<D>
AbstractMessageReceivingTemplate<D>
AbstractMessagingTemplate<D>
AbstractDestinationResolvingMessagingTemplate<D>
MessageChannelTemplate
Implements
Inherited Members
Namespace: Steeltoe.Messaging.Core
Assembly: Steeltoe.Messaging.MessagingBase.dll
Syntax
public abstract class AbstractDestinationResolvingMessagingTemplate<D> : AbstractMessagingTemplate<D>, IDestinationResolvingMessageSendingOperations<D>, IMessageSendingOperations<D>, IDestinationResolvingMessageReceivingOperations<D>, IMessageReceivingOperations<D>, IDestinationResolvingMessageRequestReplyOperations<D>, IMessageRequestReplyOperations<D>
Type Parameters
Name Description
D

Constructors

| Edit this page View Source

AbstractDestinationResolvingMessagingTemplate(IApplicationContext)

Declaration
public AbstractDestinationResolvingMessagingTemplate(IApplicationContext context)
Parameters
Type Name Description
IApplicationContext context

Properties

| Edit this page View Source

ApplicationContext

Declaration
public virtual IApplicationContext ApplicationContext { get; }
Property Value
Type Description
IApplicationContext
| Edit this page View Source

DestinationResolver

Declaration
public IDestinationResolver<D> DestinationResolver { get; set; }
Property Value
Type Description
IDestinationResolver<D>

Methods

| Edit this page View Source

ConvertAndSend(String, Object)

Declaration
public virtual void ConvertAndSend(string destinationName, object payload)
Parameters
Type Name Description
System.String destinationName
System.Object payload
| Edit this page View Source

ConvertAndSend(String, Object, IDictionary<String, Object>)

Declaration
public virtual void ConvertAndSend(string destinationName, object payload, IDictionary<string, object> headers)
Parameters
Type Name Description
System.String destinationName
System.Object payload
IDictionary<System.String, System.Object> headers
| Edit this page View Source

ConvertAndSend(String, Object, IDictionary<String, Object>, IMessagePostProcessor)

Declaration
public virtual void ConvertAndSend(string destinationName, object payload, IDictionary<string, object> headers, IMessagePostProcessor postProcessor)
Parameters
Type Name Description
System.String destinationName
System.Object payload
IDictionary<System.String, System.Object> headers
IMessagePostProcessor postProcessor
| Edit this page View Source

ConvertAndSend(String, Object, IMessagePostProcessor)

Declaration
public virtual void ConvertAndSend(string destinationName, object payload, IMessagePostProcessor postProcessor)
Parameters
Type Name Description
System.String destinationName
System.Object payload
IMessagePostProcessor postProcessor
| Edit this page View Source

ConvertAndSendAsync(String, Object, CancellationToken)

Declaration
public virtual Task ConvertAndSendAsync(string destinationName, object payload, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
System.Object payload
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

ConvertAndSendAsync(String, Object, IDictionary<String, Object>, CancellationToken)

Declaration
public virtual Task ConvertAndSendAsync(string destinationName, object payload, IDictionary<string, object> headers, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
System.Object payload
IDictionary<System.String, System.Object> headers
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

ConvertAndSendAsync(String, Object, IDictionary<String, Object>, IMessagePostProcessor, CancellationToken)

Declaration
public virtual Task ConvertAndSendAsync(string destinationName, object payload, IDictionary<string, object> headers, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
System.Object payload
IDictionary<System.String, System.Object> headers
IMessagePostProcessor postProcessor
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

ConvertAndSendAsync(String, Object, IMessagePostProcessor, CancellationToken)

Declaration
public virtual Task ConvertAndSendAsync(string destinationName, object payload, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
System.Object payload
IMessagePostProcessor postProcessor
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

ConvertSendAndReceive<T>(String, Object)

Declaration
public virtual T ConvertSendAndReceive<T>(string destinationName, object request)
Parameters
Type Name Description
System.String destinationName
System.Object request
Returns
Type Description
T
Type Parameters
Name Description
T
| Edit this page View Source

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

Declaration
public virtual T ConvertSendAndReceive<T>(string destinationName, object request, IDictionary<string, object> headers)
Parameters
Type Name Description
System.String destinationName
System.Object request
IDictionary<System.String, System.Object> headers
Returns
Type Description
T
Type Parameters
Name Description
T
| Edit this page View Source

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

Declaration
public virtual T ConvertSendAndReceive<T>(string destinationName, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor)
Parameters
Type Name Description
System.String destinationName
System.Object request
IDictionary<System.String, System.Object> headers
IMessagePostProcessor requestPostProcessor
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 destinationName, object request, IMessagePostProcessor requestPostProcessor)
Parameters
Type Name Description
System.String destinationName
System.Object request
IMessagePostProcessor requestPostProcessor
Returns
Type Description
T
Type Parameters
Name Description
T
| Edit this page View Source

ConvertSendAndReceiveAsync<T>(String, Object, CancellationToken)

Declaration
public virtual Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
System.Object request
CancellationToken cancellationToken
Returns
Type Description
Task<T>
Type Parameters
Name Description
T
| Edit this page View Source

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

Declaration
public virtual Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, IDictionary<string, object> headers, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
System.Object request
IDictionary<System.String, System.Object> headers
CancellationToken cancellationToken
Returns
Type Description
Task<T>
Type Parameters
Name Description
T
| Edit this page View Source

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

Declaration
public virtual Task<T> ConvertSendAndReceiveAsync<T>(string destinationName, object request, IDictionary<string, object> headers, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
System.Object request
IDictionary<System.String, System.Object> headers
IMessagePostProcessor requestPostProcessor
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 destinationName, object request, IMessagePostProcessor requestPostProcessor, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
System.Object request
IMessagePostProcessor requestPostProcessor
CancellationToken cancellationToken
Returns
Type Description
Task<T>
Type Parameters
Name Description
T
| Edit this page View Source

Receive(String)

Declaration
public virtual IMessage Receive(string destinationName)
Parameters
Type Name Description
System.String destinationName
Returns
Type Description
IMessage
| Edit this page View Source

ReceiveAndConvert<T>(String)

Declaration
public virtual T ReceiveAndConvert<T>(string destinationName)
Parameters
Type Name Description
System.String destinationName
Returns
Type Description
T
Type Parameters
Name Description
T
| Edit this page View Source

ReceiveAndConvertAsync<T>(String, CancellationToken)

Declaration
public virtual Task<T> ReceiveAndConvertAsync<T>(string destinationName, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
CancellationToken cancellationToken
Returns
Type Description
Task<T>
Type Parameters
Name Description
T
| Edit this page View Source

ReceiveAsync(String, CancellationToken)

Declaration
public virtual Task<IMessage> ReceiveAsync(string destinationName, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
CancellationToken cancellationToken
Returns
Type Description
Task<IMessage>
| Edit this page View Source

ResolveDestination(String)

Declaration
protected D ResolveDestination(string destinationName)
Parameters
Type Name Description
System.String destinationName
Returns
Type Description
D
| Edit this page View Source

Send(String, IMessage)

Declaration
public virtual void Send(string destinationName, IMessage message)
Parameters
Type Name Description
System.String destinationName
IMessage message
| Edit this page View Source

SendAndReceive(String, IMessage)

Declaration
public virtual IMessage SendAndReceive(string destinationName, IMessage requestMessage)
Parameters
Type Name Description
System.String destinationName
IMessage requestMessage
Returns
Type Description
IMessage
| Edit this page View Source

SendAndReceiveAsync(String, IMessage, CancellationToken)

Declaration
public virtual Task<IMessage> SendAndReceiveAsync(string destinationName, IMessage requestMessage, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
IMessage requestMessage
CancellationToken cancellationToken
Returns
Type Description
Task<IMessage>
| Edit this page View Source

SendAsync(String, IMessage, CancellationToken)

Declaration
public virtual Task SendAsync(string destinationName, IMessage message, CancellationToken cancellationToken = null)
Parameters
Type Name Description
System.String destinationName
IMessage message
CancellationToken cancellationToken
Returns
Type Description
Task

Implements