InMemoryMessageChannel

StockSharp.Messages

Canal de mensagem, baseado na fila e operando dentro de um único processo.

Herda de: Disposable

Implementa: IMessageChannel, IMessageTransport, IDisposable, ICloneable<IMessageChannel>, ICloneable

Construtores

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

Inicializa uma nova instância do InMemoryMessageChannel.

queue
Fila de mensagens.
name
Nome do canal.
errorHandler
Tratamento de erros.

Propriedades

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

O canal não pode ser aberto.

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

Contagem de fila de mensagens.

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

Nome do encarregado.

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

Obtém o armazenamento do estado subjacente.

Métodos

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

Cria uma cópia profunda de DataSeries

Close
public void Close()
inMemoryMessageChannel.Close()

Preço de fecho.

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

Libertar recursos.

Open
public void Open()
inMemoryMessageChannel.Open()

Preço de abertura.

Eventos

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

Novo evento de mensagem.

StateChanged
public event Action StateChanged
inMemoryMessageChannel.StateChanged += handler

Evento de mudança de estado.