VENTES: 1-800-867-1389

Classe MessageReceiver

Reçoit des messages du conteneur de messages et en accuse réception.

Espace de noms :  Microsoft.ServiceBus.Messaging
Assembly :  Microsoft.ServiceBus (en Microsoft.ServiceBus.dll)

public abstract class MessageReceiver : MessageClientEntity

Le type MessageReceiver expose les membres suivants.

  NomDescription
Propriété publiqueBatchFlushIntervalObtient l'intervalle de vidage du lot.
Propriété protégéeBatchingEnabledObtient une valeur indiquant si le traitement par lot est activé.
Propriété publiqueIsClosed (hérité de ClientEntity.)
Propriété publiqueLastPeekedSequenceNumberObtient ou définit le numéro de séquence du dernier message lu.
Propriété publiqueModeObtient le mode de réception de message.
Propriété publiquePathObtient le chemin d'accès de la file d'attente ou de la rubrique, par rapport à l'adresse de base MessagingFactory.
Propriété publiquePrefetchCountObtient ou définit le nombre de messages que le destinataire peut demander simultanément.
Propriété protégéeReceiverStartTime
Propriété publiqueRetryPolicy (hérité de ClientEntity.)
Propriété protégéeStartOffset
Propriété protégéeThisLock (hérité de ClientEntity.)
Haut de la page

  NomDescription
