X

Class MessageChannelTemplate

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

Constructors

| Edit this page View Source

MessageChannelTemplate(IApplicationContext, ILogger)

Declaration
public MessageChannelTemplate(IApplicationContext context, ILogger logger = null)
Parameters
Type Name Description
IApplicationContext context
ILogger logger
| Edit this page View Source

MessageChannelTemplate(ILogger)

Declaration
public MessageChannelTemplate(ILogger logger = null)
Parameters
Type Name Description
ILogger logger

Fields

| Edit this page View Source

DEFAULT_RECEIVE_TIMEOUT_HEADER

Declaration
public const string DEFAULT_RECEIVE_TIMEOUT_HEADER = null
Field Value
Type Description
System.String
| Edit this page View Source

DEFAULT_SEND_TIMEOUT_HEADER

Declaration
public const string DEFAULT_SEND_TIMEOUT_HEADER = null
Field Value
Type Description
System.String

Properties

| Edit this page View Source

ReceiveTimeout

Declaration
public virtual int ReceiveTimeout { get; set; }
Property Value
Type Description
System.Int32
| Edit this page View Source

ReceiveTimeoutHeader

Declaration
public virtual string ReceiveTimeoutHeader { get; set; }
Property Value
Type Description
System.String
| Edit this page View Source

SendTimeout

Declaration
public virtual int SendTimeout { get; set; }
Property Value
Type Description
System.Int32
| Edit this page View Source

SendTimeoutHeader

Declaration
public virtual string SendTimeoutHeader { get; set; }
Property Value
Type Description
System.String
| Edit this page View Source

ThrowExceptionOnLateReply

Declaration
public virtual bool ThrowExceptionOnLateReply { get; set; }
Property Value
Type Description
System.Boolean

Methods

| Edit this page View Source

DoReceive(IMessageChannel)

Declaration
protected override IMessage DoReceive(IMessageChannel destination)
Parameters
Type Name Description
IMessageChannel destination
Returns
Type Description
IMessage
Overrides
Steeltoe.Messaging.Core.AbstractMessageReceivingTemplate<Steeltoe.Messaging.IMessageChannel>.DoReceive(Steeltoe.Messaging.IMessageChannel)
| Edit this page View Source

DoReceive(IMessageChannel, Int32)

Declaration
protected IMessage DoReceive(IMessageChannel channel, int timeout)
Parameters
Type Name Description
IMessageChannel channel
System.Int32 timeout
Returns
Type Description
IMessage
| Edit this page View Source

DoReceiveAsync(IMessageChannel, CancellationToken)

Declaration
protected override Task<IMessage> DoReceiveAsync(IMessageChannel destination, CancellationToken cancellationToken)
Parameters
Type Name Description
IMessageChannel destination
CancellationToken cancellationToken
Returns
Type Description
Task<IMessage>
Overrides
Steeltoe.Messaging.Core.AbstractMessageReceivingTemplate<Steeltoe.Messaging.IMessageChannel>.DoReceiveAsync(Steeltoe.Messaging.IMessageChannel, CancellationToken)
| Edit this page View Source

DoReceiveAsync(IMessageChannel, Int32, CancellationToken)

Declaration
protected Task<IMessage> DoReceiveAsync(IMessageChannel channel, int timeout, CancellationToken cancellationToken = null)
Parameters
Type Name Description
IMessageChannel channel
System.Int32 timeout
CancellationToken cancellationToken
Returns
Type Description
Task<IMessage>
| Edit this page View Source

DoReceiveInternalAsync(IMessageChannel, Int32, CancellationToken)

Declaration
protected async Task<IMessage> DoReceiveInternalAsync(IMessageChannel channel, int timeout, CancellationToken cancellationToken = null)
Parameters
Type Name Description
IMessageChannel channel
System.Int32 timeout
CancellationToken cancellationToken
Returns
Type Description
Task<IMessage>
| Edit this page View Source

DoSend(IMessageChannel, IMessage)

