VERTRIEB: 1-800-867-1380

MessageReceiver-Klasse

Empfängt Nachrichten aus dem Nachrichtencontainer und bestätigt diese.

Namespace:  Microsoft.ServiceBus.Messaging
Assembly:  Microsoft.ServiceBus (in Microsoft.ServiceBus.dll)

public abstract class MessageReceiver : MessageClientEntity

Der MessageReceiver-Typ macht folgende Elemente verfügbar.

  NameBeschreibung
Öffentliche EigenschaftBatchFlushIntervalRuft das Batchleerungsintervall ab.
Geschützte EigenschaftBatchingEnabledRuft einen Wert ab, der angibt, ob Batchverarbeitung aktiviert ist.
Öffentliche EigenschaftIsClosed (Geerbt von ClientEntity.)
Öffentliche EigenschaftLastPeekedSequenceNumberRuft die Sequenznummer der Nachricht ab, für die zuletzt ein Peek-Vorgang ausgeführt wurde, oder legt sie fest.
Öffentliche EigenschaftModeRuft den Nachrichtenempfangsmodus ab.
Öffentliche EigenschaftPathRuft den Pfad der Warteschlange oder des Themas relativ zur MessagingFactory-Basisadresse ab.
Öffentliche EigenschaftPrefetchCountRuft die Anzahl der Nachrichten ab, die der Nachrichtenempfänger gleichzeitig anfordern kann, oder legt diese Anzahl fest.
Geschützte EigenschaftReceiverStartTime
Öffentliche EigenschaftRetryPolicy (Geerbt von ClientEntity.)
Geschützte EigenschaftStartOffset
Geschützte EigenschaftThisLock (Geerbt von ClientEntity.)
Zum Anfang

  NameBeschreibung
