Class MessagingTemplate

Namespace

Steeltoe.Integration

Assembly

Steeltoe.Integration.IntegrationBase.dll

[Obsolete("This feature will be removed in the next major version. See https://steeltoe.io/docs/v3/obsolete for details.")]
public class MessagingTemplate : MessageChannelTemplate, IDestinationResolvingMessageSendingOperations<IMessageChannel>, IMessageSendingOperations<IMessageChannel>, IDestinationResolvingMessageReceivingOperations<IMessageChannel>, IMessageReceivingOperations<IMessageChannel>, IDestinationResolvingMessageRequestReplyOperations<IMessageChannel>, IMessageRequestReplyOperations<IMessageChannel>

Inheritance

object

AbstractMessageSendingTemplate<IMessageChannel>

AbstractMessageReceivingTemplate<IMessageChannel>

AbstractMessagingTemplate<IMessageChannel>

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>

MessageChannelTemplate

MessagingTemplate

Implements

IDestinationResolvingMessageSendingOperations<IMessageChannel>

IMessageSendingOperations<IMessageChannel>

IDestinationResolvingMessageReceivingOperations<IMessageChannel>

IMessageReceivingOperations<IMessageChannel>

IDestinationResolvingMessageRequestReplyOperations<IMessageChannel>

IMessageRequestReplyOperations<IMessageChannel>

Inherited Members

MessageChannelTemplate.DEFAULT_SEND_TIMEOUT_HEADER

MessageChannelTemplate.DEFAULT_RECEIVE_TIMEOUT_HEADER

MessageChannelTemplate.SendTimeout

MessageChannelTemplate.ReceiveTimeout

MessageChannelTemplate.SendTimeoutHeader

MessageChannelTemplate.ReceiveTimeoutHeader

MessageChannelTemplate.ThrowExceptionOnLateReply

MessageChannelTemplate.ProcessMessageBeforeSend(IMessage)

MessageChannelTemplate.DoSend(IMessageChannel, IMessage)

MessageChannelTemplate.DoSend(IMessageChannel, IMessage, int)

MessageChannelTemplate.DoSendAsync(IMessageChannel, IMessage, CancellationToken)

MessageChannelTemplate.DoSendAsync(IMessageChannel, IMessage, int, CancellationToken)

MessageChannelTemplate.DoSendInternalAsync(IMessageChannel, IMessage, int, CancellationToken)

MessageChannelTemplate.DoReceive(IMessageChannel)

MessageChannelTemplate.DoReceive(IMessageChannel, int)

MessageChannelTemplate.DoReceiveAsync(IMessageChannel, CancellationToken)

MessageChannelTemplate.DoReceiveAsync(IMessageChannel, int, CancellationToken)

MessageChannelTemplate.DoReceiveInternalAsync(IMessageChannel, int, CancellationToken)

MessageChannelTemplate.DoSendAndReceiveAsync(IMessageChannel, IMessage, CancellationToken)

MessageChannelTemplate.DoSendAndReceiveInternalAsync(IMessageChannel, IMessage, CancellationToken)

