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()

Creates a deep copy of a 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

州变事.