InMemoryMessageChannel
StockSharp.Messages
Message channel, based on the queue and operate within a single process.
继承自: Disposable
实现: IMessageChannel, IMessageTransport, IDisposable, ICloneable<IMessageChannel>, ICloneable
构造函数
InMemoryMessageChannel(IMessageQueue, string, Action<Exception>)
Initializes a new instance of the InMemoryMessageChannel.
- queue
- Message queue.
- name
- Channel name.
- errorHandler
- Error handler.
属性
MessageCount : int
Message queue count.
State : ChannelStates
Gets the underlying state storage.
方法
Clone() : IMessageChannel
Creates a deep copy of a DataSeries
Close()
Closing price.
DisposeManaged()
Release resources.
Open()
Opening price.
事件
NewOutMessageAsync : Func<Message, CancellationToken, ValueTask>
New message event.
StateChanged : Action
State change event.