MessageChannelTemplate.DoSendAndReceive(IMessageChannel, IMessage)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ApplicationContext

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.DestinationResolver

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertAndSendAsync(string, object, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertAndSendAsync(string, object, IDictionary<string, object>, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertAndSendAsync(string, object, IMessagePostProcessor, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertAndSendAsync(string, object, IDictionary<string, object>, IMessagePostProcessor, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(string, object, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(string, object, IDictionary<string, object>, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(string, object, IMessagePostProcessor, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(string, object, IDictionary<string, object>, IMessagePostProcessor, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ReceiveAsync(string, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ReceiveAndConvertAsync<T>(string, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.SendAsync(string, IMessage, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.SendAndReceiveAsync(string, IMessage, CancellationToken)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertAndSend(string, object)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertAndSend(string, object, IDictionary<string, object>)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertAndSend(string, object, IMessagePostProcessor)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertAndSend(string, object, IDictionary<string, object>, IMessagePostProcessor)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(string, object)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(string, object, IDictionary<string, object>)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(string, object, IMessagePostProcessor)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(string, object, IDictionary<string, object>, IMessagePostProcessor)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.Receive(string)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ReceiveAndConvert<T>(string)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.Send(string, IMessage)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.SendAndReceive(string, IMessage)

AbstractDestinationResolvingMessagingTemplate<IMessageChannel>.ResolveDestination(string)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(object, CancellationToken)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(IMessageChannel, object, CancellationToken)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(IMessageChannel, object, IDictionary<string, object>, CancellationToken)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(object, IMessagePostProcessor, CancellationToken)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(IMessageChannel, object, IMessagePostProcessor, CancellationToken)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceiveAsync<T>(IMessageChannel, object, IDictionary<string, object>, IMessagePostProcessor, CancellationToken)

AbstractMessagingTemplate<IMessageChannel>.SendAndReceiveAsync(IMessage, CancellationToken)

AbstractMessagingTemplate<IMessageChannel>.SendAndReceiveAsync(IMessageChannel, IMessage, CancellationToken)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(object)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(IMessageChannel, object)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(IMessageChannel, object, IDictionary<string, object>)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(object, IMessagePostProcessor)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(IMessageChannel, object, IMessagePostProcessor)

AbstractMessagingTemplate<IMessageChannel>.ConvertSendAndReceive<T>(IMessageChannel, object, IDictionary<string, object>, IMessagePostProcessor)

AbstractMessagingTemplate<IMessageChannel>.SendAndReceive(IMessage)

AbstractMessageReceivingTemplate<IMessageChannel>.ThrowReceivedExceptions

AbstractMessageReceivingTemplate<IMessageChannel>.ReceiveAsync(CancellationToken)

AbstractMessageReceivingTemplate<IMessageChannel>.ReceiveAsync(IMessageChannel, CancellationToken)

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

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

AbstractMessageReceivingTemplate<IMessageChannel>.Receive()

AbstractMessageReceivingTemplate<IMessageChannel>.Receive(IMessageChannel)

AbstractMessageReceivingTemplate<IMessageChannel>.ReceiveAndConvert<T>()

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

AbstractMessageReceivingTemplate<IMessageChannel>.RequiredDefaultReceiveDestination

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

AbstractMessageSendingTemplate<IMessageChannel>.CONVERSION_HINT_HEADER

AbstractMessageSendingTemplate<IMessageChannel>.MessageConverter

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSendAsync(object, CancellationToken)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSendAsync(IMessageChannel, object, CancellationToken)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSendAsync(IMessageChannel, object, IDictionary<string, object>, CancellationToken)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSendAsync(object, IMessagePostProcessor, CancellationToken)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSendAsync(IMessageChannel, object, IMessagePostProcessor, CancellationToken)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSendAsync(IMessageChannel, object, IDictionary<string, object>, IMessagePostProcessor, CancellationToken)

AbstractMessageSendingTemplate<IMessageChannel>.SendAsync(IMessage, CancellationToken)

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

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSend(object)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSend(IMessageChannel, object)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSend(IMessageChannel, object, IDictionary<string, object>)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSend(object, IMessagePostProcessor)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSend(IMessageChannel, object, IMessagePostProcessor)

AbstractMessageSendingTemplate<IMessageChannel>.ConvertAndSend(IMessageChannel, object, IDictionary<string, object>, IMessagePostProcessor)

AbstractMessageSendingTemplate<IMessageChannel>.Send(IMessage)

AbstractMessageSendingTemplate<IMessageChannel>.Send(IMessageChannel, IMessage)

AbstractMessageSendingTemplate<IMessageChannel>.RequiredDefaultSendDestination

AbstractMessageSendingTemplate<IMessageChannel>.DoConvert(object, IDictionary<string, object>, IMessagePostProcessor)

AbstractMessageSendingTemplate<IMessageChannel>.ProcessHeadersToSend(IDictionary<string, object>)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

MessagingTemplate(IApplicationContext, ILogger)

public MessagingTemplate(IApplicationContext context, ILogger logger = null)

Parameters

context IApplicationContext

logger ILogger

MessagingTemplate(IApplicationContext, IMessageChannel, ILogger)

public MessagingTemplate(IApplicationContext context, IMessageChannel defaultChannel, ILogger logger = null)

Parameters

context IApplicationContext

defaultChannel IMessageChannel

logger ILogger

Properties

DefaultDestination

public IMessageChannel DefaultDestination { get; set; }

Property Value

IMessageChannel

DefaultReceiveDestination

public override IMessageChannel DefaultReceiveDestination { get; set; }

Property Value

IMessageChannel

DefaultSendDestination

public override IMessageChannel DefaultSendDestination { get; set; }

Property Value

IMessageChannel

Methods

Receive(IMessageChannel, int)

public IMessage Receive(IMessageChannel destination, int timeout)

Parameters

destination IMessageChannel

timeout int

Returns

IMessage

ReceiveAndConvert(IMessageChannel, int)

public object ReceiveAndConvert(IMessageChannel destination, int timeout)

Parameters

destination IMessageChannel

timeout int

Returns

object

SendAndReceive(IMessageChannel, IMessage)

Send a request message and receive the reply from the given destination.

public override IMessage SendAndReceive(IMessageChannel destination, IMessage requestMessage)

Parameters

destination IMessageChannel

the target destination

requestMessage IMessage

the message to send

Returns

IMessage

the receieved message; or null