MessageAdapterWrapper

MessageAdapterWrapper

protected MessageAdapterWrapper(IMessageAdapter innerAdapter)

messageAdapterWrapper = MessageAdapterWrapper(innerAdapter)

Initialize MessageAdapterWrapper.

innerAdapter

Underlying adapter.

CandlesBuildFrom

public IEnumerable<Level1Fields> CandlesBuildFrom { get; }

value = messageAdapterWrapper.CandlesBuildFrom

Possible options for candles building.

Categories

public virtual MessageAdapterCategories Categories { get; }

value = messageAdapterWrapper.Categories

Message adapter categories.

CheckTimeFrameByRequest

public bool CheckTimeFrameByRequest { get; }

value = messageAdapterWrapper.CheckTimeFrameByRequest

Check possible time-frame by request.

CurrentTime

public DateTime CurrentTime { get; }

value = messageAdapterWrapper.CurrentTime

Current time, which will be passed to the Time.

HeartbeatInterval

public TimeSpan HeartbeatInterval { get; set; }

value = messageAdapterWrapper.HeartbeatInterval
messageAdapterWrapper.HeartbeatInterval = value

Server check interval for track the connection alive. The value is Zero turned off tracking.

InnerAdapter

public IMessageAdapter InnerAdapter { get; set; }

value = messageAdapterWrapper.InnerAdapter
messageAdapterWrapper.InnerAdapter = value

Underlying adapter.

IsFullCandlesOnly

public virtual bool IsFullCandlesOnly { get; }

value = messageAdapterWrapper.IsFullCandlesOnly

Translates CandleMessage as only fully filled.

IsNativeIdentifiers

public virtual bool IsNativeIdentifiers { get; }

value = messageAdapterWrapper.IsNativeIdentifiers

Identify security in messages by native identifier Native.

IsNativeIdentifiersPersistable

public virtual bool IsNativeIdentifiersPersistable { get; }

value = messageAdapterWrapper.IsNativeIdentifiersPersistable

Native identifier can be stored.

IsPositionsEmulationRequired

public virtual bool? IsPositionsEmulationRequired { get; }

value = messageAdapterWrapper.IsPositionsEmulationRequired

Adapter required emulation PositionChangeMessage.

IsSecurityNewsOnly

public virtual bool IsSecurityNewsOnly { get; }

value = messageAdapterWrapper.IsSecurityNewsOnly

Adapter provides news related with specified security.

IsSupportExecutionsPnL

public virtual bool IsSupportExecutionsPnL { get; }

value = messageAdapterWrapper.IsSupportExecutionsPnL

Adapter fills PnL.

IsSupportOrderBookIncrements

public virtual bool IsSupportOrderBookIncrements { get; }

value = messageAdapterWrapper.IsSupportOrderBookIncrements

Adapter translates incremental order books.

IsSupportSubscriptions

public virtual bool IsSupportSubscriptions { get; }

value = messageAdapterWrapper.IsSupportSubscriptions

Support any subscriptions (ticks, order books etc.).

IsSupportTransactionLog

public virtual bool IsSupportTransactionLog { get; }

value = messageAdapterWrapper.IsSupportTransactionLog

Adapter translates orders changes on reply of OrderStatusMessage.

NotSupportedResultMessages

public virtual IEnumerable<MessageTypes> NotSupportedResultMessages { get; }

value = messageAdapterWrapper.NotSupportedResultMessages

Not supported by adapter result message types.

OwnInnerAdapter

public bool OwnInnerAdapter { get; set; }

value = messageAdapterWrapper.OwnInnerAdapter
messageAdapterWrapper.OwnInnerAdapter = value

Control InnerAdapter lifetime.

Parent

public virtual ILogSource Parent { get; set; }

value = messageAdapterWrapper.Parent
messageAdapterWrapper.Parent = value

Parental logs source.

PossibleSupportedMessages

public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; }

value = messageAdapterWrapper.PossibleSupportedMessages

Possible supported by adapter message types.

ReConnectionSettings

public ReConnectionSettings ReConnectionSettings { get; }

value = messageAdapterWrapper.ReConnectionSettings

Connection tracking settings IMessageAdapter with a server.

SendInBackFurther

protected virtual bool SendInBackFurther { get; }

value = messageAdapterWrapper.SendInBackFurther

Auto send BackMode messages to InnerAdapter.

StorageName

public string StorageName { get; }

value = messageAdapterWrapper.StorageName

The storage name, associated with the adapter.

SupportedInMessages

public virtual IEnumerable<MessageTypes> SupportedInMessages { get; set; }

value = messageAdapterWrapper.SupportedInMessages
messageAdapterWrapper.SupportedInMessages = value

Supported by adapter message types.

SupportedOrderBookDepths

public virtual IEnumerable<int> SupportedOrderBookDepths { get; }

value = messageAdapterWrapper.SupportedOrderBookDepths

