ChannelMessageAdapter

ChannelMessageAdapter

public ChannelMessageAdapter(IMessageAdapter innerAdapter, IMessageChannel inputChannel, IMessageChannel outputChannel)

channelMessageAdapter = ChannelMessageAdapter(innerAdapter, inputChannel, outputChannel)

Initializes a new instance of the ChannelMessageAdapter.

innerAdapter

Underlying adapter.

inputChannel

Incoming messages channel.

outputChannel

Outgoing message channel.

InputChannel

public IMessageChannel InputChannel { get; }

value = channelMessageAdapter.InputChannel

Adapter.

OutputChannel

public IMessageChannel OutputChannel { get; }

value = channelMessageAdapter.OutputChannel

Adapter.

OwnInputChannel

public bool OwnInputChannel { get; set; }

value = channelMessageAdapter.OwnInputChannel
channelMessageAdapter.OwnInputChannel = value

Control the lifetime of the incoming messages channel.

OwnOutputChannel

public bool OwnOutputChannel { get; set; }

value = channelMessageAdapter.OwnOutputChannel
channelMessageAdapter.OwnOutputChannel = value

Control the lifetime of the outgoing messages channel.

Clone

public override IMessageAdapter Clone()

result = channelMessageAdapter.Clone()

Create a copy of ChannelMessageAdapter.

Returns: Copy.

Dispose

public override void Dispose()

channelMessageAdapter.Dispose()

Disposes of items in the pool that implement IDisposable.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message

The message.

cancellationToken

Cancellation token.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Send message.

message

Message.

cancellationToken

CancellationToken