QueueClient Klasse

Definition

Stellt das Warteschlangenclientobjekt dar.

public abstract class QueueClient : Microsoft.ServiceBus.Messaging.MessagingEntityClient
type QueueClient = class
    inherit MessagingEntityClient
Public MustInherit Class QueueClient
Inherits MessagingEntityClient
Vererbung

Eigenschaften

IsClosed

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
MessagingFactory

Ruft die Messagingfactory ab oder legt sie fest.

Mode

Ruft den Nachrichten-Empfangsmodus ab, wenn die empfangene Nachricht verarbeitet wird.

Path

Ruft den Pfad der Warteschlange, des Themas oder des Abonnements relativ zur MessagingFactory Basisadresse ab.

(Geerbt von MessagingEntityClient)
PrefetchCount

Ruft die Anzahl von Nachrichten ab, die der Warteschlangenempfänger gleichzeitig anfordern kann, oder legt diese fest.

RetryPolicy

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
ThisLock

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)

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)

Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion ermöglicht, unabhängig davon, ob im exklusiven Modus.

AcceptMessageSession(Boolean, TimeSpan)

Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion ermöglicht, unabhängig davon, ob im exklusiven Modus.

AcceptMessageSession(String)

Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten zur Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners ermöglicht.

AcceptMessageSession(String, Boolean)

Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion mit ob im exklusiven Modus ermöglicht.

AcceptMessageSession(String, Boolean, TimeSpan)

Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners mit ob im exklusiven Modus zulässt.

AcceptMessageSession(String, Guid)

Akzeptiert eine nicht exklusive gesperrte Nachricht, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners und des angegebenen Sitzungssperrtokens ermöglicht.

AcceptMessageSession(String, Guid, TimeSpan)

Akzeptiert eine nicht exklusive gesperrte Nachricht, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners und des angegebenen Sitzungssperrtokens ermöglicht.

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 zur Verarbeitung in einer einzelnen Transaktion ermöglicht.

AcceptMessageSessionAsync(Boolean)

Akzeptiert asynchron eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten zur Verarbeitung in einer einzelnen Transaktion mit ob im exklusiven Modus und wartezeit ermöglicht.

AcceptMessageSessionAsync(Boolean, TimeSpan)

Akzeptiert asynchron eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten zur Verarbeitung in einer einzelnen Transaktion mit ob im exklusiven Modus und wartezeit ermöglicht.

AcceptMessageSessionAsync(String)

Akzeptiert asynchron eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten zur Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners ermöglicht.

AcceptMessageSessionAsync(String, Boolean)

Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners mit ob im exklusiven Modus zulässt.

AcceptMessageSessionAsync(String, Boolean, TimeSpan)

Akzeptiert eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners mit ob im exklusiven Modus zulässt.

AcceptMessageSessionAsync(String, Guid)

Akzeptiert eine nicht exklusive gesperrte Nachricht, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners und des angegebenen Sitzungssperrtokens ermöglicht.

AcceptMessageSessionAsync(String, Guid, TimeSpan)

Akzeptiert eine nicht exklusive gesperrte Nachricht, die das Gruppieren verwandter Nachrichten für die Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners und des angegebenen Sitzungssperrtokens ermöglicht.

AcceptMessageSessionAsync(String, TimeSpan)

Akzeptiert asynchron eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten zur Verarbeitung in einer einzelnen Transaktion unter Verwendung des angegebenen Sitzungsbezeichners und der wartezeit ermöglicht.

AcceptMessageSessionAsync(TimeSpan)

Akzeptiert asynchron eine Nachrichtensitzung, die das Gruppieren verwandter Nachrichten zur Verarbeitung in einer einzelnen Transaktion unter Verwendung der angegebenen Serverwartezeit ermöglicht.

CancelScheduledMessageAsync(Int64)

Bricht eine geplante Nachricht ab.

Close()

Sendet eine Bereinigungsnachricht an Service Bus, um den Abschluss der Verwendung einer Entität zu signalisieren.

(Geerbt von ClientEntity)
CloseAsync()

Sendet eine Bereinigungsnachricht asynchron 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 Nachrichtenbatches ab.

CompleteBatchAsync(IEnumerable<Guid>)

Schließt die Verarbeitung eines Nachrichtenbatches asynchron ab.

Create(String)

Erstellt eine neue Kopie von QueueClient mit dem angegebenen Pfad.

Create(String, ReceiveMode)

Erstellt eine neue Kopie von QueueClient mit dem angegebenen Pfad und Modus.

CreateFromConnectionString(String)

Erstellt eine neue instance der QueueClient Verwendung der angegebenen Verbindungszeichenfolge.

