Exporter (0) Imprimer
Développer tout

Classe SubscriptionClient

Représente la classe d'ancre utilisée dans les opérations de runtime en relation avec un abonnement à une rubrique.

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

public abstract class SubscriptionClient : MessageClientEntity

Le type SubscriptionClient expose les membres suivants.

  NomDescription
Propriété publiqueIsClosed (hérité de ClientEntity.)
Propriété publiqueMessagingFactoryObtient la fabrique de messagerie utilisée pour créer ce client d'abonnement.
Propriété publiqueModeObtient le mode de réception de message lors du traitement du message reçu.
Propriété publiqueNameObtient le nom de l'abonnement.
Propriété publiquePrefetchCountObtient ou définit le nombre de messages que le destinataire peut demander simultanément.
Propriété publiqueRetryPolicy (hérité de ClientEntity.)
Propriété protégéeThisLock (hérité de ClientEntity.)
Propriété publiqueTopicPathObtient le nom de chemin d'accès complet de la rubrique.
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 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 à l'aide du temps d'attente de serveur spécifié.
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 du temps d'attente de serveur spécifié.
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 du temps d'attente de serveur spécifié.
Méthode publiqueAddRule(RuleDescription)Ajoute une nouvelle règle à Subscription à l'aide de la description de règle spécifiée.
Méthode publiqueAddRule(String, Filter)Ajoute une règle à l'abonnement actuel avec le nom et l'expression de filtre spécifiés.
Méthode publiqueAddRuleAsync(RuleDescription)Ajoute de manière asynchrone une nouvelle règle à l'Subscription à l'aide de la description de règle spécifiée.
Méthode publiqueAddRuleAsync(String, Filter)Ajoute de manière asynchrone une règle à l'abonnement actuel avec le nom et l'expression de filtre spécifié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 publiqueBeginAddRule(RuleDescription, AsyncCallback, Object)Commence une opération asynchrone d'ajout d'une nouvelle règle à l'abonnement.
Méthode publiqueBeginAddRule(String, Filter, AsyncCallback, Object)Commence une opération asynchrone d'ajout d'une nouvelle règle à l'abonnement.
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 message.
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 d'une session de messagerie.
Méthode publiqueBeginGetMessageSessions(DateTime, AsyncCallback, Object)Commence une opération asynchrone d'obtention d'une session de messagerie.
Méthode publiqueBeginPeek(AsyncCallback, Object)Commence une opération asynchrone à retourner sans supprimer le premier message de la file d'attente.
Méthode publiqueBeginPeek(Int64, AsyncCallback, Object)Commence une opération asynchrone à retourner sans supprimer le premier message de la file d'attente.
Méthode publiqueBeginPeekBatch(Int32, AsyncCallback, Object)Commence une opération asynchrone de lecture d'un lot.
Méthode publiqueBeginPeekBatch(Int64, Int32, AsyncCallback, Object)Commence une opération asynchrone de lecture d'un lot.
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.
Méthode publiqueBeginReceiveBatch(Int32, AsyncCallback, Object)Commence une opération asynchrone de réception d'un lot.
Méthode publiqueBeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)Commence une opération asynchrone de réception d'un lot.
Méthode publiqueBeginRemoveRuleCommence une action de suppression de règle asynchrone.
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 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.
Méthode publiqueCompleteBatchAsyncAchève de manière asynchrone le traitement d'un lot.
Méthode publiqueMembre statiqueCreate(String, String)Crée une copie de SubscriptionClient avec le nom et le chemin d'accès à la rubrique spécifiés.
Méthode publiqueMembre statiqueCreate(String, String, ReceiveMode)Crée une nouvelle copie de SubscriptionClient avec le nom, le chemin d'accès à la rubrique et le mode spécifiés.
Méthode publiqueMembre statiqueCreateFromConnectionString(String, String, String)Crée une copie de SubscriptionClient à partir d'une chaîne de connexion avec le nom et le chemin d'accès à la rubrique spécifiés.
Méthode publiqueMembre statiqueCreateFromConnectionString(String, String, String, ReceiveMode)Crée une copie de SubscriptionClient à partir d'une chaîne de connexion avec le nom, le chemin d'accès à la rubrique 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 publiqueEndAddRuleMet fin à une opération d'ajout de règle asynchrone.
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 publiqueEndCompleteBatchAchève une opération asynchrone d'achèvement du traitement d'un lot.
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 publiqueEndGetMessageSessionsAchève une opération asynchrone d'obtention du traitement d'un message.
Méthode publiqueEndPeekTermine une opération asynchrone de lecture.
Méthode publiqueEndPeekBatchTermine 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.
Méthode publiqueEndRemoveRuleMet fin à une opération de suppression de règle asynchrone.
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 publiqueMembre statiqueFormatDeadLetterPathCrée un chemin de lettres mortes de nom de format à l'aide du chemin d'accès à la rubrique et du nom d'abonnement spécifiés.
Méthode publiqueMembre statiqueFormatSubscriptionPathCrée un chemin d'accès à l'abonnement au nom de format à l'aide du chemin d'accès à la rubrique et du nom d'abonnement spécifiés.
Méthode publiqueGetHashCode (hérité de Object.)
Méthode publiqueGetMessageSessions()()()()Obtient une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique.
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 une session de messagerie autorisant le regroupement de messages associés en vue de leur traitement dans une transaction unique.
Méthode publiqueGetMessageSessionsAsync(DateTime)Obtient 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 publiqueGetType (hérité de Object.)
Méthode protégéeMemberwiseClone (hérité de Object.)
Méthode protégéeOnAbortExécute l'action d'abandon. (remplace ClientEntity..::..OnAbort()()()().)
Méthode protégéeOnBeginAcceptMessageSessionS'exécute lors de l'appel de l'opération BeginAcceptMessageSession.
Méthode protégéeOnBeginAddRuleS'exécute lors de l'appel de l'opération BeginAddRule.
Méthode protégéeOnBeginCloseExécute l'action de début de fermeture. (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, String, ReceiveMode, TimeSpan, AsyncCallback, Object)Exécute l'action de début de création du destinataire.
Méthode protégéeOnBeginGetMessageSessionsS'exécute lors de l'appel de l'opération BeginGetMessageSessions.
Méthode protégéeOnBeginOpen (hérité de ClientEntity.)
Méthode protégéeOnBeginRemoveRuleCommence à supprimer une Rule d'un Subscription via le protocole de client d'exécution.
Méthode protégéeOnBeginRemoveRulesByTagCommence à supprimer une Rule d'un Subscription via le protocole client d'exécution à l'aide d'une balise.
Méthode protégéeOnCloseExécute l'action de fermeture. (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éeOnEndAddRuleMet fin à l'appel asynchrone à OnBeginAddRule.
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éeOnEndGetMessageSessionsExécute l'action de fin d'obtention du message.
Méthode protégéeOnEndOpen (hérité de ClientEntity.)
Méthode protégéeOnEndRemoveRuleMet fin à l'appel asynchrone à OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
Méthode protégéeOnEndRemoveRulesMet fin à l'appel asynchrone à OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
Méthode protégéeOnFaulted (hérité de ClientEntity.)
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é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)Retourne sans supprimer les premiers messages du lot.
Méthode publiquePeekBatch(Int64, Int32)Retourne sans supprimer les premiers messages du lot.
Méthode publiquePeekBatchAsync(Int32)Retourne de manière asynchrone sans supprimer les premiers messages d'un lot.
Méthode publiquePeekBatchAsync(Int64, Int32)Retourne de manière asynchrone sans supprimer les premiers messages d'un lot.
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 après l'opération asynchrone.
Méthode publiqueReceiveBatch(Int32)Reçoit un lot après l'opération asynchrone.
Méthode publiqueReceiveBatch(Int32, TimeSpan)Reçoit un lot après l'opération asynchrone.
Méthode publiqueReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))Reçoit de manière asynchrone un ensemble de messages (pour le traitement par lots).
Méthode publiqueReceiveBatchAsync(Int32)Reçoit de manière asynchrone un ensemble de messages (pour le traitement par lots).
Méthode publiqueReceiveBatchAsync(Int32, TimeSpan)Reçoit de manière asynchrone un ensemble de messages (pour le traitement par lots).
Méthode publiqueRegisterSessionHandler(Type)Inscrit le gestionnaire pour la session cliente.
Méthode publiqueRegisterSessionHandler(Type, SessionHandlerOptions)Inscrit le gestionnaire pour la session cliente.
Méthode publiqueRegisterSessionHandlerAsync(Type)Inscrit le gestionnaire de façon asynchrone pour la session cliente.
Méthode publiqueRegisterSessionHandlerAsync(Type, SessionHandlerOptions)Inscrit le gestionnaire de façon asynchrone pour la session cliente.
Méthode publiqueRegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Inscrit la fabrique de gestionnaires pour la session cliente.
Méthode publiqueRegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)Inscrit la fabrique de gestionnaires pour la session cliente.
Méthode publiqueRegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)Inscrit la fabrique de gestionnaires de façon asynchrone pour la session cliente.
Méthode publiqueRegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)Inscrit la fabrique de gestionnaires de façon asynchrone pour la session cliente.
Méthode publiqueRemoveRuleSupprime la règle décrite par ruleName.
Méthode publiqueRemoveRuleAsyncSupprime de manière asynchrone la règle décrite par ruleName.
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 abstract class is not meant to be inherited, so protected members of this class should be ignored.

// Create subscription client
SubscriptionClient mySubscriptionClient = 
factory.CreateSubscriptionClient(topicName, subscriptionName);

// Create a receiver
MessageReceiver myMessageReceiver = mySubscriptionClient.CreateReceiver(ReceiveMode.PeekLock);

// Receive messages
for (int count = 0; count &lt; MsgCount; count++)
{
    var message = subscriptionClient.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