InMemoryMessageChannel

StockSharp.Messages

Nachrichtenkanal, basierend auf der Warteschlange und arbeiten innerhalb eines einzigen Prozesses.

Konstruktoren

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

inMemoryMessageChannel = InMemoryMessageChannel(queue, name, errorHandler)

Initialisiert eine neue Instanz von InMemoryMessageChannel.

Disabled

public bool Disabled { get; set; }

value = inMemoryMessageChannel.Disabled
inMemoryMessageChannel.Disabled = value

Der Kanal kann nicht geöffnet werden.

MessageCount

public int MessageCount { get; }

value = inMemoryMessageChannel.MessageCount

Anzahl der Nachrichtenwarteschlange.

Name

public string Name { get; }

value = inMemoryMessageChannel.Name

Name des Bearbeiters.

State

public ChannelStates State { get; private set; }

value = inMemoryMessageChannel.State
inMemoryMessageChannel.State = value

Bekommt den zugrunde liegenden Zustandsspeicher.

Clone

public virtual IMessageChannel Clone()

result = inMemoryMessageChannel.Clone()

Erstellt eine tiefe Kopie eines DataSeries

Rückgabe: A new object that is a deep copy of this instance.

public void Close()

inMemoryMessageChannel.Close()

Schlusspreis.

protected override void DisposeManaged()

inMemoryMessageChannel.DisposeManaged()

Ressourcen freigeben.

Open

public void Open()

inMemoryMessageChannel.Open()

Eröffnungspreis.

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

inMemoryMessageChannel.NewOutMessageAsync += handler

Neues Nachrichtenereignis.

StateChanged

public event Action StateChanged

inMemoryMessageChannel.StateChanged += handler

Ereignis der Zustandsänderung.