IQueueAdapter Schnittstelle

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.1.0

Streamwarteschlangenspeicheradapter. Dies ist eine Abstraktionsebene, die die Implementierungsdetails des zugrunde liegenden Warteschlangensystems ausblendet.

public interface IQueueAdapter

type IQueueAdapter = interface

Public Interface IQueueAdapter

Abgeleitet

Orleans.Providers.MemoryAdapterFactory<TSerializer>

Orleans.Providers.Streams.Generator.GeneratorAdapterFactory

Orleans.ServiceBus.Providers.EventHubAdapterFactory

Orleans.Streaming.EventHubs.EventHubAdapterFactory

Eigenschaften

Direction	Ruft die Richtung dieses Warteschlangenadapters ab: ReadOnly, WriteOnlyoder ReadWrite.
IsRewindable	Ruft einen Wert ab, der angibt, ob es sich um einen wieder aufwickelbaren Streamadapter handelt. Unterstützt das Abonnieren vom vorherigen Zeitpunkt.
Name	Ruft den Namen des Adapters ab. In erster Linie für Protokollierungszwecke

Methoden

CreateReceiver(QueueId)	Erstellt einen Warteschlangenempfänger für die angegebene queueId
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Schreibt einen Satz von Ereignissen in die Warteschlange als einzelnen Batch, der der bereitgestellten streamId zugeordnet ist.

Erweiterungsmethoden

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)

Schreibt einen Satz von Ereignissen in die Warteschlange als einzelnen Batch, der dem bereitgestellten streamIdzugeordnet ist.