InMemoryMessageChannel

StockSharp.Messages

Canal de mensaje, basado en la cola y operando dentro de un solo proceso.

Hereda de: Disposable

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

Constructores

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

Inicia una nueva instancia de la InMemoryMessageChannel.

queue
Mensaje.
name
Nombre del canal.
errorHandler
Manejador de error.

Propiedades

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

El canal no puede ser abierto.

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

Cuenta de cola de mensaje.

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

Nombre de manutención.

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

Consigue el almacenamiento estatal subyacente.

Métodos

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

Crea una copia profunda de un DataSeries

Close
public void Close()
inMemoryMessageChannel.Close()

Precio de cierre.

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

Libera recursos.

Open
public void Open()
inMemoryMessageChannel.Open()

Precio de apertura.

Eventos

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

Nuevo evento de mensaje.

StateChanged
public event Action StateChanged
inMemoryMessageChannel.StateChanged += handler

Acto de cambio de Estado.