Class StorageMessageAdapter

Storage based message adapter.

Inheritance
Object
MessageAdapterWrapper
StorageMessageAdapter
Implements
Ecng.Common.ICloneable<IMessageChannel>
Ecng.Serialization.IPersistable
Inherited Members
Namespace: StockSharp.Algo.Storages
Assembly: StockSharp.Algo.dll
Syntax
public class StorageMessageAdapter : MessageAdapterWrapper, IMessageAdapterWrapper, IMessageAdapter, IMessageChannel, ICloneable<IMessageChannel>, ICloneable, IPersistable, ILogReceiver, ILogSource, IDisposable

Constructors

StorageMessageAdapter(IMessageAdapter, StorageProcessor)

Initializes a new instance of the StorageMessageAdapter.

Declaration
public StorageMessageAdapter(IMessageAdapter innerAdapter, StorageProcessor storageProcessor)
Parameters
Type Name Description
IMessageAdapter innerAdapter

The adapter, to which messages will be directed.
StorageProcessor storageProcessor

Storage processor.

Methods

Clone()

Create a copy of StorageMessageAdapter.

Declaration
public override IMessageChannel Clone()
Returns
Type Description
IMessageChannel

Copy.

GetCandleArgs(Type, SecurityId, Nullable<DateTimeOffset>, Nullable<DateTimeOffset>)

Get possible args for the specified candle type and instrument.

Declaration
public override IEnumerable<object> GetCandleArgs(Type candleType, SecurityId securityId, Nullable<DateTimeOffset> from, Nullable<DateTimeOffset> to)
Parameters
Type Name Description
Type candleType

The type of the message CandleMessage.
SecurityId securityId

Security ID.
Nullable<DateTimeOffset> from

The initial date from which you need to get data.
Nullable<DateTimeOffset> to

The final date by which you need to get data.
Returns
Type Description
IEnumerable<Object>

Possible args.
Overrides

OnSendInMessage(Message)

Send message.

Declaration
protected override bool OnSendInMessage(Message message)
Parameters
Type Name Description
Message message

Message.
Returns
Type Description
Boolean

true if the specified message was processed successfully, otherwise, false.
Overrides

Implements

Ecng.Common.ICloneable<>
Ecng.Serialization.IPersistable

Extension Methods