SubscriptionClient Klasse

Definition

Namespace:

Microsoft.ServiceBus.Messaging

Assembly:

Microsoft.ServiceBus.dll

Paket:

WindowsAzure.ServiceBus v6.2.2

Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.

public abstract class SubscriptionClient : Microsoft.ServiceBus.Messaging.MessagingEntityClient

type SubscriptionClient = class
    inherit MessagingEntityClient

Public MustInherit Class SubscriptionClient
Inherits MessagingEntityClient

Vererbung

Object

ClientEntity

MessagingEntityClient

SubscriptionClient

Beispiele

// Create subscription client
SubscriptionClient mySubscriptionClient = 
factory.CreateSubscriptionClient(mySubscription);

// Receive messages
for (int count = 0; count < MsgCount; count++)
{
    var message = mySubscriptionClient.Receive();
    message.Complete();
}

Eigenschaften

IsClosed	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
MessagingFactory	Ruft die Messaging factory ab, die zum Erstellen dieses Abonnementclients verwendet wird.
Mode	Ruft den Nachrichten-Empfangsmodus ab, wenn die empfangene Nachricht verarbeitet wird.
Name	Ruft den Namen des Abonnements ab.
Path	Ruft den Pfad der Warteschlange, des Themas oder des Abonnements relativ zur MessagingFactory Basisadresse ab. (Geerbt von MessagingEntityClient)
PrefetchCount	Ruft die Anzahl der Nachrichten ab, die der Nachrichtenempfänger gleichzeitig anfordern kann, oder legt sie fest.
RetryPolicy	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
ThisLock	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
TopicPath	Ruft den vollständigen Pfadnamen des Themas ab.

Methoden

