InMemoryMessageChannel

StockSharp.Messages

Канал сообщений основан на очереди и работает в рамках одного процесса.

Наследует: Disposable

Реализует: IMessageChannel, IMessageTransport, IDisposable, ICloneable<IMessageChannel>, ICloneable

Конструкторы

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

Инициализирует новый экземпляр InMemoryMessageChannel.

queue
Очередь сообщений.
name
Название канала.
errorHandler
Обработчик ошибок.

Свойства

Disabled
public bool Disabled { get; set; }
value = inMemoryMessageChannel.Disabled
inMemoryMessageChannel.Disabled = value

Канал не может быть открыт.

MessageCount
public int MessageCount { get; }
value = inMemoryMessageChannel.MessageCount

Очередь сообщений.

Name
public string Name { get; }
value = inMemoryMessageChannel.Name

Имя владельца.

State
public ChannelStates State { get; private set; }
value = inMemoryMessageChannel.State
inMemoryMessageChannel.State = value

Получает базовое хранилище.

Методы

Clone
public virtual IMessageChannel Clone()
result = inMemoryMessageChannel.Clone()

Создает глубокую копию DataSeries.

Close
public void Close()
inMemoryMessageChannel.Close()

Цена закрытия.

DisposeManaged
protected override void DisposeManaged()
inMemoryMessageChannel.DisposeManaged()

Освободите ресурсы.

Open
public void Open()
inMemoryMessageChannel.Open()

Цена открытия.

События

NewOutMessageAsync
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
inMemoryMessageChannel.NewOutMessageAsync += handler

Новое событие сообщения.

StateChanged
public event Action StateChanged
inMemoryMessageChannel.StateChanged += handler

Событие изменения состояния.