Available options for MaxDepth.

TransactionIdGenerator

public IdGenerator TransactionIdGenerator { get; }

value = messageAdapterWrapper.TransactionIdGenerator

Transaction id generator.

CloneAsync

public abstract ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)

result = messageAdapterWrapper.CloneAsync(cancellationToken)

Create a copy of the adapter.

cancellationToken

CancellationToken

Returns: Copy.

Dispose

public virtual void Dispose()

messageAdapterWrapper.Dispose()

Disposes of items in the pool that implement IDisposable.

GetSupportedMarketDataTypesAsync

public virtual IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)

result = messageAdapterWrapper.GetSupportedMarketDataTypesAsync(securityId, from, to)

Get supported by adapter message types.

securityId

SecurityId

from

Start date for request. If , then all available messages will be returned.

to

End date for request. If , then all available messages will be returned.

Returns: Supported by adapter market data types.

InnerAdapterNewOutMessageAsync

protected virtual ValueTask InnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapterWrapper.InnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message

The message.

cancellationToken

Cancellation token.

IsAllDownloadingSupported

public virtual bool IsAllDownloadingSupported(DataType dataType)

result = messageAdapterWrapper.IsAllDownloadingSupported(dataType)

Is for the specified all securities downloading enabled.

dataType

Data type info.

Returns: Check result.

IsSecurityRequired

public virtual bool IsSecurityRequired(DataType dataType)

result = messageAdapterWrapper.IsSecurityRequired(dataType)

Support filtering subscriptions (subscribe/unsubscribe for specified security).

dataType

Data type info.

Returns: Check result.

IsSupportCandlesPriceLevels

public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)

result = messageAdapterWrapper.IsSupportCandlesPriceLevels(subscription)

Support candles PriceLevels.

subscription

MarketDataMessage

Returns: Check result.

IsSupportCandlesUpdates

public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)

result = messageAdapterWrapper.IsSupportCandlesUpdates(subscription)

Support candles subscription and live updates.

subscription

MarketDataMessage

Returns: Check result.

LoadAsync

public virtual Task LoadAsync(SettingsStorage storage, CancellationToken cancellationToken)

result = messageAdapterWrapper.LoadAsync(storage, cancellationToken)

Load settings.

storage

Settings storage.

cancellationToken

CancellationToken

Returns: Task

LogDebug

public void LogDebug(string message, object[] args)

messageAdapterWrapper.LogDebug(message, args)

To record a debug message to the log.

message

Text message.

args

Text message settings. Used if a message is the format string. For details, see Object[]).

LogError

public void LogError(string message, object[] args)

messageAdapterWrapper.LogError(message, args)

To record an error to the log.

message

Text message.

args

Text message settings. Used if a message is the format string. For details, see Object[]).

LogInfo

public void LogInfo(string message, object[] args)

messageAdapterWrapper.LogInfo(message, args)

To record a message to the log.

message

Text message.

args

Text message settings. Used if a message is the format string. For details, see Object[]).

LogVerbose

public void LogVerbose(string message, object[] args)

messageAdapterWrapper.LogVerbose(message, args)

To record a verbose message to the log.

message

Text message.

args

Text message settings. Used if a message is the format string. For details, see Object[]).

LogWarning

public void LogWarning(string message, object[] args)

messageAdapterWrapper.LogWarning(message, args)

To record a warning to the log.

message

Text message.

args

Text message settings. Used if a message is the format string. For details, see Object[]).

OnInnerAdapterNewOutMessageAsync

protected virtual ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapterWrapper.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message

The message.

cancellationToken

Cancellation token.

OnSendInMessageAsync

protected virtual ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapterWrapper.OnSendInMessageAsync(message, cancellationToken)

Send message.

message

Message.

cancellationToken

CancellationToken

RaiseNewOutMessageAsync

protected ValueTask RaiseNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapterWrapper.RaiseNewOutMessageAsync(message, cancellationToken)

To call the event NewOutMessageAsync.

message

The message.

cancellationToken

Cancellation token.

SaveAsync

public virtual Task SaveAsync(SettingsStorage storage, CancellationToken cancellationToken)

result = messageAdapterWrapper.SaveAsync(storage, cancellationToken)

Save settings.

storage

Settings storage.

cancellationToken

CancellationToken

Returns: Task

SendInMessageAsync

public virtual ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapterWrapper.SendInMessageAsync(message, cancellationToken)

Processes a generic message asynchronously.

message

The message to process.

cancellationToken

CancellationToken

ToString

public override string ToString()

result = messageAdapterWrapper.ToString()

Returns a string representation of the tuple, with values separated by commas.

Returns: A string representing the tuple's values.

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

messageAdapterWrapper.NewOutMessageAsync += handler

New message event.

ParentRemoved

public event Action<ILogSource> ParentRemoved

messageAdapterWrapper.ParentRemoved += handler

Parent removed.