ServiceBusSessionReceiver Klasse
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
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.ServiceBusReceivertype ServiceBusSessionReceiver = class
inherit ServiceBusReceiverPublic Class ServiceBusSessionReceiver
Inherits ServiceBusReceiver- Vererbung
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 . |
| Identifier |
Ein Name, der zum Identifizieren des Empfängerclients verwendet wird. Wenn |
| 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 |
| 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 |
| ReceiveDeferredMessagesAsync(IEnumerable<Int64>, CancellationToken) |
Empfängt eine Liste verzögerter Nachrichten, die durch identifiziert werden |
| 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 |
| 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) |
Gilt für:
Azure SDK for .NET