MessageReceiver Classe
TOC
Réduire la table des matières
Développer la table des matières
Cet article a fait l'objet d'une traduction automatique. Déplacez votre pointeur sur les phrases de l'article pour voir la version originale de ce texte.
Traduction
Source

MessageReceiver, classe

 

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

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


public abstract class MessageReceiver : ClientEntity

NomDescription
System_CAPS_pubpropertyBatchFlushInterval

Obtient l'intervalle de vidage du lot.

System_CAPS_protpropertyBatchingEnabled

Obtient une valeur indiquant si le traitement par lots est activé.

System_CAPS_pubpropertyIsClosed

(Hérité de ClientEntity.)

System_CAPS_pubpropertyLastPeekedSequenceNumber

Obtient ou définit le numéro de séquence du dernier message lu.

System_CAPS_pubpropertyMode

Obtient le message de mode de réception.

System_CAPS_protpropertyOffsetInclusive

System_CAPS_pubpropertyPath

Obtient le chemin d'accès de la file d'attente ou rubrique, relatif à la MessagingFactory adresse de base.

System_CAPS_pubpropertyPrefetchCount

Obtient ou définit le nombre de messages que le destinataire peut demander simultanément.

System_CAPS_protpropertyReceiverStartTime

Obtient ou définit l'heure de début du récepteur.

System_CAPS_pubpropertyRetryPolicy

(Hérité de ClientEntity.)

System_CAPS_protpropertyStartOffset

Obtient ou définit le point de départ du décalage.

System_CAPS_protpropertySupportsGetRuntimeEntityDescription

System_CAPS_protpropertyThisLock

(Hérité de ClientEntity.)

NomDescription
System_CAPS_pubmethodAbandon(Guid)

Ignore le message et abandonne la propriété de verrouillage du message.

System_CAPS_pubmethodAbandon(Guid, IDictionary<String, Object>)

Ignore le message et abandonne la propriété de verrouillage du message.

System_CAPS_pubmethodAbandonAsync(Guid)

Ignore le message de façon asynchrone et abandonne la propriété de verrouillage du message.

System_CAPS_pubmethodAbandonAsync(Guid, IDictionary<String, Object>)

Ignore le message de façon asynchrone et abandonne la propriété de verrouillage du message.

System_CAPS_pubmethodAbort()

Effectue une fonctionnalité d'abandon sur l'entité de messagerie.(Hérité de ClientEntity.)

System_CAPS_pubmethodClose()

Envoie un message de nettoyage à Service Bus pour signaler la fin de l'utilisation d'une entité.(Hérité de ClientEntity.)

System_CAPS_pubmethodCloseAsync()

Envoie en mode asynchrone un message de nettoyage à Service Bus pour signaler la fin de l'utilisation d'une entité.(Hérité de ClientEntity.)

System_CAPS_pubmethodComplete(Guid)

Termine l'opération de réception d'un message.

System_CAPS_pubmethodCompleteAsync(Guid)

Achève de manière asynchrone l'opération de réception d'un message.

System_CAPS_pubmethodCompleteBatch(IEnumerable<Guid>)

Achève l'opération de réception d'un lot de messages.

System_CAPS_pubmethodCompleteBatchAsync(IEnumerable<Guid>)

Achève de manière asynchrone l'opération de réception d'un lot de messages.

System_CAPS_pubmethodDeadLetter(Guid)

Déplace le message non remis vers la file d'attente de lettres mortes.

System_CAPS_pubmethodDeadLetter(Guid, IDictionary<String, Object>)

Déplace le message non remis vers la file d'attente de lettres mortes.

System_CAPS_pubmethodDeadLetter(Guid, String, String)

Déplace le message non remis vers la file d'attente de lettres mortes.

System_CAPS_pubmethodDeadLetterAsync(Guid)

Déplace de manière asynchrone le message non remis vers la file d'attente de lettres mortes.

