Table of Contents

Class BufferMessageAdapter

Namespace
StockSharp.Algo.Storages
Assembly
StockSharp.Algo.dll

Buffered message adapter.

public class BufferMessageAdapter : MessageAdapterWrapper, IMessageAdapterWrapper, IMessageAdapter, IMessageChannel, ICloneable<IMessageChannel>, ICloneable, IPersistable, ILogReceiver, ILogSource, IDisposable
Inheritance
BufferMessageAdapter
Implements
ICloneable<IMessageChannel>
IPersistable
Inherited Members
Extension Methods

Constructors

BufferMessageAdapter(IMessageAdapter, StorageCoreSettings, StorageBuffer, SnapshotRegistry)

Initializes a new instance of the BufferMessageAdapter.

public BufferMessageAdapter(IMessageAdapter innerAdapter, StorageCoreSettings settings, StorageBuffer buffer, SnapshotRegistry snapshotRegistry)

Parameters

innerAdapter IMessageAdapter

Underlying adapter.

settings StorageCoreSettings

Storage settings.

buffer StorageBuffer

Storage buffer.

snapshotRegistry SnapshotRegistry

Snapshot storage registry.

Properties

Buffer

Storage buffer.

public StorageBuffer Buffer { get; }

Property Value

StorageBuffer

Settings

Storage settings.

public StorageCoreSettings Settings { get; }

Property Value

StorageCoreSettings

SnapshotRegistry

Snapshot storage registry.

public SnapshotRegistry SnapshotRegistry { get; }

Property Value

SnapshotRegistry

Methods

Clone()

Create a copy of BufferMessageAdapter.

public override IMessageChannel Clone()

Returns

IMessageChannel

Copy.

OnInnerAdapterNewOutMessage(Message)

Process InnerAdapter output message.

protected override void OnInnerAdapterNewOutMessage(Message message)

Parameters

message Message

The message.

OnSendInMessage(Message)

Send message.

protected override bool OnSendInMessage(Message message)

Parameters

message Message

Message.

Returns

bool

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