ServiceBusSessionReceiver Klasse

Definition

Namespace:

Azure.Messaging.ServiceBus

Assembly:

Azure.Messaging.ServiceBus.dll

Paket:

Azure.Messaging.ServiceBus v7.17.5

Source:

ServiceBusSessionReceiver.cs

Der ServiceBusSessionReceiver ist für den Empfang und Das Abstellen ServiceBusReceivedMessage von Nachrichten von sitzungsfähigen Warteschlangen und Abonnements verantwortlich. Es wird erstellt, indem aufgerufen AcceptNextSessionAsync(String, String, ServiceBusSessionReceiverOptions, CancellationToken)wird.

public class ServiceBusSessionReceiver : Azure.Messaging.ServiceBus.ServiceBusReceiver

type ServiceBusSessionReceiver = class
    inherit ServiceBusReceiver

Public Class ServiceBusSessionReceiver
Inherits ServiceBusReceiver

Vererbung

Object

ServiceBusReceiver

ServiceBusSessionReceiver

Konstruktoren

ServiceBusSessionReceiver()

Initialisiert eine neue instance der ServiceBusSessionReceiver -Klasse zum Mocking.

Eigenschaften

EntityPath	Der Pfad der Service Bus-Entität, mit der der Empfänger verbunden ist, spezifisch für den Service Bus-Namespace, der ihn enthält. (Geerbt von ServiceBusReceiver)
FullyQualifiedNamespace	Der vollqualifizierte Service Bus-Namespace, dem der Empfänger zugeordnet ist. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net (Geerbt von ServiceBusReceiver)
Identifier	Ein Name, der zum Identifizieren des Empfängerclients verwendet wird. Wenn null oder leer, wird ein zufälliger eindeutiger Wert verwendet. (Geerbt von ServiceBusReceiver)
IsClosed	Gibt an, ob diese ServiceBusSessionReceiver vom Benutzer geschlossen wurde oder ob der zugrunde liegende Sitzungslink geschlossen wurde, weil die Sitzungssperre verloren ging oder der Link getrennt wurde. Wenn dies der Fall ist true, kann der Empfänger nicht für weitere Vorgänge verwendet werden. Wenn dies der Fall istfalse, ist es trotzdem möglich, dass die Sitzungssperre verloren gegangen ist, daher ist es wichtig, weiterhin mit Reason gleich zu SessionLockLostbehandelnServiceBusException.
PrefetchCount	Die Anzahl der Nachrichten, die eifrig von Warteschlangen oder Abonnements angefordert und lokal in die Warteschlange gestellt werden, ohne Rücksicht darauf, ob eine Verarbeitung derzeit aktiv ist, soll dazu beitragen, den Durchsatz zu maximieren, indem der Empfänger aus einem lokalen Cache empfangen kann, anstatt auf eine Dienstanforderung zu warten. (Geerbt von ServiceBusReceiver)
ReceiveMode	Der ReceiveMode , der verwendet wird, um anzugeben, wie Nachrichten empfangen werden. (Geerbt von ServiceBusReceiver)
SessionId	Die dem Empfänger zugeordnete Sitzungs-ID.
SessionLockedUntil	Ruft die DateTimeOffset ab, bis die Sitzung des Empfängers gesperrt ist.

Methoden

AbandonMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, CancellationToken)	Gibt ein ServiceBusReceivedMessageauf. Dadurch wird die Nachricht wieder für die sofortige Verarbeitung verfügbar gemacht, da die Sperre für die vom Empfänger gespeicherte Nachricht aufgehoben wird. (Geerbt von ServiceBusReceiver)
CloseAsync(CancellationToken)	Führt die Aufgabe aus, die zum sauber der von ServiceBusReceiververwendeten Ressourcen erforderlich ist. (Geerbt von ServiceBusReceiver)
CompleteMessageAsync(ServiceBusReceivedMessage, CancellationToken)	Schließt einen ab ServiceBusReceivedMessage. Dadurch wird die Nachricht aus dem Dienst gelöscht. (Geerbt von ServiceBusReceiver)
DeadLetterMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, CancellationToken)	Verschiebt eine Nachricht in die Unterqueue für unzustellbare Nachrichten. (Geerbt von ServiceBusReceiver)
DeadLetterMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, String, String, CancellationToken)	Verschiebt eine Nachricht in die Unterqueue für unzustellbare Nachrichten. (Geerbt von ServiceBusReceiver)
DeadLetterMessageAsync(ServiceBusReceivedMessage, String, String, CancellationToken)	Verschiebt eine Nachricht in die Unterqueue für unzustellbare Nachrichten. (Geerbt von ServiceBusReceiver)
DeferMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, CancellationToken)	Gibt an, dass der Empfänger die Verarbeitung für die Nachricht zurückstellen möchte. (Geerbt von ServiceBusReceiver)
DisposeAsync()	Führt die Aufgabe aus, die zum sauber der von ServiceBusReceiververwendeten Ressourcen erforderlich ist. Dies entspricht dem Aufrufen CloseAsync(CancellationToken)von . (Geerbt von ServiceBusReceiver)
GetSessionStateAsync(CancellationToken)	Ruft den Sitzungsstatus ab.
PeekMessageAsync(Nullable<Int64>, CancellationToken)	Ruft den nächsten Aktiven ab ServiceBusReceivedMessage , ohne den Status des Empfängers oder der Nachrichtenquelle zu ändern. (Geerbt von ServiceBusReceiver)
PeekMessagesAsync(Int32, Nullable<Int64>, CancellationToken)	Der ServiceBusSessionReceiver ist für den Empfang und Das Abstellen ServiceBusReceivedMessage von Nachrichten von sitzungsfähigen Warteschlangen und Abonnements verantwortlich. Es wird erstellt, indem aufgerufen AcceptNextSessionAsync(String, String, ServiceBusSessionReceiverOptions, CancellationToken)wird. (Geerbt von ServiceBusReceiver)
ReceiveDeferredMessageAsync(Int64, CancellationToken)	Empfängt eine verzögerte Nachricht, die durch identifiziert wird sequenceNumber. (Geerbt von ServiceBusReceiver)
ReceiveDeferredMessagesAsync(IEnumerable<Int64>, CancellationToken)	Empfängt eine Liste verzögerter Nachrichten, die durch identifiziert werden sequenceNumbers. (Geerbt von ServiceBusReceiver)
ReceiveMessageAsync(Nullable<TimeSpan>, CancellationToken)	Empfängt einen ServiceBusReceivedMessage von der Entität mithilfe ReceiveMode des Modus. ReceiveMode standardmäßig auf PeekLock-Modus festgelegt. (Geerbt von ServiceBusReceiver)
ReceiveMessagesAsync(CancellationToken)	Empfängt Nachrichten als asynchrone Aufzählung von der Entität im ReceiveMode Modus. ReceiveMode standardmäßig auf PeekLock-Modus festgelegt. Nachrichten werden von der Entität empfangen, da IAsyncEnumerable durchlaufen wird. Wenn keine Nachrichten verfügbar sind, wird von dieser Methode die Abfrage fortgesetzt, bis Nachrichten verfügbar sind, d. h. sie gibt nie NULL zurück. (Geerbt von ServiceBusReceiver)
ReceiveMessagesAsync(Int32, Nullable<TimeSpan>, CancellationToken)	Empfängt eine Liste von ServiceBusReceivedMessage von der Entität, die den Modus verwendet ReceiveMode . ReceiveMode standardmäßig auf PeekLock-Modus festgelegt. Diese Methode garantiert nicht, dass genaue maxMessages Nachrichten zurückgegeben werden, auch wenn nachrichten in der Warteschlange oder dem Thema verfügbar sind maxMessages . (Geerbt von ServiceBusReceiver)
RenewMessageLockAsync(ServiceBusReceivedMessage, CancellationToken)	Erneuert die Sperre für die Nachricht. Die Sperre wird basierend auf der in der Warteschlange angegebenen Einstellung verlängert. (Geerbt von ServiceBusReceiver)
RenewSessionLockAsync(CancellationToken)	Erneuert die Sperre für die sitzung, die durch angegeben SessionIdwird. Die Sperre wird basierend auf der für die Entität angegebenen Einstellung verlängert.
SetSessionStateAsync(BinaryData, CancellationToken)	Legen Sie einen benutzerdefinierten Zustand für die Sitzung fest, der später mit abgerufen werden kann. GetSessionStateAsync(CancellationToken)