CreateFromConnectionString(String, ReceiveMode)

Erstellt eine neue instance der Verwendung der angegebenen Verbindungszeichenfolge und des QueueClient Empfangsmodus.

CreateFromConnectionString(String, String)

Erstellt eine neue Kopie von QueueClient aus einer Verbindungszeichenfolge mit dem angegebenen Warteschlangenpfad. Verwenden Sie diese Überladung nur, wenn die Verbindungszeichenfolge die EntityPath -Eigenschaft nicht verwendet.

CreateFromConnectionString(String, String, ReceiveMode)

Erstellt eine neue instance von QueueClient aus einer Verbindungszeichenfolge mit dem angegebenen Pfad und Modus. Verwenden Sie diese Überladung nur, wenn die Verbindungszeichenfolge die EntityPath -Eigenschaft nicht verwendet.

CreateWithAzureActiveDirectory(Uri, String, AzureActiveDirectoryTokenProvider+AuthenticationCallback, String, ReceiveMode, Nullable<TimeSpan>, TransportType)

Erstellt eine neue instance des mithilfe des QueueClient Azure Active Directory-Authentifizierungskontexts.

CreateWithManagedIdentity(Uri, String, ReceiveMode, Nullable<TimeSpan>, TransportType)

Erstellt eine neue instance von mithilfe der QueueClient Azure Managed Identity-Authentifizierung.

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)

Hält die Verarbeitung einer Nachricht an.

Defer(Guid, IDictionary<String,Object>)

Hält die Verarbeitung einer Nachricht an.

DeferAsync(Guid)

Hält die Verarbeitung einer Nachricht asynchron an.

DeferAsync(Guid, IDictionary<String,Object>)

Hält die Verarbeitung einer Nachricht asynchron an.

Fault()

Nur zur internen Verwendung. Verhindern Sie das Erben von dieser Klasse.

(Geerbt von ClientEntity)
FormatDeadLetterPath(String)

Erstellt einen Formatnamen aus dem angegebenen Warteschlangenpfad für unzustellbare Nachrichten.

FormatTransferDeadLetterPath(String)

Stellt das Warteschlangenclientobjekt dar.

GetMessageSessions()

Ruft die Nachrichtensitzungen ab, sodass Sie Sitzungen in Warteschlangen durchsuchen können. Nur Sitzungen mit aktiven Nachrichten in der Warteschlange werden zurückgegeben. Die Sitzungen in der Deadletter-Warteschlange oder Sitzungen mit einem SessionState-Wert als "aktiv" und keine Nachrichten werden bei diesem Aufruf nicht zurückgegeben.

GetMessageSessions(DateTime)

Ruft alle Nachrichtensitzungen ab, deren Sitzungszustand seit lastUpdatedTimeaktualisiert wurde.

GetMessageSessionsAsync()

Ruft die Nachrichtensitzungen asynchron ab, sodass Sie Sitzungen in Warteschlangen durchsuchen können. Nur Sitzungen mit aktiven Nachrichten in der Warteschlange werden zurückgegeben. Die Sitzungen in der Deadletter-Warteschlange oder Sitzungen mit einem SessionState-Wert als "aktiv" und keine Nachrichten werden bei diesem Aufruf nicht zurückgegeben.

GetMessageSessionsAsync(DateTime)

Ruft asynchron alle Nachrichtensitzungen ab, deren Sitzungszustand seit lastUpdatedTimeaktualisiert wurde.

OnAbort()

Wird beim Aufrufen des Abort-Ereignisses ausgeführt.

OnBeginAcceptMessageSession(String, ReceiveMode, Int32, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object)

Stellt das Warteschlangenclientobjekt dar.

OnBeginClose(TimeSpan, AsyncCallback, Object)

Wird ausgeführt, wenn der Close-Vorgang aufgerufen wird.

OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)

Führt die Aktion start create receiver aus.

OnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)

Führt die Aktion start create receiver aus.

OnBeginCreateSender(TimeSpan, AsyncCallback, Object)

Führt die Aktion Start create sender aus.

OnBeginGetMessageSessions(DateTime, AsyncCallback, Object)

Führt die BeginGetMessageSessions-Aktion aus.

OnBeginOpen(TimeSpan, AsyncCallback, Object)

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
OnClose(TimeSpan)

Wird beim Aufrufen der Aktion Schließen ausgeführt.

OnClosed()

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
OnEndAcceptMessageSession(IAsyncResult)

Wird beim Aufrufen des Vorgangs EndAcceptMessageSession ausgeführt.

OnEndClose(IAsyncResult)

Führt die Aktion zum Beenden des Schließens aus.

