Cette page vous a-t-elle été utile ?
Votre avis sur ce contenu est important. N'hésitez pas à nous faire part de vos commentaires.
Vous avez d'autres commentaires ?
1500 caractères restants
Exporter (0) Imprimer
Développer tout

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)

[<AbstractClassAttribute>]
type MessageReceiver =  
    class 
        inherit MessageClientEntity 
    end

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é protégéeOffsetInclusive
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éeReceiverStartTimeObtient ou définit l'heure de début du récepteur.
Propriété publiqueRetryPolicy (hérité de ClientEntity.)
Propriété protégéeStartOffsetObtient ou définit le point de départ du décalage.
Propriété protégéeSupportsGetRuntimeEntityDescription
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(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(String, Object))Ignore le message de manière asynchrone et abandonne la propriété de son verrou.
Méthode publiqueAbortEffectue une fonctionnalité d'abandon sur l'entité de messagerie. (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(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(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(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(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 publiqueCloseEnvoie un message de nettoyage à Service Bus pour signaler la fin de l'utilisation d'une entité. (hérité de ClientEntity.)
Méthode publiqueCloseAsyncEnvoie en mode asynchrone un message de nettoyage à Service Bus pour signaler la fin de l'utilisation d'une entité. (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(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(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(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(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éeFaultPour utilisation interne uniquement. Ne pas hériter de cette classe. (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 protégéeGetProperty(T)
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(ArraySegment(Byte)), Boolean, TimeSpan, AsyncCallback, Object)S'exécute sur l'appel de l'opération OnComplete ou BeginComplete.
Méthode protégéeOnBeginComplete(TrackingContext, IEnumerable(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(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éeOnBeginTryReceiveEventDataS'exécute sur l'appel de l'opération OnTryReceive ou BeginTryReceive pour les données d'événement.
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éeOnEndTryReceiveEventDataExécute l'action EndTryReceive pour les données d'événement.
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(Int64), TimeSpan, IEnumerable(BrokeredMessage))S'exécute sur l'appel de l'opération TryReceive.
Méthode protégéeOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable(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(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(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

Vous pouvez utiliser la classe QueueClient pour échanger des messages sans créer d’objet MessageReceiver. Vous pouvez également utiliser MessageSender et MessageReceiver pour créer un expéditeur et un destinataire sur une entité. Vous pouvez seulement utiliser un MessageReceiver pour recevoir les messages d’une file d’attente ou d’un abonnement. Vous ne pouvez pas recevoir de messages ou écouter les messages d’une rubrique. De même, vous pouvez seulement utiliser un MessageSender pour envoyer des messages à une file d’attente ou une rubrique. Vous ne pouvez pas envoyer de messages à un abonnement. Notez que le mode de réception de messages par défaut est PeekLock, ce qui garantit une réception fiable des messages.

Lorsque vous créez un MessageReceiver pour des abonnements, le paramètre entityPath a la forme topicPath/subscriptions/subscriptionName.

L’exemple suivant reçoit un message de la file d’attente créée dans l’exemple MessageSender :

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

Les membres static publics (Shared dans Visual Basic) de ce type sont thread-safe. Le fait que les membres de l'instance soient thread-safe est également garanti.

Ajouts de la communauté

AJOUTER
Microsoft réalise une enquête en ligne pour recueillir votre opinion sur le site Web de MSDN. Si vous choisissez d’y participer, cette enquête en ligne vous sera présentée lorsque vous quitterez le site Web de MSDN.

Si vous souhaitez y participer,
Afficher:
© 2015 Microsoft