LookupTrackingMessageAdapter

LookupTrackingMessageAdapter

public LookupTrackingMessageAdapter(IMessageAdapter innerAdapter, ILookupTrackingManagerState state)

lookupTrackingMessageAdapter = LookupTrackingMessageAdapter(innerAdapter, state)

Message adapter that tracks multiple lookups requests and put them into single queue.

innerAdapter

Inner message adapter.

state

State storage.

TimeOut

private TimeSpan TimeOut { get; set; }

value = lookupTrackingMessageAdapter.TimeOut
lookupTrackingMessageAdapter.TimeOut = value

Securities and portfolios lookup timeout.

Clone

public override IMessageAdapter Clone()

result = lookupTrackingMessageAdapter.Clone()

Create a copy of LookupTrackingMessageAdapter.

Returns: Copy.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = lookupTrackingMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message

The message.

cancellationToken

Cancellation token.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = lookupTrackingMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Send message.

message

Message.

cancellationToken

CancellationToken