Abandon(Guid)	Verwirft die Nachricht und gibt den Besitzer der Nachrichtensperre auf.
Abandon(Guid, IDictionary<String,Object>)	Verwirft die Nachricht und gibt den Besitzer der Nachrichtensperre auf.
AbandonAsync(Guid)	Verwirft die Nachricht asynchron und gibt den Besitzer der Nachrichtensperre auf.
AbandonAsync(Guid, IDictionary<String,Object>)	Verwirft die Nachricht asynchron und gibt den Besitzer der Nachrichtensperre auf.
Abort()	Führt abbruchfunktionen für die Messagingentität aus. (Geerbt von ClientEntity)
AcceptMessageSession()	Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion ermöglicht.
AcceptMessageSession(Boolean)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSession(Boolean, TimeSpan)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSession(String)	Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion mithilfe des angegebenen Sitzungsbezeichners ermöglicht.
AcceptMessageSession(String, Boolean)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSession(String, Boolean, TimeSpan)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSession(String, Guid)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSession(String, Guid, TimeSpan)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSession(String, TimeSpan)	Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners und der Wartezeit ermöglicht.
AcceptMessageSession(TimeSpan)	Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung der angegebenen Serverwartezeit ermöglicht.
AcceptMessageSessionAsync()	Akzeptiert asynchron eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung der angegebenen Serverwartezeit ermöglicht.
AcceptMessageSessionAsync(Boolean)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSessionAsync(Boolean, TimeSpan)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSessionAsync(String)	Akzeptiert asynchron eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung der angegebenen Serverwartezeit ermöglicht.
AcceptMessageSessionAsync(String, Boolean)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSessionAsync(String, Boolean, TimeSpan)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSessionAsync(String, Guid)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSessionAsync(String, Guid, TimeSpan)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
AcceptMessageSessionAsync(String, TimeSpan)	Akzeptiert asynchron eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung der angegebenen Serverwartezeit ermöglicht.
AcceptMessageSessionAsync(TimeSpan)	Akzeptiert asynchron eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung der angegebenen Serverwartezeit ermöglicht.
AddRule(RuleDescription)	Fügt mithilfe der SubscriptionDescription angegebenen Regelbeschreibung eine neue Regel hinzu.
AddRule(String, Filter)	Fügt dem aktuellen Abonnement eine Regel mit dem angegebenen Namen und Filterausdruck hinzu.
AddRuleAsync(RuleDescription)	Fügt mithilfe der SubscriptionDescription angegebenen Regelbeschreibung asynchron eine neue Regel hinzu.
AddRuleAsync(String, Filter)	Fügt dem aktuellen Abonnement asynchron eine Regel mit dem angegebenen Namen und Filterausdruck hinzu.
Close()	Sendet eine Bereinigungsmeldung an Service Bus, um den Abschluss der Verwendung einer Entität zu signalisieren. (Geerbt von ClientEntity)
CloseAsync()	Sendet asynchron eine Bereinigungsnachricht an Service Bus, um den Abschluss der Verwendung einer Entität zu signalisieren. (Geerbt von ClientEntity)
Complete(Guid)	Schließt die Verarbeitung einer Nachricht ab.
CompleteAsync(Guid)	Schließt die Verarbeitung einer Nachricht asynchron ab.
CompleteBatch(IEnumerable<Guid>)	Schließt die Verarbeitung eines Batches ab.
CompleteBatchAsync(IEnumerable<Guid>)	Schließt die Verarbeitung eines Batches asynchron ab.
Create(String, String)	Erstellt eine neue Kopie von SubscriptionClient mit angegebenem Namen und Themenpfad.
Create(String, String, ReceiveMode)	Erstellt eine neue Kopie von SubscriptionClient mit angegebenem Namen, Themenpfad und Modus.
CreateFromConnectionString(String, String, String)	Erstellt eine neue Kopie von SubscriptionClient aus einer Verbindungszeichenfolge mit angegebenem Themenpfad und -namen.
CreateFromConnectionString(String, String, String, ReceiveMode)	Erstellt eine neue Kopie von SubscriptionClient aus einer Verbindungszeichenfolge mit angegebenem Themenpfad, Namen und Modus.
CreateWithAzureActiveDirectory(Uri, String, String, AzureActiveDirectoryTokenProvider+AuthenticationCallback, String, ReceiveMode, Nullable<TimeSpan>, TransportType)	Erstellt mithilfe des Authentifizierungsrückrufs eine neue instance von SubscriptionClient .
CreateWithManagedIdentity(Uri, String, String, ReceiveMode, Nullable<TimeSpan>, TransportType)	Erstellt mithilfe der Azure Managed Identity-Authentifizierung eine neue instance vonSubscriptionClient.
DeadLetter(Guid)	Verschiebt die nicht zugestellte Nachricht in die Warteschlange für unzustellbare Nachrichten.
DeadLetter(Guid, IDictionary<String,Object>)	Verschiebt die nicht zugestellte Nachricht in die Warteschlange für unzustellbare Nachrichten.
DeadLetter(Guid, String, String)	Verschiebt die nicht zugestellte Nachricht in die Warteschlange für unzustellbare Nachrichten.
DeadLetterAsync(Guid)	Verschiebt die nicht zugestellte Nachricht asynchron in die Warteschlange für unzustellbare Nachrichten.
DeadLetterAsync(Guid, IDictionary<String,Object>)	Verschiebt die nicht zugestellte Nachricht asynchron in die Warteschlange für unzustellbare Nachrichten.
DeadLetterAsync(Guid, String, String)	Verschiebt die nicht zugestellte Nachricht asynchron in die Warteschlange für unzustellbare Nachrichten.
Defer(Guid)	Setzt die Verarbeitung einer Nachricht an.
Defer(Guid, IDictionary<String,Object>)	Setzt die Verarbeitung einer Nachricht an.
DeferAsync(Guid)	Setzt die Verarbeitung einer Nachricht asynchron an.
DeferAsync(Guid, IDictionary<String,Object>)	Setzt die Verarbeitung einer Nachricht asynchron an.
Fault()	Nur zur internen Verwendung. Verhindern Sie das Erben von dieser Klasse. (Geerbt von ClientEntity)
FormatDeadLetterPath(String, String)	Erstellt einen Formatnamen-Deadletterpfad unter Verwendung des angegebenen Themenpfads und des angegebenen Abonnementnamens.
FormatSubscriptionPath(String, String)	Erstellt einen Formatnamenabonnementpfad unter Verwendung des angegebenen Themenpfads und des angegebenen Abonnementnamens.
GetMessageSessions()	Ruft eine Nachrichtensitzung ab, die die Gruppierung verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion ermöglicht.
GetMessageSessions(DateTime)	Ruft alle Nachrichtensitzungen ab, deren Sitzungsstatus seit lastUpdatedTimeaktualisiert wurde.
GetMessageSessionsAsync()	Ruft asynchron eine Nachrichtensitzung ab, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion ermöglicht.
GetMessageSessionsAsync(DateTime)	Ruft asynchron eine Nachrichtensitzung ab, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion ermöglicht.
OnAbort()	Führt die Abbruchaktion aus.
OnBeginAcceptMessageSession(String, ReceiveMode, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des BeginAcceptMessageSession-Vorgangs ausgeführt.
OnBeginAddRule(RuleDescription, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des BeginAddRule-Vorgangs ausgeführt.
OnBeginClose(TimeSpan, AsyncCallback, Object)	Führt die Schließen beginnen-Aktion aus.
OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)	Führt die Start-Create-Empfängeraktion aus.
OnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object)	Führt die Start-Create-Empfängeraktion aus.
OnBeginGetMessageSessions(DateTime, AsyncCallback, Object)	Wird beim Aufrufen des BeginGetMessageSessions-Vorgangs ausgeführt.
OnBeginGetRules(Int32, Int32, TimeSpan, AsyncCallback, Object)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
OnBeginOpen(TimeSpan, AsyncCallback, Object)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object)	Beginnt mit dem Entfernen eines RuleDescription aus über SubscriptionDescription das Laufzeitclientprotokoll.
OnBeginRemoveRulesByTag(String, TimeSpan, AsyncCallback, Object)	Beginnt mit dem Entfernen eines RuleDescription aus einem SubscriptionDescription über das Laufzeitclientprotokoll mithilfe eines -Tags.
OnClose(TimeSpan)	Führt die Schließenaktion aus.
OnClosed()	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
OnEndAcceptMessageSession(IAsyncResult)	Wird beim Aufrufen des Vorgangs EndAcceptMessageSession ausgeführt.
OnEndAddRule(IAsyncResult)	Beendet den asynchronen Aufruf von OnBeginAddRule(RuleDescription, TimeSpan, AsyncCallback, Object).
OnEndClose(IAsyncResult)	Führt die Schließen-Endaktion aus.
OnEndCreateReceiver(IAsyncResult)	Führt die End create receiver-Aktion aus.
OnEndGetMessageSessions(IAsyncResult)	Führt die Aktion "End get message" aus.
OnEndGetRules(IAsyncResult)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
OnEndOpen(IAsyncResult)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
OnEndRemoveRule(IAsyncResult)	Beendet den asynchronen Aufruf von OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
OnEndRemoveRules(IAsyncResult)	Beendet den asynchronen Aufruf von OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
OnFaulted()	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
OnMessage(Action<BrokeredMessage>)	Verarbeitet eine Nachricht in einer ereignisgesteuerten Nachrichtenpumpe.
OnMessage(Action<BrokeredMessage>, OnMessageOptions)	Verarbeitet eine Nachricht in einer ereignisgesteuerten Nachrichtenpumpe mit den angegebenen OnMessageOptions Optionen.
OnMessageAsync(Func<BrokeredMessage,Task>)	Verarbeitet eine Nachricht asynchron.
OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions)	Verarbeitet eine Nachricht asynchron.
OnOpen(TimeSpan)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
OnOpened()	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
Peek()	Gibt zurück, ohne die erste Nachricht in der Warteschlange zu entfernen.
Peek(Int64)	Gibt zurück, ohne die erste Nachricht in der Warteschlange zu entfernen.
PeekAsync()	Gibt asynchron zurück, ohne die erste Nachricht in der Warteschlange zu entfernen.
PeekAsync(Int64)	Gibt asynchron zurück, ohne die erste Nachricht in der Warteschlange zu entfernen.
PeekBatch(Int32)	Gibt zurück, ohne die ersten Nachrichten in einem Batch zu entfernen.
PeekBatch(Int64, Int32)	Gibt zurück, ohne die ersten Nachrichten in einem Batch zu entfernen.
PeekBatchAsync(Int32)	Gibt asynchron zurück, ohne die ersten Nachrichten in einem Batch zu entfernen.
PeekBatchAsync(Int64, Int32)	Gibt asynchron zurück, ohne die ersten Nachrichten in einem Batch zu entfernen.
Receive()	Empfängt eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
Receive(Int64)	Empfängt eine verzögerte Nachricht mithilfe von Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver. Diese Methode funktioniert nur für verzögerte Nachrichten, nicht für reguläre Nachrichten.
Receive(TimeSpan)	Empfängt eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
ReceiveAsync()	Empfängt asynchron eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
ReceiveAsync(Int64)	Empfängt asynchron eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver. Diese Methode funktioniert nur für verzögerte Nachrichten, nicht für reguläre Nachrichten.
ReceiveAsync(TimeSpan)	Empfängt asynchron eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
ReceiveBatch(IEnumerable<Int64>)	Empfängt einen Batch nach dem asynchronen Vorgang.
ReceiveBatch(Int32)	Empfängt einen Batch nach dem asynchronen Vorgang.
ReceiveBatch(Int32, TimeSpan)	Empfängt einen Batch nach dem asynchronen Vorgang.
ReceiveBatchAsync(IEnumerable<Int64>)	Empfängt asynchron eine Reihe von Nachrichten (für die Batchverarbeitung).
ReceiveBatchAsync(Int32)	Empfängt asynchron eine Reihe von Nachrichten (für die Batchverarbeitung).
ReceiveBatchAsync(Int32, TimeSpan)	Empfängt asynchron eine Reihe von Nachrichten (für die Batchverarbeitung).
RegisterSessionHandler(Type)	Registriert den Handler für die Clientsitzung.
RegisterSessionHandler(Type, SessionHandlerOptions)	Registriert den Handler für die Clientsitzung.
RegisterSessionHandlerAsync(Type)	Registriert den Handler asynchron für die Clientsitzung.
RegisterSessionHandlerAsync(Type, SessionHandlerOptions)	Registriert den Handler asynchron für die Clientsitzung.
RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)	Registriert die Handlerfactory für die Clientsitzung.
RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)	Registriert die Handlerfactory für die Clientsitzung.
RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)	Registriert die Handler factory asynchron für die Clientsitzung.
RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)	Registriert die Handler factory asynchron für die Clientsitzung.
RemoveRule(String)	Entfernt die von beschriebene ruleNameRegel.
RemoveRuleAsync(String)	Entfernt asynchron die von beschriebene ruleNameRegel.
RenewMessageLock(Guid)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
RenewMessageLockAsync(Guid)	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird.
ThrowIfClosed()	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
ThrowIfDisposed()	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
ThrowIfDisposedOrImmutable()	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
ThrowIfDisposedOrNotOpen()	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)
ThrowIfFaulted()	Stellt die Ankerklasse dar, die in Laufzeitvorgängen im Zusammenhang mit einem Themenabonnement verwendet wird. (Geerbt von ClientEntity)