MessageReceiver Klasse

Referenz

Definition

Namespace:: Microsoft.ServiceBus.Messaging

Assembly:: Microsoft.ServiceBus.dll

Paket:: WindowsAzure.ServiceBus v6.2.2

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.

Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen.

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

type MessageReceiver = class
    inherit MessagingEntityClient

Public MustInherit Class MessageReceiver
Inherits MessagingEntityClient

Vererbung: Object

ClientEntity

MessagingEntityClient
MessageReceiver

Abgeleitet: Microsoft.ServiceBus.Messaging.MessageSession

Hinweise

Bitte beachten Sie, dass der Nachrichtenübermittlungsmechanismus standardmäßig keinen zuverlässigen Nachrichtenempfang ermöglicht. Service Bus löscht die Nachricht, sobald sie aus dem System ausgeht. Für eine garantierte Zustellung können Sie den PeekLock-Übermittlungsmodus verwenden.

//********************************************************************************
//                             Sending messages to a Queue
//********************************************************************************

// Create a sender
MessageSender myMessageSender = myQueueClient.CreateSender(SendMode.Default);

// Send messages
List<string> Issues = new List<string>();
foreach (var issue in Issues)
{
myMessageSender.Send(new BrokeredMessage(issue));
}

//********************************************************************************
//                           Recieving messages from a Queue
//********************************************************************************

// Create a receiver
MessageReceiver myMessageReceiver = 
myQueueClient.CreateReceiver(ReceiveMode.PeekLock);

// Receive messages
for (int count = 0; count < Issues.Count; count++)
{
var message = myMessageReceiver.Receive();
message.Complete();
}

//********************************************************************************
//                    Receiving messages from a particular session
//********************************************************************************

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

// Create a receiver
MessageReceiver myMessageReceiver = mySubscriptionClient.AcceptMessageSession(ReceiveMode.PeekLock);

// Receive messages
for (int count = 0; count *lt; Issues.Count; count++)
{
var message = myMessageReceiver.Receive();
message.Complete();
}

Eigenschaften