Méthode publiqueAbandon(Guid)Ignore le message et abandonne la propriété de son verrou.
Méthode publiqueAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>))Ignore le message et abandonne la propriété de son verrou.
Méthode publiqueAbandonAsync(Guid)Ignore le message de manière asynchrone et abandonne la propriété de son verrou.
Méthode publiqueAbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Ignore le message de manière asynchrone et abandonne la propriété de son verrou.
Méthode publiqueAbortPerforms abort functionality on the messaging entity. (hérité de ClientEntity.)
Méthode publiqueBeginAbandon(Guid, AsyncCallback, Object)Commence une opération asynchrone pour abandonner le message et son verrou.
Méthode publiqueBeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Commence une opération asynchrone pour abandonner le message et son verrou.
Méthode publiqueBeginCloseCommence une opération asynchrone de fermeture d'entité cliente de message. (hérité de MessageClientEntity.)
Méthode publiqueBeginCompleteCommence une opération asynchrone d'achèvement de la réception d'un message.
Méthode publiqueBeginCompleteBatchCommence une opération asynchrone d'achèvement d'un traitement par lot des messages.
Méthode publiqueBeginDeadLetter(Guid, AsyncCallback, Object)Commence une opération asynchrone de déplacement d'un message vers la file d'attente de lettres mortes.
Méthode publiqueBeginDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Commence une opération asynchrone de déplacement d'un message vers la file d'attente de lettres mortes.
Méthode publiqueBeginDeadLetter(Guid, String, String, AsyncCallback, Object)Commence une opération asynchrone de déplacement d'un message vers la file d'attente de lettres mortes.
Méthode publiqueBeginDefer(Guid, AsyncCallback, Object)Commence une opération asynchrone de suspension de la réception d'un message.
Méthode publiqueBeginDefer(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)Commence une opération asynchrone de suspension de la réception d'un message.
Méthode publiqueBeginPeek(AsyncCallback, Object)Commence une opération de lecture d'un message.
Méthode publiqueBeginPeek(Int64, AsyncCallback, Object)Commence une opération de lecture d'un message.
Méthode publiqueBeginPeekBatch(Int32, AsyncCallback, Object)Commence une opération de lecture d'un lot de messages.
Méthode publiqueBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Commence une opération de lecture d'un lot de messages.
Méthode publiqueBeginReceive(AsyncCallback, Object)Commence une opération asynchrone de réception de message.
Méthode publiqueBeginReceive(Int64, AsyncCallback, Object)Commence une opération asynchrone de réception de message.
Méthode publiqueBeginReceive(TimeSpan, AsyncCallback, Object)Commence une opération asynchrone de réception de message.
Méthode publiqueBeginReceiveBatch(IEnumerable<(Of <<'(Int64>)>>), AsyncCallback, Object)Commence une opération asynchrone de réception d'un lot de messages.
Méthode publiqueBeginReceiveBatch(Int32, AsyncCallback, Object)Commence une opération asynchrone de réception d'un lot de messages.
Méthode publiqueBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Commence une opération asynchrone de réception d'un lot de messages.
Méthode publiqueCloseSends a cleanup message to Service Bus to signal the completion of the usage of an entity. (hérité de ClientEntity.)
Méthode publiqueCloseAsyncSends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity. (hérité de ClientEntity.)
Méthode publiqueCompleteAchève l'opération de réception d'un message.
Méthode publiqueCompleteAsyncAchève de manière asynchrone l'opération de réception d'un message.
Méthode publiqueCompleteBatchAchève l'opération de réception d'un lot de messages.
Méthode publiqueCompleteBatchAsyncAchève de manière asynchrone l'opération de réception d'un lot de messages.
Méthode publiqueDeadLetter(Guid)Déplace le message non remis vers la file d'attente de lettres mortes.
Méthode publiqueDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>))Déplace le message non remis vers la file d'attente de lettres mortes.
Méthode publiqueDeadLetter(Guid, String, String)Déplace le message non remis vers la file d'attente de lettres mortes.
Méthode publiqueDeadLetterAsync(Guid)Déplace de manière asynchrone le message non remis vers la file d'attente de lettres mortes.
Méthode publiqueDeadLetterAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Déplace de manière asynchrone le message non remis vers la file d'attente de lettres mortes.
Méthode publiqueDeadLetterAsync(Guid, String, String)Déplace de manière asynchrone le message non remis vers la file d'attente de lettres mortes.
Méthode publiqueDefer(Guid)Indique que le destinataire souhaite différer le traitement de ce message.
Méthode publiqueDefer(Guid, IDictionary<(Of <<'(String, Object>)>>))Indique que le destinataire souhaite différer le traitement de ce message.
Méthode publiqueDeferAsync(Guid)Diffère de manière asynchrone le traitement d'un message.
Méthode publiqueDeferAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))Diffère de manière asynchrone le traitement d'un message.
Méthode publiqueEndAbandonMet fin à une opération asynchrone pour abandonner le message et son verrou.
Méthode publiqueEndCloseAchève une opération asynchrone de fermeture d'entité cliente de message. (hérité de MessageClientEntity.)
Méthode publiqueEndCompleteMet fin à l'opération asynchrone d'achèvement de la réception d'un message.
Méthode publiqueEndCompleteBatchMet fin à l'opération asynchrone d'achèvement de la réception d'un message par lot.
Méthode publiqueEndDeadLetterMet fin à une opération asynchrone de déplacement du message vers la file d'attente de caractères inactifs.
Méthode publiqueEndDeferMet fin à une opération asynchrone d'ajournement de la réception d'un message.
Méthode publiqueEndPeekMet fin à une opération asynchrone de lecture d'un message.
Méthode publiqueEndPeekBatchMet fin à une opération asynchrone de lecture d'un lot de messages.
Méthode publiqueEndReceiveMet fin à une opération asynchrone de réception d'un message.
Méthode publiqueEndReceiveBatchTermine une opération asynchrone de réception d'un lot de messages.
Méthode publiqueEquals (hérité de Object.)
Méthode protégéeFaultFor internal use only. Do not inherit from this class. (hérité de ClientEntity.)
Méthode protégéeFinalize (hérité de Object.)
Méthode publiqueGetHashCode (hérité de Object.)
Méthode protégéeMembre statiqueGetLockTokenObtient le jeton de verrou lié au message.
Méthode protégéeMembre statiqueGetLockTokensObtient la collection de jetons de message à partir de la collection de messages spécifiée.
Méthode publiqueGetType (hérité de Object.)
Méthode protégéeMemberwiseClone (hérité de Object.)
Méthode protégéeOnAbandonS'exécute lors de l'appel de l'opération Abandon.
Méthode protégéeOnAbort (hérité de ClientEntity.)
Méthode protégéeOnBeginAbandonS'exécute lors de l'appel de l'opération OnAbandon ou BeginAbandon.
Méthode protégéeOnBeginClose (hérité de ClientEntity.)
Méthode protégéeOnBeginComplete(TrackingContext, IEnumerable<(Of <<'(ArraySegment<(Of <<'(Byte>)>>)>)>>), Boolean, TimeSpan, AsyncCallback, Object)
Méthode protégéeOnBeginComplete(TrackingContext, IEnumerable<(Of <<'(Guid>)>>), Boolean, TimeSpan, AsyncCallback, Object)S'exécute sur l'appel de l'opération OnComplete ou BeginComplete.
Méthode protégéeOnBeginDeadLetterS'exécute lors de l'appel de l'opération OnDeadLetter ou BeginDeadLetter.
Méthode protégéeOnBeginDeferS'exécute lors de l'appel de l'opération OnDefer ou BeginDefer.
Méthode protégéeOnBeginOpen (hérité de ClientEntity.)
Méthode protégéeOnBeginPeekS'exécute lors de l'appel de l'opération BeginPeek.
Méthode protégéeOnBeginRenewMessageLocksS'exécute lors de l'appel de l'opération OnBegin pour les messages verrouillés.
Méthode protégéeOnBeginTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, AsyncCallback, Object)S'exécute sur l'appel de l'opération OnTryReceive ou BeginTryReceive.
Méthode protégéeOnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)S'exécute sur l'appel de l'opération OnTryReceive ou BeginTryReceive.
Méthode protégéeOnBeginTryReceive2S'exécute sur l'appel de l'opération OnTryReceive ou BeginTryReceive.
Méthode protégéeOnBeginTryReceiveEventData
Méthode protégéeOnClose (hérité de ClientEntity.)
Méthode protégéeOnClosed (hérité de ClientEntity.)
Méthode protégéeOnCompleteS'exécute sur l'appel de l'opération Complete.
Méthode protégéeOnDeadLetterS'exécute lors de l'appel de l'opération DeadLetter.
Méthode protégéeOnDeferS'exécute lors de l'appel de l'opération Defer.
Méthode protégéeOnEndAbandonExécute l'action de fin d'abandon.
Méthode protégéeOnEndClose (hérité de ClientEntity.)
Méthode protégéeOnEndCompleteExécute l'action d'achèvement finale.
Méthode protégéeOnEndDeadLetterExécute l'action finale de déplacement vers la file d'attente de caractères inactifs.
Méthode protégéeOnEndDeferExécute l'action d'ajournement finale.
Méthode protégéeOnEndOpen (hérité de ClientEntity.)
Méthode protégéeOnEndPeekExécute l'opération EndPeek.
Méthode protégéeOnEndRenewMessageLocksExécute l'action EndRenew pour les verrouillages de messages.
Méthode protégéeOnEndTryReceiveExécute l'action de fin de tentative de réception.
Méthode protégéeOnEndTryReceive2Exécute l'action de fin de tentative de réception.
Méthode protégéeOnEndTryReceiveEventData
Méthode protégéeOnFaulted (hérité de ClientEntity.)
Méthode publiqueOnMessageTraite un message dans une pompe de messages pilotée par événements.
Méthode publiqueOnMessageAsyncTraite de manière asynchrone un message dans une pompe de messages pilotée par événements.
Méthode protégéeOnOpen (hérité de ClientEntity.)
Méthode protégéeOnOpened (hérité de ClientEntity.)
Méthode protégéeOnPeekS'exécute lors de l'appel de l'opération Peek.
Méthode protégéeOnRenewMessageLocksExécute l'action Renew pour les messages verrouillés.
Méthode protégéeOnTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)S'exécute sur l'appel de l'opération TryReceive.
Méthode protégéeOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)S'exécute sur l'appel de l'opération TryReceive.
Méthode publiquePeek()()()()Lit le message suivant sans modifier l'état du destinataire ou de la source du message.
Méthode publiquePeek(Int64)Lit le message suivant sans modifier l'état du destinataire ou de la source du message.
Méthode publiquePeekAsync()()()()Lit de manière asynchrone le message suivant sans modifier l'état du destinataire ou de la source du message.
Méthode publiquePeekAsync(Int64)Lit de manière asynchrone le message suivant sans modifier l'état du destinataire ou de la source du message.
Méthode publiquePeekBatch(Int32)Lit le lot de messages suivant sans modifier l'état du destinataire ou de la source du message.
Méthode publiquePeekBatch(Int64, Int32)Lit le lot de messages suivant sans modifier l'état du destinataire ou de la source du message.
Méthode publiquePeekBatchAsync(Int32)Lit de manière asynchrone le lot de messages suivant sans modifier l'état du destinataire ou de la source du message.
Méthode publiquePeekBatchAsync(Int64, Int32)Lit de manière asynchrone le lot de messages suivant sans modifier l'état du destinataire ou de la source du message.
Méthode publiqueReceive()()()()Reçoit un BrokeredMessage à partir de la file d'attente ou de la rubrique actuelle.
Méthode publiqueReceive(Int64)Reçoit un message à partir de la file d'attente ou de la rubrique actuelle.
Méthode publiqueReceive(TimeSpan)Reçoit un BrokeredMessage à partir de la file d'attente ou de la rubrique actuelle.
Méthode publiqueReceiveAsync()()()()Reçoit de manière asynchrone un message à partir de la file d'attente ou de la rubrique actuelle.
Méthode publiqueReceiveAsync(Int64)Reçoit de manière asynchrone un message à partir de la file d'attente ou de la rubrique actuelle.
Méthode publiqueReceiveAsync(TimeSpan)Reçoit de manière asynchrone un message à partir de la file d'attente ou de la rubrique actuelle.
Méthode publiqueReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))Reçoit un lot de messages.
Méthode publiqueReceiveBatch(Int32)Reçoit un lot de messages.
Méthode publiqueReceiveBatch(Int32, TimeSpan)Reçoit un lot de messages.
Méthode publiqueReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Reçoit de manière asynchrone un lot de messages.
Méthode publiqueReceiveBatchAsync(Int32)Reçoit de manière asynchrone un lot de messages.
Méthode publiqueReceiveBatchAsync(Int32, TimeSpan)Reçoit de manière asynchrone un lot de messages.
Méthode protégéeThrowIfClosed (hérité de ClientEntity.)
Méthode protégéeThrowIfDisposed (hérité de ClientEntity.)
Méthode protégéeThrowIfDisposedOrImmutable (hérité de ClientEntity.)
Méthode protégéeThrowIfDisposedOrNotOpen (hérité de ClientEntity.)
Méthode protégéeThrowIfFaulted (hérité de ClientEntity.)
Méthode publiqueToString (hérité de Object.)
Haut de la page

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.

Cela vous a-t-il été utile ?
(1500 caractères restants)
Merci pour vos suggestions.

Ajouts de la communauté

AJOUTER
Afficher:
© 2014 Microsoft