System_CAPS_pubmethodDeadLetterAsync(Guid, IDictionary<String, Object>)

Déplace le message non remis de manière asynchrone à la file d'attente de lettres mortes.

System_CAPS_pubmethodDeadLetterAsync(Guid, String, String)

Déplace le message non remis de manière asynchrone à la file d'attente de lettres mortes.

System_CAPS_pubmethodDefer(Guid)

Indique que le destinataire souhaite différer le traitement du message.

System_CAPS_pubmethodDefer(Guid, IDictionary<String, Object>)

Indique que le destinataire souhaite différer le traitement de ce message.

System_CAPS_pubmethodDeferAsync(Guid)

Diffère de manière asynchrone le traitement d'un message.

System_CAPS_pubmethodDeferAsync(Guid, IDictionary<String, Object>)

Diffère de manière asynchrone le traitement d'un message.

System_CAPS_pubmethodEquals(Object)

(Hérité de Object.)

System_CAPS_protmethodFault()

À usage interne uniquement. Ne pas hériter de cette classe.(Hérité de ClientEntity.)

System_CAPS_protmethodFinalize()

(Hérité de Object.)

System_CAPS_pubmethodGetHashCode()

(Hérité de Object.)

System_CAPS_protmethodSystem_CAPS_staticGetLockToken(BrokeredMessage)

Obtient le jeton de verrou lié au message.

System_CAPS_protmethodSystem_CAPS_staticGetLockTokens(IEnumerable<BrokeredMessage>)

Obtient la collection de jetons à partir de la collection spécifiée de messages.

System_CAPS_protmethodGetProperty<T>()

System_CAPS_pubmethodGetType()

(Hérité de Object.)

System_CAPS_protmethodMemberwiseClone()

(Hérité de Object.)

System_CAPS_protmethodOnAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String, Object>, TimeSpan)

S'exécute lors de l'appel du Abandon opération.

System_CAPS_protmethodOnAbort()

(Hérité de ClientEntity.)

System_CAPS_protmethodOnBeginAbandon(TrackingContext, IEnumerable<Guid>, IDictionary<String, Object>, Boolean, TimeSpan, AsyncCallback, Object)

S'exécute lors de l'appel du OnAbandon ou BeginAbandon opération.

System_CAPS_protmethodOnBeginClose(TimeSpan, AsyncCallback, Object)

(Hérité de ClientEntity.)

System_CAPS_protmethodOnBeginComplete(TrackingContext, IEnumerable<ArraySegment<Byte>>, Boolean, TimeSpan, AsyncCallback, Object)

S'exécute lors de l'appel du OnComplete ou BeginComplete opération.

System_CAPS_protmethodOnBeginComplete(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)

S'exécute sur l'appel du OnComplete ou BeginComplete opération.

System_CAPS_protmethodOnBeginDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String, Object>, String, String, Boolean, TimeSpan, AsyncCallback, Object)

S'exécute sur l'appel du OnDeadLetter ou BeginDeadLetter opération.

System_CAPS_protmethodOnBeginDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String, Object>, Boolean, TimeSpan, AsyncCallback, Object)

S'exécute lors de l'appel du OnDefer ou BeginDefer opération.

System_CAPS_protmethodOnBeginOpen(TimeSpan, AsyncCallback, Object)

(Hérité de ClientEntity.)

System_CAPS_protmethodOnBeginPeek(TrackingContext, Int64, Int32, TimeSpan, AsyncCallback, Object)

S'exécute sur l'appel du BeginPeek opération.

System_CAPS_protmethodOnBeginRenewMessageLocks(TrackingContext, IEnumerable<Guid>, Boolean, TimeSpan, AsyncCallback, Object)

S'exécute lors de l'appel du OnBegin opération pour les messages verrouillés.

System_CAPS_protmethodOnBeginTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, AsyncCallback, Object)

S'exécute lors de l'appel du OnTryReceive ou BeginTryReceive opération.

