VENTES: 1-800-867-1389

Classe QueueClient

Représente l'objet client de file d'attente.

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

public abstract class QueueClient : MessageClientEntity

Le type QueueClient expose les membres suivants.

  NomDescription
Propriété publiqueIsClosed (hérité de ClientEntity.)
Propriété publiqueMessagingFactoryObtient ou définit la fabrique de messagerie.
Propriété publiqueModeObtient le mode de réception de message lors du traitement du message reçu.
Propriété publiquePathObtient ou définit le nom de chemin d'accès complet de la file d'attente.
Propriété publiquePrefetchCountObtient ou définit le nombre de messages que le destinataire de file d'attente peut demander simultanément.
Propriété publiqueRetryPolicy (hérité de ClientEntity.)
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 publiqueAcceptMessageSession()Accepte une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique.
Méthode publiqueAcceptMessageSession(String)Accepte une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique à l'aide de l'identificateur de session indiqué.
Méthode publiqueAcceptMessageSession(TimeSpan)Accepte une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique à l'aide du temps d'attente du serveur spécifié.
Méthode publiqueAcceptMessageSession(String, TimeSpan)Accepte une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique à l'aide de l'identificateur de session et du temps d'attente indiqués.
Méthode publiqueAcceptMessageSessionAsync()Accepte de manière asynchrone une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique.
Méthode publiqueAcceptMessageSessionAsync(String)Accepte de manière asynchrone une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique à l'aide de l'identificateur de session indiqué.
Méthode publiqueAcceptMessageSessionAsync(TimeSpan)Accepte de manière asynchrone une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique à l'aide du temps d'attente de serveur spécifié.
Méthode publiqueAcceptMessageSessionAsync(String, TimeSpan)Accepte de manière asynchrone une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique à l'aide de l'identificateur de session et du temps d'attente indiqués.
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 publiqueBeginAcceptMessageSession(AsyncCallback, Object)Commence une opération asynchrone d'acceptation d'une session de messagerie.
Méthode publiqueBeginAcceptMessageSession(String, AsyncCallback, Object)Commence une opération asynchrone d'acceptation d'une session de messagerie.
Méthode publiqueBeginAcceptMessageSession(TimeSpan, AsyncCallback, Object)Commence une opération asynchrone d'acceptation d'une session de messagerie.
Méthode publiqueBeginAcceptMessageSession(String, TimeSpan, AsyncCallback, Object)Commence une opération asynchrone d'acceptation d'une session de messagerie.
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 du traitement d'un message.
Méthode publiqueBeginCompleteBatchCommence une opération asynchrone d'achèvement du traitement d'un lot de 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 d'interruption du traitement d'un message.
Méthode publiqueBeginDefer(Guid, IDictionary<String, Object>, AsyncCallback, Object)Commence une opération asynchrone d'interruption du traitement d'un message.
Méthode publiqueBeginGetMessageSessions(AsyncCallback, Object)Commence une opération asynchrone d'obtention des sessions de messagerie.
Méthode publiqueBeginGetMessageSessions(DateTime, AsyncCallback, Object)Commence une opération asynchrone d'obtention des sessions de messagerie.
Méthode publiqueBeginPeek(AsyncCallback, Object)Commence une opération asynchrone de lecture d'un message.
Méthode publiqueBeginPeek(Int64, AsyncCallback, Object)Commence une opération asynchrone de lecture d'un message.
Méthode publiqueBeginPeekBatch(Int32, AsyncCallback, Object)Commence une opération asynchrone de lecture d'un lot de messages.
Méthode publiqueBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Commence une opération asynchrone 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 publiqueBeginSendCommence une opération asynchrone d'envoi de message.
Méthode publiqueBeginSendBatchCommence une opération asynchrone d'envoi 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 le traitement d'un message.
Méthode publiqueCompleteAsyncAchève de manière asynchrone le traitement d'un message.
Méthode publiqueCompleteBatchAchève le traitement d'un lot de messages.
Méthode publiqueCompleteBatchAsyncAchève de manière asynchrone le traitement d'un lot de messages.
Méthode publiqueMembre statiqueCreate(String)Crée une copie de QueueClient avec le chemin d'accès spécifié.
Méthode publiqueMembre statiqueCreate(String, ReceiveMode)Crée une copie de QueueClient avec le chemin d'accès et le mode spécifiés.
Méthode publiqueMembre statiqueCreateFromConnectionString(String)
Méthode publiqueMembre statiqueCreateFromConnectionString(String, ReceiveMode)
Méthode publiqueMembre statiqueCreateFromConnectionString(String, String)Crée une copie de QueueClient à partir d'une chaîne de connexion avec le chemin d'accès spécifié.
Méthode publiqueMembre statiqueCreateFromConnectionString(String, String, ReceiveMode)Crée une copie de QueueClient à partir d'une chaîne de connexion avec le chemin d'accès et le mode spécifiés.
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)Interrompt le traitement d'un message.
Méthode publiqueDefer(Guid, IDictionary<String, Object>)Interrompt le traitement d'un message.
Méthode publiqueDeferAsync(Guid)Interrompt de manière asynchrone le traitement d'un message.
Méthode publiqueDeferAsync(Guid, IDictionary<String, Object>)Interrompt de manière asynchrone le traitement d'un message.
Méthode publiqueEndAbandonAchève une opération asynchrone pour abandonner le message et son verrou.
Méthode publiqueEndAcceptMessageSessionAchève une opération asynchrone d'acceptation d'une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique.
Méthode publiqueEndCloseAchève une opération asynchrone de fermeture d'entité cliente de message. (hérité de MessageClientEntity.)
Méthode publiqueEndCompleteAchève une opération asynchrone d'achèvement du traitement d'un message.
Méthode publiqueEndCompleteBatchMet fin à une opération asynchrone d'achèvement du traitement d'un lot de messages.
Méthode publiqueEndDeadLetterAchève une opération asynchrone de déplacement du message vers la file d'attente de lettres mortes.
Méthode publiqueEndDeferAchève une opération asynchrone de suspension du traitement d'un message.
Méthode publiqueEndGetMessageSessionsTermine une opération asynchrone d'obtention des sessions de messagerie.
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 publiqueEndReceiveAchève une opération asynchrone de réception de message.
Méthode publiqueEndReceiveBatchAchève une opération asynchrone de réception d'un lot de messages.
Méthode publiqueEndSendAchève une opération asynchrone d'envoi de message.
Méthode publiqueEndSendBatchAchève une opération asynchrone d'envoi 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 publiqueMembre statiqueFormatDeadLetterPathCrée un nom de format à partir de la file d'attente de caractères inactifs spécifiée.
Méthode publiqueMembre statiqueFormatTransferDeadLetterPath
Méthode publiqueGetHashCode (hérité de Object.)
Méthode publiqueGetMessageSessions()Obtient les sessions de messagerie pour vous permettre de parcourir les sessions dans les files d’attente.
Méthode publiqueGetMessageSessions(DateTime)Récupère toutes les sessions de messagerie dont l’état a changé depuis lastUpdatedTime.
Méthode publiqueGetMessageSessionsAsync()Obtient de manière asynchrone les sessions de messagerie pour vous permettre de parcourir les sessions dans les files d'attente.
Méthode publiqueGetMessageSessionsAsync(DateTime)Récupère de manière asynchrone toutes les sessions de messagerie dont l'état a changé depuis lastUpdatedTime.
Méthode publiqueGetType (hérité de Object.)
Méthode protégéeMemberwiseClone (hérité de Object.)
Méthode protégéeOnAbortS'exécute sur l'appel de l'événement Abort. (remplace ClientEntity.OnAbort().)
Méthode protégéeOnBeginAcceptMessageSessionS'exécute lors de l'appel de l'opération BeginAcceptMessageSession.
Méthode protégéeOnBeginCloseS'exécute lors de l'appel de l'opération Close. (remplace ClientEntity.OnBeginClose(TimeSpan, AsyncCallback, Object).)
Méthode protégéeOnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)Exécute l'action de début de création du destinataire.
Méthode protégéeOnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)Exécute l'action de début de création du destinataire.
Méthode protégéeOnBeginCreateSenderExécute l'action de début de création de l'expéditeur.
Méthode protégéeOnBeginGetMessageSessionsExécute l'action BeginGetMessageSessions.
Méthode protégéeOnBeginOpen (hérité de ClientEntity.)
Méthode protégéeOnCloseS'exécute sur l'appel de l'action Close. (remplace ClientEntity.OnClose(TimeSpan).)
Méthode protégéeOnClosed (hérité de ClientEntity.)
Méthode protégéeOnEndAcceptMessageSessionS'exécute lors de l'appel de l'opération EndAcceptMessageSession.
Méthode protégéeOnEndCloseExécute l'action de fin de fermeture. (remplace ClientEntity.OnEndClose(IAsyncResult).)
Méthode protégéeOnEndCreateReceiverExécute l'action de fin de création de destinataire.
Méthode protégéeOnEndCreateSenderExécute l'action de fin de création de l'expéditeur.
Méthode protégéeOnEndGetMessageSessionsExécute l'action de fin d'obtention du message.
Méthode protégéeOnEndOpen (hérité de ClientEntity.)
Méthode protégéeOnFaulted (hérité de ClientEntity.)
Méthode publiqueOnMessage(Action<BrokeredMessage>)Traite un message dans une pompe de messages pilotée par événements.
Méthode publiqueOnMessage(Action<BrokeredMessage>, OnMessageOptions)Traite un message dans une pompe de messages pilotée par événements avec un ensemble donné d'options OnMessageOptions.
Méthode publiqueOnMessageAsync(Func<BrokeredMessage, Task>)Traite de manière asynchrone un message.
Méthode publiqueOnMessageAsync(Func<BrokeredMessage, Task>, OnMessageOptions)Traite de manière asynchrone un message.
Méthode protégéeOnOpen (hérité de ClientEntity.)
Méthode protégéeOnOpened (hérité de ClientEntity.)
Méthode publiquePeek()Retourne sans supprimer le premier message de la file d'attente.
Méthode publiquePeek(Int64)Retourne sans supprimer le premier message de la file d'attente.
Méthode publiquePeekAsync()Retourne de manière asynchrone sans supprimer le premier message de la file d'attente.
Méthode publiquePeekAsync(Int64)Retourne de manière asynchrone sans supprimer le premier message de la file d'attente.
Méthode publiquePeekBatch(Int32)Lit un lot de messages.
Méthode publiquePeekBatch(Int64, Int32)Lit un lot de messages.
Méthode publiquePeekBatchAsync(Int32)Lit de manière asynchrone un lot de messages.
Méthode publiquePeekBatchAsync(Int64, Int32)Lit de manière asynchrone un lot de messages.
Méthode publiqueReceive()Reçoit un message à l'aide du InternalReceiver.
Méthode publiqueReceive(Int64)Reçoit un message à l'aide du InternalReceiver.
Méthode publiqueReceive(TimeSpan)Reçoit un message à l'aide du InternalReceiver.
Méthode publiqueReceiveAsync()Reçoit de manière asynchrone un message à l'aide du InternalReceiver.
Méthode publiqueReceiveAsync(Int64)Reçoit de manière asynchrone un message à l'aide du InternalReceiver.
Méthode publiqueReceiveAsync(TimeSpan)Reçoit de manière asynchrone un message à l'aide du InternalReceiver.
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 publiqueRegisterSessionHandler(Type)Inscrit le gestionnaire de sessions avec un type spécifique.
Méthode publiqueRegisterSessionHandler(Type, SessionHandlerOptions)Inscrit le gestionnaire de sessions avec un type spécifique et les options du gestionnaire.
Méthode publiqueRegisterSessionHandlerAsync(Type)Inscrit de manière asynchrone le gestionnaire de sessions avec un type spécifique.
Méthode publiqueRegisterSessionHandlerAsync(Type, SessionHandlerOptions)Inscrit de manière asynchrone le gestionnaire de sessions avec un type spécifique et les options du gestionnaire.
Méthode publiqueRegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Inscrit une fabrique du gestionnaire de sessions de messages avec des options spécifiées.
Méthode publiqueRegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)Inscrit une fabrique du gestionnaire de sessions de messages avec des options spécifiées.
Méthode publiqueRegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Inscrit de manière asynchrone une fabrique du gestionnaire de sessions de messages.
Méthode publiqueRegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)Inscrit de manière asynchrone une fabrique du gestionnaire de sessions de messages.
Méthode publiqueSendEnvoie un message en utilisant le InternalSender.
Méthode publiqueSendAsyncEnvoie de manière asynchrone un message à l'aide de l'InternalSender.
Méthode publiqueSendBatchEnvoie un ensemble de messages répartis (pour le traitement par lots).
Méthode publiqueSendBatchAsyncEnvoie de manière asynchrone un ensemble de messages répartis (pour le traitement par lots).
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

This class is mainly used for Service Bus run-time operations, such as sending and receiving messages.

This abstract class is not meant to be inherited, so protected members of this class should be ignored.

// Create the MessagingFactory
     MessagingFactory factory = 
     MessagingFactory.Create(myServiceBusNamespaceUri, SharedSecretTokenProvider.CreateSharedSecretTokenProvider(issuerName, issuerKey));
    
     //********************************************************************************
     //                          Sending messages to a Queue
     //********************************************************************************
    
     // Create queue client
     QueueClient myQueueClient = factory.CreateQueueClient("myQueue");
    
     // Send messages
     List <object>; Issues = new List <object>();
     foreach (var issue in Issues)
     {
        myQueueClient.Send(new BrokeredMessage(issue));
     }
    
     // ... Recieve messages
     for (int count = 0; count < MsgCount; count++)
     {
         var message = myQueueClient.Receive();
         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
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