InMemoryMessageChannel

StockSharp.Messages

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

Erbt von: Disposable

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

Konstruktoren

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

Initialisiert eine neue Instanz von InMemoryMessageChannel.

queue
Nachrichtenwarteschlange.
name
Kanalname.
errorHandler
Fehlerbehandler.

Eigenschaften

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.

Methoden

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

Erstellt eine tiefe Kopie eines DataSeries

Close
public void Close()
inMemoryMessageChannel.Close()

Schlusspreis.

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

Ressourcen freigeben.

Open
public void Open()
inMemoryMessageChannel.Open()

Eröffnungspreis.

Ereignisse

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

Neues Nachrichtenereignis.

StateChanged
public event Action StateChanged
inMemoryMessageChannel.StateChanged += handler

Ereignis der Zustandsänderung.