System_CAPS_protmethodOnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)

S'exécute lors de l'appel du OnTryReceive ou BeginTryReceive opération.

System_CAPS_protmethodOnBeginTryReceive2(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)

S'exécute sur l'appel du OnTryReceive ou BeginTryReceive opération.

System_CAPS_protmethodOnBeginTryReceiveEventData(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)

S'exécute sur l'appel du OnTryReceive ou BeginTryReceive opération pour les données d'événement.

System_CAPS_protmethodOnClose(TimeSpan)

(Hérité de ClientEntity.)

System_CAPS_protmethodOnClosed()

(Hérité de ClientEntity.)

System_CAPS_protmethodOnComplete(TrackingContext, IEnumerable<Guid>, TimeSpan)

S'exécute lors de l'appel du Complete opération.

System_CAPS_protmethodOnDeadLetter(TrackingContext, IEnumerable<Guid>, IDictionary<String, Object>, String, String, TimeSpan)

S'exécute lors de l'appel du DeadLetter opération.

System_CAPS_protmethodOnDefer(TrackingContext, IEnumerable<Guid>, IDictionary<String, Object>, TimeSpan)

S'exécute lors de l'appel du Defer opération.

System_CAPS_protmethodOnEndAbandon(IAsyncResult)

Exécute l'action de fin d'abandon.

System_CAPS_protmethodOnEndClose(IAsyncResult)

(Hérité de ClientEntity.)

System_CAPS_protmethodOnEndComplete(IAsyncResult)

Exécute l'action d'achèvement finale.

System_CAPS_protmethodOnEndDeadLetter(IAsyncResult)

Exécute l'action finale de déplacement vers la file d'attente de caractères inactifs.

System_CAPS_protmethodOnEndDefer(IAsyncResult)

Exécute l'action d'ajournement finale.

System_CAPS_protmethodOnEndOpen(IAsyncResult)

(Hérité de ClientEntity.)

System_CAPS_protmethodOnEndPeek(IAsyncResult)

Exécute le EndPeek opération.

System_CAPS_protmethodOnEndRenewMessageLocks(IAsyncResult)

Exécute le EndRenew action pour les verrouillages de messages.

System_CAPS_protmethodOnEndTryReceive(IAsyncResult, IEnumerable<BrokeredMessage>)

Exécute l'action de fin de tentative de réception.

System_CAPS_protmethodOnEndTryReceive2(IAsyncResult, IEnumerable<BrokeredMessage>)

Exécute l'essayer l'action de réception.

System_CAPS_protmethodOnEndTryReceiveEventData(IAsyncResult, IEnumerable<EventData>)

Exécute le EndTryReceive action pour les données d'événement.

System_CAPS_protmethodOnFaulted()

(Hérité de ClientEntity.)

System_CAPS_pubmethodOnMessage(Action<BrokeredMessage>, OnMessageOptions)

Traite un message dans une pompe de messages pilotée par événements.

System_CAPS_pubmethodOnMessageAsync(Func<BrokeredMessage, Task>, OnMessageOptions)

Traite de manière asynchrone un message dans une pompe de messages pilotée par événements.

System_CAPS_protmethodOnOpen(TimeSpan)

(Hérité de ClientEntity.)

System_CAPS_protmethodOnOpened()

(Hérité de ClientEntity.)

System_CAPS_protmethodOnPeek(TrackingContext, Int64, Int32, TimeSpan)

S'exécute lors de l'appel du Peek opération.

System_CAPS_protmethodOnRenewMessageLocks(TrackingContext, IEnumerable<Guid>, TimeSpan)

Exécute le Renew action pour les messages verrouillés.

System_CAPS_protmethodOnTryReceive(TrackingContext, IEnumerable<Int64>, TimeSpan, IEnumerable<BrokeredMessage>)

S'exécute sur l'appel du TryReceive opération.