Öffentliche MethodeAbandon(Guid)Verwirft die Nachricht und gibt den Besitz der Nachrichtensperre auf.
Öffentliche MethodeAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>))Verwirft die Nachricht und gibt den Besitz der Nachrichtensperre auf.
Öffentliche MethodeAbandonAsync(Guid)Verwirft die Nachricht asynchron und gibt den Besitz der Nachrichtensperre auf.
Öffentliche MethodeAbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Verwirft die Nachricht asynchron und gibt den Besitz der Nachrichtensperre auf.
Öffentliche MethodeAbortPerforms abort functionality on the messaging entity. (Geerbt von ClientEntity.)
Öffentliche MethodeBeginAbandon(Guid, AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Verwerfen der Nachricht und Aufgeben der Sperre.
Öffentliche MethodeBeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Verwerfen der Nachricht und Aufgeben der Sperre.
Öffentliche MethodeBeginCloseBeginnt einen asynchronen Vorgang zum Schließen der Nachrichtencliententität. (Geerbt von MessageClientEntity.)
Öffentliche MethodeBeginCompleteBeginnt einen asynchronen Vorgang zum Abschließen des Empfangs einer Nachricht.
Öffentliche MethodeBeginCompleteBatchBeginnt einen asynchronen Vorgang zum Abschließen eines Nachrichtenbatches.
Öffentliche MethodeBeginDeadLetter(Guid, AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Verschieben einer Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeBeginDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Verschieben einer Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeBeginDeadLetter(Guid, String, String, AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Verschieben einer Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeBeginDefer(Guid, AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Anhalten des Empfangs einer Nachricht.
Öffentliche MethodeBeginDefer(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Anhalten des Empfangs einer Nachricht.
Öffentliche MethodeBeginPeek(AsyncCallback, Object)Beginnt einen Peek-Vorgang einer Nachricht.
Öffentliche MethodeBeginPeek(Int64, AsyncCallback, Object)Beginnt einen Peek-Vorgang einer Nachricht.
Öffentliche MethodeBeginPeekBatch(Int32, AsyncCallback, Object)Beginnt einen Peek-Vorgang eines Nachrichtenbatches.
Öffentliche MethodeBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Beginnt einen Peek-Vorgang eines Nachrichtenbatches.
Öffentliche MethodeBeginReceive(AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Empfangen einer Nachricht.
Öffentliche MethodeBeginReceive(Int64, AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Empfangen einer Nachricht.
Öffentliche MethodeBeginReceive(TimeSpan, AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Empfangen einer Nachricht.
Öffentliche MethodeBeginReceiveBatch(IEnumerable<(Of <<'(Int64>)>>), AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Empfangen eines Nachrichtenbatches.
Öffentliche MethodeBeginReceiveBatch(Int32, AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Empfangen eines Nachrichtenbatches.
Öffentliche MethodeBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Beginnt einen asynchronen Vorgang zum Empfangen eines Nachrichtenbatches.
Öffentliche MethodeCloseSends a cleanup message to Service Bus to signal the completion of the usage of an entity. (Geerbt von ClientEntity.)
Öffentliche MethodeCloseAsyncSends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity. (Geerbt von ClientEntity.)
Öffentliche MethodeCompleteSchließt den Empfangsvorgang für eine Nachricht ab.
Öffentliche MethodeCompleteAsyncSchließt asynchron den Empfangsvorgang für eine Nachricht ab.
Öffentliche MethodeCompleteBatchSchließt den Empfangsvorgang für einen Nachrichtenbatch ab.
Öffentliche MethodeCompleteBatchAsyncSchließt asynchron den Empfangsvorgang für einen Nachrichtenbatch ab.
Öffentliche MethodeDeadLetter(Guid)Verschiebt die nicht zugestellte Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>))Verschiebt die nicht zugestellte Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeDeadLetter(Guid, String, String)Verschiebt die nicht zugestellte Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeDeadLetterAsync(Guid)Verschiebt asynchron die nicht zugestellte Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeDeadLetterAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Verschiebt asynchron die nicht zugestellte Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeDeadLetterAsync(Guid, String, String)Verschiebt asynchron die nicht zugestellte Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeDefer(Guid)Gibt an, dass der Empfänger die Verarbeitung für die Nachricht zurückstellen möchte.
Öffentliche MethodeDefer(Guid, IDictionary<(Of <<'(String, Object>)>>))Gibt an, dass der Empfänger die Verarbeitung für die Nachricht zurückstellen möchte.
Öffentliche MethodeDeferAsync(Guid)Verzögert asynchron die Verarbeitung einer Nachricht.
Öffentliche MethodeDeferAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Verzögert asynchron die Verarbeitung einer Nachricht.
Öffentliche MethodeEndAbandonBeendet den asynchronen Vorgang zum Verwerfen der Nachricht und Aufgeben der Sperre.
Öffentliche MethodeEndCloseBeendet einen asynchronen Vorgang zum Schließen der Nachrichtencliententität. (Geerbt von MessageClientEntity.)
Öffentliche MethodeEndCompleteBeendet den asynchronen Vorgang zum Abschließen des Empfangs einer Nachricht.
Öffentliche MethodeEndCompleteBatchBeendet den asynchronen Vorgang zum Abschließen des Empfangs einer Batchnachricht.
Öffentliche MethodeEndDeadLetterBeendet einen asynchronen Vorgang zum Verschieben der Nachricht in die Warteschlange für unzustellbare Nachrichten.
Öffentliche MethodeEndDeferBeendet einen asynchronen Vorgang zum Zurückstellen des Empfangs einer Nachricht.
Öffentliche MethodeEndPeekBeendet einen asynchronen Peek-Vorgang einer Nachricht.
Öffentliche MethodeEndPeekBatchBeendet einen asynchronen Peek-Vorgang eines Nachrichtenbatches.
Öffentliche MethodeEndReceiveBeendet einen asynchronen Vorgang zum Empfangen einer Nachricht.
Öffentliche MethodeEndReceiveBatchBeendet einen asynchronen Vorgang zum Empfangen eines Nachrichtenbatches.
Öffentliche MethodeEquals (Geerbt von Object.)
Geschützte MethodeFaultFor internal use only. Do not inherit from this class. (Geerbt von ClientEntity.)
Geschützte MethodeFinalize (Geerbt von Object.)
Öffentliche MethodeGetHashCode (Geerbt von Object.)
Geschützte MethodeStatisches ElementGetLockTokenRuft das Sperrtoken ab, das an die Nachricht gebunden ist.
Geschützte MethodeStatisches ElementGetLockTokensRuft die Auflistung der Sperrtoken aus der angegebenen Auflistung von Nachrichten ab.
Öffentliche MethodeGetType (Geerbt von Object.)
Geschützte MethodeMemberwiseClone (Geerbt von Object.)
Geschützte MethodeOnAbandonWird bei einem Aufruf des Vorgangs Abandon ausgeführt.
Geschützte MethodeOnAbort (Geerbt von ClientEntity.)
Geschützte MethodeOnBeginAbandonWird bei einem Aufruf des Vorgangs OnAbandon oder BeginAbandon ausgeführt.
Geschützte MethodeOnBeginClose (Geerbt von ClientEntity.)
Geschützte MethodeOnBeginComplete(TrackingContext, IEnumerable<(Of <<'(ArraySegment<(Of <<'(Byte>)>>)>)>>), Boolean, TimeSpan, AsyncCallback, Object)
Geschützte MethodeOnBeginComplete(TrackingContext, IEnumerable<(Of <<'(Guid>)>>), Boolean, TimeSpan, AsyncCallback, Object)Wird bei einem Aufruf des Vorgangs OnComplete oder BeginComplete ausgeführt.
Geschützte MethodeOnBeginDeadLetterWird bei einem Aufruf des Vorgangs OnDeadLetter oder BeginDeadLetter ausgeführt.
Geschützte MethodeOnBeginDeferWird bei einem Aufruf des Vorgangs OnDefer oder BeginDefer ausgeführt.
Geschützte MethodeOnBeginOpen (Geerbt von ClientEntity.)
Geschützte MethodeOnBeginPeekWird bei einem Aufruf des Vorgangs BeginPeek ausgeführt.
Geschützte MethodeOnBeginRenewMessageLocksWird bei einem Aufruf des Vorgangs OnBegin für Sperrnachrichten ausgeführt.
Geschützte MethodeOnBeginTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, AsyncCallback, Object)Wird bei einem Aufruf des Vorgangs OnTryReceive oder BeginTryReceive ausgeführt.
Geschützte MethodeOnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)Wird bei einem Aufruf des Vorgangs OnTryReceive oder BeginTryReceive ausgeführt.
Geschützte MethodeOnBeginTryReceive2Wird bei einem Aufruf des Vorgangs OnTryReceive oder BeginTryReceive ausgeführt.
Geschützte MethodeOnBeginTryReceiveEventData
Geschützte MethodeOnClose (Geerbt von ClientEntity.)
Geschützte MethodeOnClosed (Geerbt von ClientEntity.)
Geschützte MethodeOnCompleteWird bei einem Aufruf des Vorgangs Complete ausgeführt.
Geschützte MethodeOnDeadLetterWird bei einem Aufruf des Vorgangs DeadLetter ausgeführt.
Geschützte MethodeOnDeferWird bei einem Aufruf des Vorgangs Defer ausgeführt.
Geschützte MethodeOnEndAbandonFührt die Aktion zum Beenden des Verwerfungsvorgangs aus.
Geschützte MethodeOnEndClose (Geerbt von ClientEntity.)
Geschützte MethodeOnEndCompleteFührt die Aktion zum Beenden des Abschlussvorgangs aus.
Geschützte MethodeOnEndDeadLetterFührt die Aktion zum Beenden des Verschiebevorgangs der Nachricht in die Warteschlange für unzustellbare Nachrichten aus.
Geschützte MethodeOnEndDeferFührt die Aktion zum Beenden der Zurückstellung aus.
Geschützte MethodeOnEndOpen (Geerbt von ClientEntity.)
Geschützte MethodeOnEndPeekFührt den EndPeek-Vorgang aus.
Geschützte MethodeOnEndRenewMessageLocksFührt die Aktion EndRenew für Nachrichtensperren aus.
Geschützte MethodeOnEndTryReceiveFührt die Aktion zum Beenden des Empfangsversuchs aus.
Geschützte MethodeOnEndTryReceive2Führt die Aktion zum Beenden des Empfangsversuchs aus.
Geschützte MethodeOnEndTryReceiveEventData
Geschützte MethodeOnFaulted (Geerbt von ClientEntity.)
Öffentliche MethodeOnMessageVerarbeitet eine Nachricht in einem ereignisgesteuerten Nachrichtensystem.
Öffentliche MethodeOnMessageAsyncVerarbeitet asynchron eine Nachricht in einem ereignisgesteuerten Nachrichtensystem.
Geschützte MethodeOnOpen (Geerbt von ClientEntity.)
Geschützte MethodeOnOpened (Geerbt von ClientEntity.)
Geschützte MethodeOnPeekWird bei einem Aufruf des Vorgangs Peek ausgeführt.
Geschützte MethodeOnRenewMessageLocksFührt die Aktion Renew für Sperrnachrichten aus.
Geschützte MethodeOnTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)Wird bei einem Aufruf des Vorgangs TryReceive ausgeführt.
Geschützte MethodeOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)Wird bei einem Aufruf des Vorgangs TryReceive ausgeführt.
Öffentliche MethodePeek()()()()Liest die nächste Nachricht, ohne den Status des Empfängers oder die Nachrichtenquelle zu ändern.
Öffentliche MethodePeek(Int64)Liest die nächste Nachricht, ohne den Status des Empfängers oder die Nachrichtenquelle zu ändern.
Öffentliche MethodePeekAsync()()()()Liest asynchron die nächste Nachricht, ohne den Status des Empfängers oder die Nachrichtenquelle zu ändern.
Öffentliche MethodePeekAsync(Int64)Liest asynchron die nächste Nachricht, ohne den Status des Empfängers oder die Nachrichtenquelle zu ändern.
Öffentliche MethodePeekBatch(Int32)Liest den nächsten Nachrichtenbatch, ohne den Status des Empfängers oder die Nachrichtenquelle zu ändern.
Öffentliche MethodePeekBatch(Int64, Int32)Liest den nächsten Nachrichtenbatch, ohne den Status des Empfängers oder die Nachrichtenquelle zu ändern.
Öffentliche MethodePeekBatchAsync(Int32)Liest asynchron den nächsten Nachrichtenbatch, ohne den Status des Empfängers oder die Nachrichtenquelle zu ändern.
Öffentliche MethodePeekBatchAsync(Int64, Int32)Liest asynchron den nächsten Nachrichtenbatch, ohne den Status des Empfängers oder die Nachrichtenquelle zu ändern.
Öffentliche MethodeReceive()()()()Empfängt ein BrokeredMessage-Objekt aus der aktuellen Warteschlange oder dem aktuellen Thema.
Öffentliche MethodeReceive(Int64)Empfängt eine Nachricht aus der aktuellen Warteschlange oder dem aktuellen Thema.
Öffentliche MethodeReceive(TimeSpan)Empfängt ein BrokeredMessage-Objekt aus der aktuellen Warteschlange oder dem aktuellen Thema.
Öffentliche MethodeReceiveAsync()()()()Empfängt asynchron eine Nachricht aus der aktuellen Warteschlange oder dem aktuellen Thema.
Öffentliche MethodeReceiveAsync(Int64)Empfängt asynchron eine Nachricht aus der aktuellen Warteschlange oder dem aktuellen Thema.
Öffentliche MethodeReceiveAsync(TimeSpan)Empfängt asynchron eine Nachricht aus der aktuellen Warteschlange oder dem aktuellen Thema.
Öffentliche MethodeReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))Empfängt einen Nachrichtenbatch.
Öffentliche MethodeReceiveBatch(Int32)Empfängt einen Nachrichtenbatch.
Öffentliche MethodeReceiveBatch(Int32, TimeSpan)Empfängt einen Nachrichtenbatch.
Öffentliche MethodeReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Empfängt asynchron einen Nachrichtenbatch.
Öffentliche MethodeReceiveBatchAsync(Int32)Empfängt asynchron einen Nachrichtenbatch.
Öffentliche MethodeReceiveBatchAsync(Int32, TimeSpan)Empfängt asynchron einen Nachrichtenbatch.
Geschützte MethodeThrowIfClosed (Geerbt von ClientEntity.)
Geschützte MethodeThrowIfDisposed (Geerbt von ClientEntity.)
Geschützte MethodeThrowIfDisposedOrImmutable (Geerbt von ClientEntity.)
Geschützte MethodeThrowIfDisposedOrNotOpen (Geerbt von ClientEntity.)
Geschützte MethodeThrowIfFaulted (Geerbt von ClientEntity.)
Öffentliche MethodeToString (Geerbt von Object.)
Zum Anfang

Although you can use the QueueClient class to send and receive messages without creating a MessageReceiver object, you can also use MessageSender and MessageReceiver to create a sender and receiver on an entity. However, note that you can only use a MessageReceiver to receive messages from a queue or subscription; you cannot receive messages or listen for messages from a topic. Similarly, you can only use a MessageSender to send messages to a queue or topic; you cannot send messages to a subscription. Note that the default message receive mode is PeekLock, which ensures reliable message receiving.

When you create a MessageReceiver for subscriptions, the entityPath parameter is of the form topicPath/subscriptions/subscriptionName.

The following example receives a message from the queue created in the MessageSender example:

Uri serviceUri = ServiceBusEnvironment.CreateServiceUri("sb", ServiceNamespace, string.Empty); 

MessagingFactory factory = MessagingFactory.Create(serviceUri, credentials); 

MessageReceiver myMessageReceiver = factory.CreateMessageReceiver(queueName);

BrokeredMessage message;
while ((message = myMessageReceiver.Receive(new TimeSpan(hours: 0, minutes: 1, seconds: 5))) != null)
{
    Console.WriteLine(
    string.Format(
    "Message received: Id = {0}, Body = {1}", message.MessageId, message.GetBody<string>()));
    message.Complete();
}

Any public static (Shared in Visual Basic) members of this type are thread safe. Instance members are also guaranteed to be thread safe.

Fanden Sie dies hilfreich?
(1500 verbleibende Zeichen)
Vielen Dank für Ihr Feedback.

Community-Beiträge

HINZUFÜGEN
Anzeigen:
© 2014 Microsoft