InMemoryMessageChannel

StockSharp.Messages

Message channel, based on the queue and operate within a single process.

Inherits: Disposable

Constructors

public InMemoryMessageChannel(IMessageQueue queue, string name, Action<Exception> errorHandler)

inMemoryMessageChannel = InMemoryMessageChannel(queue, name, errorHandler)

Initializes a new instance of the InMemoryMessageChannel.

Disabled

public bool Disabled { get; set; }

value = inMemoryMessageChannel.Disabled
inMemoryMessageChannel.Disabled = value

The channel cannot be opened.

MessageCount

public int MessageCount { get; }

value = inMemoryMessageChannel.MessageCount

Message queue count.

Name

public string Name { get; }

value = inMemoryMessageChannel.Name

Handler name.

State

public ChannelStates State { get; private set; }

value = inMemoryMessageChannel.State
inMemoryMessageChannel.State = value

State.

Clone

public virtual IMessageChannel Clone()

result = inMemoryMessageChannel.Clone()

Creates a deep copy of a DataSeries

public void Close()

inMemoryMessageChannel.Close()

Close channel.

protected override void DisposeManaged()

inMemoryMessageChannel.DisposeManaged()

Release resources.

Open

public void Open()

inMemoryMessageChannel.Open()

Open channel.

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

inMemoryMessageChannel.NewOutMessageAsync += handler

New message event.

StateChanged

public event Action StateChanged

inMemoryMessageChannel.StateChanged += handler

State change event.