System_CAPS_protmethodOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<BrokeredMessage>)

S'exécute lors de l'appel du TryReceive opération.

System_CAPS_pubmethodPeek()

Lit le message suivant sans modifier l'état du destinataire ou de la source du message.

System_CAPS_pubmethodPeek(Int64)

Lit le message suivant sans modifier l'état du destinataire ou de la source du message.

System_CAPS_pubmethodPeekAsync()

Lit de manière asynchrone le message suivant sans modifier l'état du destinataire ou de la source du message.

System_CAPS_pubmethodPeekAsync(Int64)

Lit de manière asynchrone le message suivant sans modifier l'état du destinataire ou de la source du message.

System_CAPS_pubmethodPeekBatch(Int32)

Lit le lot de messages suivant sans modifier l'état du destinataire ou de la source du message.

System_CAPS_pubmethodPeekBatch(Int64, Int32)

Lit le lot de messages suivant sans modifier l'état du destinataire ou de la source du message.

System_CAPS_pubmethodPeekBatchAsync(Int32)

Lit de façon asynchrone le lot de messages suivant sans modifier l'état du destinataire ou de la source du message.

System_CAPS_pubmethodPeekBatchAsync(Int64, Int32)

Lit de façon asynchrone le lot de messages suivant sans modifier l'état du destinataire ou de la source du message.

System_CAPS_pubmethodReceive()

Reçoit un BrokeredMessage à partir de la file d'attente actuelle ou de la rubrique.

System_CAPS_pubmethodReceive(Int64)

Reçoit un message de la file d'attente actuelle ou de la rubrique.

System_CAPS_pubmethodReceive(TimeSpan)

Reçoit un BrokeredMessage à partir de la file d'attente actuelle ou de la rubrique.

System_CAPS_pubmethodReceiveAsync()

Reçoit de manière asynchrone un message à partir de la file d'attente ou de la rubrique actuelle.

System_CAPS_pubmethodReceiveAsync(Int64)

Reçoit un message de manière asynchrone à partir de la file d'attente actuelle ou de la rubrique.

System_CAPS_pubmethodReceiveAsync(TimeSpan)

Reçoit un message de manière asynchrone à partir de la file d'attente actuelle ou de la rubrique.

System_CAPS_pubmethodReceiveBatch(IEnumerable<Int64>)

Reçoit un lot de messages.

System_CAPS_pubmethodReceiveBatch(Int32)

Reçoit un lot de messages.

System_CAPS_pubmethodReceiveBatch(Int32, TimeSpan)

Reçoit un lot de messages.

System_CAPS_pubmethodReceiveBatchAsync(IEnumerable<Int64>)

Reçoit de manière asynchrone un lot de messages.

System_CAPS_pubmethodReceiveBatchAsync(Int32)

Reçoit de manière asynchrone un lot de messages.

System_CAPS_pubmethodReceiveBatchAsync(Int32, TimeSpan)

Reçoit de manière asynchrone un lot de messages.

System_CAPS_protmethodThrowIfClosed()

(Hérité de ClientEntity.)

System_CAPS_protmethodThrowIfDisposed()

(Hérité de ClientEntity.)

System_CAPS_protmethodThrowIfDisposedOrImmutable()

(Hérité de ClientEntity.)

System_CAPS_protmethodThrowIfDisposedOrNotOpen()

(Hérité de ClientEntity.)

System_CAPS_protmethodThrowIfFaulted()

(Hérité de ClientEntity.)

System_CAPS_pubmethodToString()

(Hérité de Object.)

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

Lorsque vous créez un MessageReceiver pour les abonnements, la entityPath paramètre est de la forme topicPath/subscriptions/subscriptionName.

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

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

N'importe quel public statique (Shared en Visual Basic) de ce type sont thread-safe. Le fait que les membres de l'instance soient thread-safe est également garanti.

Retour au début
Afficher:
© 2016 Microsoft