BatchFlushInterval	Ruft das Batchleerintervall ab.
BatchingEnabled	Ruft einen Wert ab, der angibt, ob die Batchverarbeitung aktiviert ist.
IsClosed	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
LastPeekedSequenceNumber	Ruft die Sequenznummer der zuletzt angezeigten Nachricht ab oder legt diese fest.
Mode	Ruft den Nachrichten-Empfangsmodus 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.
RefreshEntityRuntimeDescription	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen.
RetryPolicy	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
SupportsGetRuntimeEntityDescription	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen.
ThisLock	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (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)
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 den Empfangsvorgang für eine Nachricht ab. Bei Verwendung von AMQP kann dieser Vorgang nur für Nachrichten ausgeführt werden, die von diesem Empfänger empfangen wurden.
CompleteAsync(Guid)	Schließt den Empfangsvorgang für eine Nachricht asynchron ab. Bei Verwendung von AMQP kann dieser Vorgang nur für Nachrichten ausgeführt werden, die von diesem Empfänger empfangen wurden.
CompleteBatch(IEnumerable<Guid>)	Schließt den Empfangsvorgang für einen Nachrichtenbatch ab. Bei Verwendung von AMQP kann dieser Vorgang nur für Nachrichten ausgeführt werden, die von diesem Empfänger empfangen wurden.
CompleteBatchAsync(IEnumerable<Guid>)	Schließt den Empfangsvorgang für einen Nachrichtenbatch asynchron ab. Bei Verwendung von AMQP kann dieser Vorgang nur für Nachrichten ausgeführt werden, die von diesem Empfänger empfangen wurden.
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)	Gibt an, dass der Empfänger die Verarbeitung für die Nachricht zurückstellen möchte.
Defer(Guid, IDictionary<String,Object>)	Gibt an, dass der Empfänger die Verarbeitung für die Nachricht zurückstellen möchte.
DeferAsync(Guid)	Verzögern Sie die Verarbeitung der Nachricht asynchron.
DeferAsync(Guid, IDictionary<String,Object>)	Verzögern Sie die Verarbeitung der Nachricht asynchron.
Fault()	Nur zur internen Verwendung. Verhindern Sie das Erben von dieser Klasse. (Geerbt von ClientEntity)
GetLockToken(BrokeredMessage)	Ruft das an die Nachricht gebundene Sperrtoken ab.
GetLockTokens(IEnumerable<BrokeredMessage>)	Ruft die Auflistung von Sperrtoken aus der angegebenen Auflistung von Nachrichten ab.
GetProperty<T>()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen.
OnAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, TimeSpan)	Führt die Abbruchaktion aus.
OnAbort()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnBeginAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, Boolean, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des OnAbandon- oder BeginAbandon-Vorgangs ausgeführt.
OnBeginClose(TimeSpan, AsyncCallback, Object)	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnBeginComplete(TrackingContext, IEnumerable<ArraySegment<Byte>>, Boolean, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des Vorgangs OnComplete oder BeginComplete ausgeführt.
OnBeginComplete(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des Vorgangs OnComplete oder BeginComplete ausgeführt.
OnBeginDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, String, String, Boolean, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des Vorgangs OnDeadLetter oder BeginDeadLetter ausgeführt.
OnBeginDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, Boolean, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des OnDefer- oder BeginDefer-Vorgangs ausgeführt.
OnBeginOpen(TimeSpan, AsyncCallback, Object)	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnBeginPeek(TrackingContext, Int64, Int32, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des BeginPeek-Vorgangs ausgeführt.
OnBeginRenewMessageLocks(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des OnBegin-Vorgangs für Sperrnachrichten ausgeführt.
OnBeginTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, AsyncCallback, Object)	Führt die Aktion begin try receive aus.
OnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)	Führt die Aktion begin try receive aus.
OnBeginTryReceive2(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)	Führt die Aktion begin try receive aus.
OnBeginTryReceiveEventData(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)	Wird beim Aufrufen des OnTryReceive- oder BeginTryReceive-Vorgangs für die Ereignisdaten ausgeführt.
OnClose(TimeSpan)	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnClosed()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnComplete(TrackingContext, IEnumerable<Guid>, TimeSpan)	Führt die vollständige Aktion aus.
OnDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, String, String, TimeSpan)	Führt die Warteschlangenaktion zum Verschieben in unzustellbare Nachrichten aus.
OnDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String,Object>, TimeSpan)	Führt die Zurückstellungsaktion aus.
OnEndAbandon(IAsyncResult)	Führt die Endabbruchaktion aus.
OnEndClose(IAsyncResult)	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnEndComplete(IAsyncResult)	Führt die end complete-Aktion aus.
OnEndDeadLetter(IAsyncResult)	Führt die Warteschlangenaktion zum Ende des Verschiebens in unzustellbare Nachrichten aus.
OnEndDefer(IAsyncResult)	Führt die Ende-Zurückstellungsaktion aus.
OnEndOpen(IAsyncResult)	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnEndPeek(IAsyncResult)	Führt den EndPeek-Vorgang aus.
OnEndRenewMessageLocks(IAsyncResult)	Führt die Aktion EndRenew für Nachrichtensperren aus.
OnEndTryReceive(IAsyncResult, IEnumerable<BrokeredMessage>)	Führt die Aktion "End try receive" aus.
OnEndTryReceive2(IAsyncResult, IEnumerable<BrokeredMessage>)	Führt die Aktion "End try receive" aus.
OnEndTryReceiveEventData(IAsyncResult, IEnumerable<EventData>)	Führt die EndTryReceive-Aktion für die Ereignisdaten aus.
OnFaulted()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnMessage(Action<BrokeredMessage>, OnMessageOptions)	Verarbeitet eine Nachricht in einer ereignisgesteuerten Nachrichtenpumpe.
OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions)	Verarbeitet eine Nachricht asynchron in einer ereignisgesteuerten Nachrichtenpumpe.
OnOpen(TimeSpan)	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnOpened()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
OnPeek(TrackingContext, Int64, Int32, TimeSpan)	Wird beim Aufrufen des Peek-Vorgangs ausgeführt.
OnRenewMessageLocks(TrackingContext, IEnumerable<Guid>, TimeSpan)	Führt die Aktion Verlängern für Sperrnachrichten aus.
OnTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, IEnumerable<BrokeredMessage>)	Führt die Aktion try receive aus.
OnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<BrokeredMessage>)	Führt die Aktion try receive aus.
Peek()	Liest die nächste Nachricht, ohne den Status des Empfängers oder der Nachrichtenquelle zu ändern.
Peek(Int64)	Liest die nächste Nachricht, ohne den Status des Empfängers oder der Nachrichtenquelle zu ändern.
PeekAsync()	Liest die nächste Nachricht asynchron, ohne den Status des Empfängers oder der Nachrichtenquelle zu ändern.
PeekAsync(Int64)	Liest die nächste Nachricht asynchron, ohne den Status des Empfängers oder der Nachrichtenquelle zu ändern.
PeekBatch(Int32)	Liest den nächsten Nachrichtenbatch, ohne den Status des Empfängers oder der Nachrichtenquelle zu ändern.
PeekBatch(Int64, Int32)	Liest den nächsten Nachrichtenbatch, ohne den Status des Empfängers oder der Nachrichtenquelle zu ändern.
PeekBatchAsync(Int32)	Liest den nächsten Nachrichtenbatch asynchron, ohne den Status des Empfängers oder der Nachrichtenquelle zu ändern.
PeekBatchAsync(Int64, Int32)	Liest den nächsten Nachrichtenbatch asynchron, ohne den Status des Empfängers oder der Nachrichtenquelle zu ändern.
Receive()	Empfängt einen BrokeredMessage aus der aktuellen Warteschlange oder dem aktuellen Thema.
Receive(Int64)	Empfängt eine verzögerte Nachricht aus der aktuellen Warteschlange oder dem aktuellen Thema. Diese Methode funktioniert nur für verzögerte Nachrichten, nicht für reguläre Nachrichten.
Receive(TimeSpan)	Empfängt einen BrokeredMessage aus der aktuellen Warteschlange oder dem aktuellen Thema.
ReceiveAsync()	Empfängt asynchron eine Nachricht aus der aktuellen Warteschlange oder dem aktuellen Thema.
ReceiveAsync(Int64)	Empfängt asynchron eine verzögerte Nachricht aus der aktuellen Warteschlange oder dem aktuellen Thema. Diese Methode funktioniert nur für verzögerte Nachrichten, nicht für reguläre Nachrichten.
ReceiveAsync(TimeSpan)	Empfängt asynchron eine Nachricht aus der aktuellen Warteschlange oder dem aktuellen Thema.
ReceiveBatch(IEnumerable<Int64>)	Empfängt einen Batch von Nachrichten.
ReceiveBatch(Int32)	Empfängt einen Batch von Nachrichten.
ReceiveBatch(Int32, TimeSpan)	Empfängt einen Batch von Nachrichten.
ReceiveBatchAsync(IEnumerable<Int64>)	Empfängt asynchron einen Batch von Nachrichten.
ReceiveBatchAsync(Int32)	Empfängt asynchron einen Batch von Nachrichten.
ReceiveBatchAsync(Int32, TimeSpan)	Empfängt asynchron einen Batch von Nachrichten.
ThrowIfClosed()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
ThrowIfDisposed()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
ThrowIfDisposedOrImmutable()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
ThrowIfDisposedOrNotOpen()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)
ThrowIfFaulted()	Die MessageReceiver-Klasse wird verwendet, um Nachrichten aus dem Nachrichtencontainer zu empfangen und zu bestätigen. (Geerbt von ClientEntity)

Gilt für:

Freigeben über