OnEndCreateReceiver(IAsyncResult)

Führt die End create receiver-Aktion aus.

OnEndCreateSender(IAsyncResult)

Führt die End create sender-Aktion aus.

OnEndGetMessageSessions(IAsyncResult)

Führt die Aktion zum Abrufen der Nachricht am Ende aus.

OnEndOpen(IAsyncResult)

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
OnFaulted()

Stellt das Warteschlangenclientobjekt dar.

(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 dem angegebenen Satz von OnMessageOptions Optionen.

OnMessageAsync(Func<BrokeredMessage,Task>)

Verarbeitet eine Nachricht asynchron.

OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions)

Verarbeitet eine Nachricht asynchron.

OnOpen(TimeSpan)

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
OnOpened()

Stellt das Warteschlangenclientobjekt dar.

(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)

Hier wird ein Batch von Nachrichten eingesehen.

PeekBatch(Int64, Int32)

Hier wird ein Batch von Nachrichten eingesehen.

PeekBatchAsync(Int32)

Ruft einen Nachrichtenbatch asynchron ein.

PeekBatchAsync(Int64, Int32)

Ruft einen Nachrichtenbatch asynchron ein.

Receive()

Empfängt mithilfe von Microsoft.ServiceBus.Messaging.QueueClient.InternalReceivereine Nachricht.

Receive(Int64)

Empfängt mithilfe von Microsoft.ServiceBus.Messaging.QueueClient.InternalReceivereine verzögerte Nachricht. Diese Methode funktioniert nur für verzögerte Nachrichten, nicht für reguläre Nachrichten.

Receive(TimeSpan)

Empfängt mithilfe von Microsoft.ServiceBus.Messaging.QueueClient.InternalReceivereine Nachricht.

ReceiveAsync()

Empfängt asynchron eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver.

ReceiveAsync(Int64)

Empfängt asynchron eine verzögerte Nachricht mithilfe von Microsoft.ServiceBus.Messaging.QueueClient.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.QueueClient.InternalReceiver.

ReceiveBatch(IEnumerable<Int64>)

Empfängt einen Nachrichtenbatch.

ReceiveBatch(Int32)

Empfängt einen Nachrichtenbatch.

ReceiveBatch(Int32, TimeSpan)

Empfängt einen Nachrichtenbatch.

ReceiveBatchAsync(IEnumerable<Int64>)

Empfängt asynchron einen Nachrichtenbatch.

ReceiveBatchAsync(Int32)

Empfängt asynchron einen Nachrichtenbatch.

ReceiveBatchAsync(Int32, TimeSpan)

Empfängt asynchron einen Nachrichtenbatch.

RegisterSessionHandler(Type)

Registriert den Sitzungshandler bei einem bestimmten Typ.

RegisterSessionHandler(Type, SessionHandlerOptions)

Registriert den Sitzungshandler mit bestimmten Typ- und Handleroptionen.

RegisterSessionHandlerAsync(Type)

Registriert den Sitzungshandler asynchron bei einem bestimmten Typ.

RegisterSessionHandlerAsync(Type, SessionHandlerOptions)

Registriert den Sitzungshandler asynchron mit bestimmten Typ- und Handleroptionen.

RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)

Registriert eine Nachrichtensitzungshandlerfactory mit angegebenen Optionen.

RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)

Registriert eine Nachrichtensitzungshandlerfactory mit angegebenen Optionen.

RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)

Registriert asynchron eine Nachrichtensitzungshandlerfactory.

RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)

Registriert asynchron eine Nachrichtensitzungshandlerfactory.

RenewMessageLock(Guid)

Stellt das Warteschlangenclientobjekt dar.

RenewMessageLockAsync(Guid)

Stellt das Warteschlangenclientobjekt dar.

ScheduleMessageAsync(BrokeredMessage, DateTimeOffset)

Sendet eine geplante Nachricht.

Send(BrokeredMessage)

Sendet eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.QueueClient.InternalSender.

SendAsync(BrokeredMessage)

Sendet asynchron eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.QueueClient.InternalSender.

SendBatch(IEnumerable<BrokeredMessage>)

Sendet eine Reihe von Brokernachrichten (für die Batchverarbeitung).

SendBatchAsync(IEnumerable<BrokeredMessage>)

Sendet asynchron einen Satz von Brokernachrichten (für die Batchverarbeitung).

ThrowIfClosed()

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
ThrowIfDisposed()

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
ThrowIfDisposedOrImmutable()

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
ThrowIfDisposedOrNotOpen()

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)
ThrowIfFaulted()

Stellt das Warteschlangenclientobjekt dar.

(Geerbt von ClientEntity)

Gilt für: