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 UTC 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

Parent.

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.

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.

Load

public virtual void Load(SettingsStorage storage)

messageAdapterWrapper.Load(storage)

Load settings.

storage

Settings storage.

LogDebug

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

messageAdapterWrapper.LogDebug(message, args)

LogError

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

messageAdapterWrapper.LogError(message, args)

LogInfo

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

messageAdapterWrapper.LogInfo(message, args)

LogVerbose

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

messageAdapterWrapper.LogVerbose(message, args)

LogWarning

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

messageAdapterWrapper.LogWarning(message, args)

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.

Save

public virtual void Save(SettingsStorage storage)

messageAdapterWrapper.Save(storage)

Save settings.

storage

Settings storage.

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: Строковое представление.

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

messageAdapterWrapper.NewOutMessageAsync += handler

New message event.

ParentRemoved

public event Action<ILogSource> ParentRemoved

messageAdapterWrapper.ParentRemoved += handler