Declaration
protected override void DoSend(IMessageChannel destination, IMessage message)
Parameters
Type Name Description
IMessageChannel destination
IMessage message
Overrides
Steeltoe.Messaging.Core.AbstractMessageSendingTemplate<Steeltoe.Messaging.IMessageChannel>.DoSend(Steeltoe.Messaging.IMessageChannel, Steeltoe.Messaging.IMessage)
| Edit this page View Source

DoSend(IMessageChannel, IMessage, Int32)

Declaration
protected void DoSend(IMessageChannel channel, IMessage message, int timeout)
Parameters
Type Name Description
IMessageChannel channel
IMessage message
System.Int32 timeout
| Edit this page View Source

DoSendAndReceive(IMessageChannel, IMessage)

Declaration
protected override IMessage DoSendAndReceive(IMessageChannel destination, IMessage requestMessage)
Parameters
Type Name Description
IMessageChannel destination
IMessage requestMessage
Returns
Type Description
IMessage
Overrides
Steeltoe.Messaging.Core.AbstractMessagingTemplate<Steeltoe.Messaging.IMessageChannel>.DoSendAndReceive(Steeltoe.Messaging.IMessageChannel, Steeltoe.Messaging.IMessage)
| Edit this page View Source

DoSendAndReceiveAsync(IMessageChannel, IMessage, CancellationToken)

Declaration
protected override Task<IMessage> DoSendAndReceiveAsync(IMessageChannel destination, IMessage requestMessage, CancellationToken cancellationToken = null)
Parameters
Type Name Description
IMessageChannel destination
IMessage requestMessage
CancellationToken cancellationToken
Returns
Type Description
Task<IMessage>
Overrides
Steeltoe.Messaging.Core.AbstractMessagingTemplate<Steeltoe.Messaging.IMessageChannel>.DoSendAndReceiveAsync(Steeltoe.Messaging.IMessageChannel, Steeltoe.Messaging.IMessage, CancellationToken)
| Edit this page View Source

DoSendAndReceiveInternalAsync(IMessageChannel, IMessage, CancellationToken)

Declaration
protected async Task<IMessage> DoSendAndReceiveInternalAsync(IMessageChannel channel, IMessage requestMessage, CancellationToken cancellationToken = null)
Parameters
Type Name Description
IMessageChannel channel
IMessage requestMessage
CancellationToken cancellationToken
Returns
Type Description
Task<IMessage>
| Edit this page View Source

DoSendAsync(IMessageChannel, IMessage, CancellationToken)

Declaration
protected override Task DoSendAsync(IMessageChannel destination, IMessage message, CancellationToken cancellationToken)
Parameters
Type Name Description
IMessageChannel destination
IMessage message
CancellationToken cancellationToken
Returns
Type Description
Task
Overrides
Steeltoe.Messaging.Core.AbstractMessageSendingTemplate<Steeltoe.Messaging.IMessageChannel>.DoSendAsync(Steeltoe.Messaging.IMessageChannel, Steeltoe.Messaging.IMessage, CancellationToken)
| Edit this page View Source

DoSendAsync(IMessageChannel, IMessage, Int32, CancellationToken)

Declaration
protected Task DoSendAsync(IMessageChannel channel, IMessage message, int timeout, CancellationToken cancellationToken = null)
Parameters
Type Name Description
IMessageChannel channel
IMessage message
System.Int32 timeout
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

DoSendInternalAsync(IMessageChannel, IMessage, Int32, CancellationToken)

Declaration
protected async Task DoSendInternalAsync(IMessageChannel channel, IMessage message, int timeout, CancellationToken cancellationToken = null)
Parameters
Type Name Description
IMessageChannel channel
IMessage message
System.Int32 timeout
CancellationToken cancellationToken
Returns
Type Description
Task
| Edit this page View Source

ProcessMessageBeforeSend(IMessage)

Declaration
protected virtual IMessage ProcessMessageBeforeSend(IMessage message)
Parameters
Type Name Description
IMessage message
Returns
Type Description
IMessage

Implements