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
Очередь сообщений.
State
public ChannelStates State { get; private set; }
value = inMemoryMessageChannel.State
inMemoryMessageChannel.State = value
Получает базовое хранилище.
Методы
Clone
public virtual IMessageChannel Clone()
result = inMemoryMessageChannel.Clone()
Создает глубокую копию DataSeries.
DisposeManaged
protected override void DisposeManaged()
inMemoryMessageChannel.DisposeManaged()
Освободите ресурсы.
События
NewOutMessageAsync
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
inMemoryMessageChannel.NewOutMessageAsync += handler
Новое событие сообщения.
StateChanged
public event Action StateChanged
inMemoryMessageChannel.StateChanged += handler
Событие изменения состояния.