Exporter (0) Imprimer
Développer tout

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 extends MessageClientEntity

Le type QueueClient expose les membres suivants.

  NomDescription
Propriété publiqueIsClosedObtient ou définit une valeur indiquant si l'entité cliente de message est fermée. (hérité de MessageClientEntity.)
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é publiqueRetryPolicyObtient ou définit une stratégie de nouvelle tentative associée à cette instance qui indique si la requête peut être soumise à nouveau. (hérité de MessageClientEntity.)
Propriété protégéeThisLockObtient un objet qui permet de verrouiller l'instance MessageClientEntity. (hérité de MessageClientEntity.)
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 publiqueAbortAbandonne l'entité cliente de message et la met en état de fermeture. (hérité de MessageClientEntity.)
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<(Of <<'(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<(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 d'interruption du traitement d'un message.
Méthode publiqueBeginDefer(Guid, IDictionary<(Of <<'(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<(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 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 publiqueCloseFerme l'entité cliente de message et la met en état fermé. (hérité de MessageClientEntity.)
Méthode publiqueCloseAsyncFerme de manière asynchrone l'entité cliente de message et lui attribue l'état Fermé. (hérité de MessageClientEntity.)
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, 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<(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)Interrompt le traitement d'un message.
Méthode publiqueDefer(Guid, IDictionary<(Of <<'(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<(Of <<'(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éeFaultMet l'entité cliente de message en état d'échec. (hérité de MessageClientEntity.)
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 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 MessageClientEntity..::..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 MessageClientEntity..::..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éeOnBeginOpenS'exécute lors de l'appel de l'opération de commencement d'ouverture de l'entité cliente de message. (hérité de MessageClientEntity.)
Méthode protégéeOnCloseS'exécute sur l'appel de l'action Close. (remplace MessageClientEntity..::..OnClose(TimeSpan).)
Méthode protégéeOnClosedSe produit lorsque l'entité cliente de message passe en état de fermeture. (hérité de MessageClientEntity.)
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 MessageClientEntity..::..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éeOnEndOpenS'exécute lors de l'appel de l'opération d'arrêt d'ouverture de l'entité cliente de message. (hérité de MessageClientEntity.)
Méthode protégéeOnFaultedS'exécute sur l'appel de l'opération Fault. (hérité de MessageClientEntity.)
Méthode publiqueOnMessage(Action<(Of <<'(BrokeredMessage>)>>))Traite un message dans une pompe de messages pilotée par événements.
Méthode publiqueOnMessage(Action<(Of <<'(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<(Of <<'(BrokeredMessage, Task>)>>))Traite de manière asynchrone un message.
Méthode publiqueOnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>), OnMessageOptions)Traite de manière asynchrone un message.
Méthode protégéeOnOpenS'exécute lors de l'appel de l'opération d'ouverture de l'entité cliente de message. (hérité de MessageClientEntity.)
Méthode protégéeOnOpenedS'exécute une fois l'entité cliente de message ouverte. (hérité de MessageClientEntity.)
Méthode protégéeOnRuntimeDescriptionChangedSignale un événement lorsque la description de l'exécution est modifiée. (hérité de MessageClientEntity.)
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<(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 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éeThrowIfClosedLève une exception en cas de fermeture de l'entité cliente de message. (hérité de MessageClientEntity.)
Méthode protégéeThrowIfDisposedLève une exception en cas de suppression de l'entité cliente de message. (hérité de MessageClientEntity.)
Méthode protégéeThrowIfDisposedOrImmutableLève une exception si le client est supprimé ou immuable. (hérité de MessageClientEntity.)
Méthode protégéeThrowIfDisposedOrNotOpenLève une exception si le client est supprimé ou non ouvert. (hérité de MessageClientEntity.)
Méthode protégéeThrowIfFaultedLève une exception si le client est en échec. (hérité de MessageClientEntity.)
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.

Ajouts de la communauté

AJOUTER
Afficher:
© 2014 Microsoft