QueueClient Classe

Définition

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

public abstract class QueueClient : Microsoft.ServiceBus.Messaging.MessagingEntityClient
type QueueClient = class
    inherit MessagingEntityClient
Public MustInherit Class QueueClient
Inherits MessagingEntityClient
Héritage

Propriétés

IsClosed

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

(Hérité de ClientEntity)
MessagingFactory

Obtient ou définit la fabrique de messagerie.

Mode

Obtient le mode de réception du message lors du traitement du message reçu.

Path

Obtient le chemin d’accès de la file d’attente, de la rubrique ou de l’abonnement par rapport à l’adresse de MessagingFactory base.

(Hérité de MessagingEntityClient)
PrefetchCount

Obtient ou définit le nombre de messages que le récepteur de file d’attente peut demander simultanément.

RetryPolicy

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

(Hérité de ClientEntity)
ThisLock

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

(Hérité de ClientEntity)

Méthodes

Abandon(Guid)

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

Abandon(Guid, IDictionary<String,Object>)

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

AbandonAsync(Guid)

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

AbandonAsync(Guid, IDictionary<String,Object>)

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

Abort()

Exécute la fonctionnalité d’abandon sur l’entité de messagerie.

(Hérité de ClientEntity)
AcceptMessageSession()

Accepte une session de messages qui autorise le regroupement de messages associés à des fins de traitement dans une seule transaction.

AcceptMessageSession(Boolean)

Accepte une session de message qui autorise le regroupement de messages associés à des fins de traitement en une seule ith de transaction, que ce soit en mode exclusif.

AcceptMessageSession(Boolean, TimeSpan)

Accepte une session de message qui autorise le regroupement de messages associés à des fins de traitement en une seule ith de transaction, que ce soit en mode exclusif.

AcceptMessageSession(String)

Accepte une session de message qui autorise le regroupement de messages associés à des fins de traitement dans une seule transaction à l’aide de l’identificateur de session donné.

AcceptMessageSession(String, Boolean)

Accepte une session de messages qui autorise le regroupement de messages associés à des fins de traitement dans une seule transaction avec s’il est en mode exclusif.

AcceptMessageSession(String, Boolean, TimeSpan)

Accepte une session de message qui autorise le regroupement de messages associés à des fins de traitement dans une transaction unique à l’aide de l’identificateur de session donné avec s’il est en mode exclusif.

AcceptMessageSession(String, Guid)

Accepte une session verrouillée non exclusive de message qui autorise le regroupement de messages associés pour traitement dans une transaction unique à l’aide de l’identificateur de session et du jeton de verrouillage de session donnés.

AcceptMessageSession(String, Guid, TimeSpan)

Accepte une session verrouillée non exclusive de message qui autorise le regroupement de messages associés pour traitement dans une transaction unique à l’aide de l’identificateur de session et du jeton de verrouillage de session donnés.

AcceptMessageSession(String, TimeSpan)

Accepte une session de message qui autorise le regroupement de messages associés à des fins de traitement dans une transaction unique à l’aide de l’identificateur de session et du temps d’attente donnés.

AcceptMessageSession(TimeSpan)

Accepte une session de message qui autorise le regroupement de messages associés à des fins de traitement dans une seule transaction à l’aide du temps d’attente du serveur spécifié.

AcceptMessageSessionAsync()

Accepte de façon asynchrone une session de message qui permet le regroupement de messages associés à des fins de traitement dans une seule transaction.

AcceptMessageSessionAsync(Boolean)

Accepte de façon asynchrone une session de message qui autorise le regroupement de messages associés à des fins de traitement dans une seule transaction avec le mode exclusif et le temps d’attente.

AcceptMessageSessionAsync(Boolean, TimeSpan)

Accepte de façon asynchrone une session de message qui autorise le regroupement de messages associés à des fins de traitement dans une seule transaction avec le mode exclusif et le temps d’attente.

AcceptMessageSessionAsync(String)

Accepte de façon asynchrone une session de message qui autorise le regroupement de messages associés à des fins de traitement dans une seule transaction à l’aide de l’identificateur de session donné.

AcceptMessageSessionAsync(String, Boolean)

Accepte une session de message qui autorise le regroupement de messages associés à des fins de traitement dans une transaction unique à l’aide de l’identificateur de session donné avec s’il est en mode exclusif.

AcceptMessageSessionAsync(String, Boolean, TimeSpan)

Accepte une session de message qui autorise le regroupement de messages associés à des fins de traitement dans une transaction unique à l’aide de l’identificateur de session donné avec s’il est en mode exclusif.

AcceptMessageSessionAsync(String, Guid)

Accepte une session verrouillée non exclusive de message qui autorise le regroupement de messages associés pour traitement dans une transaction unique à l’aide de l’identificateur de session et du jeton de verrouillage de session donnés.

AcceptMessageSessionAsync(String, Guid, TimeSpan)

Accepte une session verrouillée non exclusive de message qui autorise le regroupement de messages associés pour traitement dans une transaction unique à l’aide de l’identificateur de session et du jeton de verrouillage de session donnés.

AcceptMessageSessionAsync(String, TimeSpan)

Accepte de manière asynchrone une session de message qui permet le regroupement de messages associés à des fins de traitement dans une transaction unique à l’aide de l’identificateur de session et du temps d’attente donnés.

AcceptMessageSessionAsync(TimeSpan)

Accepte de manière asynchrone une session de messages qui autorise le regroupement de messages associés à des fins de traitement dans une seule transaction à l’aide du temps d’attente du serveur spécifié.

CancelScheduledMessageAsync(Int64)

Annule un message planifié

Close()

Envoie un message de nettoyage à Service Bus pour signaler la fin de l’utilisation d’une entité.

(Hérité de ClientEntity)
CloseAsync()

Envoie un message de nettoyage de façon asynchrone à Service Bus pour signaler la fin de l’utilisation d’une entité.

(Hérité de ClientEntity)
Complete(Guid)

Termine le traitement d’un message.

CompleteAsync(Guid)

Termine de manière asynchrone le traitement d’un message.

CompleteBatch(IEnumerable<Guid>)

Termine le traitement d’un lot de messages.

CompleteBatchAsync(IEnumerable<Guid>)

Termine de manière asynchrone le traitement d’un lot de messages.

Create(String)

Crée une copie de avec le QueueClient chemin spécifié.

Create(String, ReceiveMode)

Crée une copie de avec le QueueClient chemin et le mode spécifiés.

CreateFromConnectionString(String)

Crée une instance d’utilisation de la chaîne de QueueClient connexion spécifiée.

CreateFromConnectionString(String, ReceiveMode)

Crée une instance d’utilisation de la chaîne de QueueClient connexion et du mode de réception spécifiés.

CreateFromConnectionString(String, String)

Crée une copie de à partir d’une chaîne de QueueClient connexion avec le chemin de file d’attente spécifié. Utilisez cette surcharge uniquement lorsque la chaîne de connexion n’utilise pas la EntityPath propriété .

CreateFromConnectionString(String, String, ReceiveMode)

Crée une instance de à partir d’une chaîne de QueueClient connexion avec le chemin et le mode spécifiés. Utilisez cette surcharge uniquement lorsque la chaîne de connexion n’utilise pas la EntityPath propriété .

CreateWithAzureActiveDirectory(Uri, String, AzureActiveDirectoryTokenProvider+AuthenticationCallback, String, ReceiveMode, Nullable<TimeSpan>, TransportType)

Crée une instance de à l’aide du QueueClient contexte d’authentification Azure Active Directory.

CreateWithManagedIdentity(Uri, String, ReceiveMode, Nullable<TimeSpan>, TransportType)

Crée une instance de à l’aide de l’authentification QueueClient Azure Managed Identity.

DeadLetter(Guid)

Déplace le message non remis dans la file d’attente de lettres mortes.

DeadLetter(Guid, IDictionary<String,Object>)

Déplace le message non remis dans la file d’attente de lettres mortes.

DeadLetter(Guid, String, String)

Déplace le message non remis dans la file d’attente de lettres mortes.

DeadLetterAsync(Guid)

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

DeadLetterAsync(Guid, IDictionary<String,Object>)

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

DeadLetterAsync(Guid, String, String)

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

Defer(Guid)

Interrompt le traitement d’un message.

Defer(Guid, IDictionary<String,Object>)

Interrompt le traitement d’un message.

DeferAsync(Guid)

Suspend de façon asynchrone le traitement d’un message.

DeferAsync(Guid, IDictionary<String,Object>)

Suspend de façon asynchrone le traitement d’un message.

Fault()

À usage interne uniquement. N’héritez pas de cette classe.

(Hérité de ClientEntity)
FormatDeadLetterPath(String)

Génère un nom de format à partir du chemin de file d’attente de lettres mortes spécifié.

FormatTransferDeadLetterPath(String)

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

GetMessageSessions()

Obtient les sessions de messages, ce qui vous permet de parcourir les sessions sur les files d’attente. Seules les sessions avec des messages actifs dans la file d’attente sont retournées. Les sessions de la file d’attente de lettres mortes ou les sessions dont l’état SessionState est « actif » et aucun message n’est retourné avec cet appel.

GetMessageSessions(DateTime)

Récupère toutes les sessions de message dont l’état de session a été mis à jour depuis lastUpdatedTime.

GetMessageSessionsAsync()

Obtient de façon asynchrone les sessions de message, ce qui vous permet de parcourir les sessions sur les files d’attente. Seules les sessions avec des messages actifs dans la file d’attente sont retournées. Les sessions de la file d’attente de lettres mortes ou les sessions dont l’état SessionState est « actif » et aucun message n’est retourné avec cet appel.

GetMessageSessionsAsync(DateTime)

Récupère de façon asynchrone toutes les sessions de message dont l’état de session a été mis à jour depuis lastUpdatedTime.

OnAbort()

S’exécute lors de l’appel de l’événement Abort.

OnBeginAcceptMessageSession(String, ReceiveMode, Int32, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object)

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

OnBeginClose(TimeSpan, AsyncCallback, Object)

S’exécute lorsque l’opération Close est appelée.

OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)

Exécute l’action begin create receiver.

OnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)

Exécute l’action begin create receiver.

OnBeginCreateSender(TimeSpan, AsyncCallback, Object)

Exécute l’action commencer à créer l’expéditeur.

OnBeginGetMessageSessions(DateTime, AsyncCallback, Object)

Exécute l’action BeginGetMessageSessions.

OnBeginOpen(TimeSpan, AsyncCallback, Object)

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

(Hérité de ClientEntity)
OnClose(TimeSpan)

S’exécute lors de l’appel de l’action Fermer.

OnClosed()

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

(Hérité de ClientEntity)
OnEndAcceptMessageSession(IAsyncResult)

S’exécute lors de l’appel de l’opération EndAcceptMessageSession.

OnEndClose(IAsyncResult)

Exécute l’action de fin de fermeture.

OnEndCreateReceiver(IAsyncResult)

Exécute l’action de fin de la création du récepteur.

OnEndCreateSender(IAsyncResult)

Exécute l’action de fin de création de l’expéditeur.

OnEndGetMessageSessions(IAsyncResult)

Exécute l’action de fin d’obtention du message.

OnEndOpen(IAsyncResult)

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

(Hérité de ClientEntity)
OnFaulted()

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

(Hérité de ClientEntity)
OnMessage(Action<BrokeredMessage>)

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

OnMessage(Action<BrokeredMessage>, OnMessageOptions)

Traite un message dans une pompe de messages pilotée par les événements, avec l’ensemble d’options OnMessageOptions donné.

OnMessageAsync(Func<BrokeredMessage,Task>)

Traite un message de manière asynchrone.

OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions)

Traite un message de manière asynchrone.

OnOpen(TimeSpan)

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

(Hérité de ClientEntity)
OnOpened()

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

(Hérité de ClientEntity)
Peek()

Retourne sans supprimer le premier message de la file d’attente.

Peek(Int64)

Retourne sans supprimer le premier message de la file d’attente.

PeekAsync()

Retourne de manière asynchrone sans supprimer le premier message de la file d’attente.

PeekAsync(Int64)

Retourne de manière asynchrone sans supprimer le premier message de la file d’attente.

PeekBatch(Int32)

Affiche un lot de messages.

PeekBatch(Int64, Int32)

Affiche un lot de messages.

PeekBatchAsync(Int32)

Affiche un aperçu asynchrone d’un lot de messages.

PeekBatchAsync(Int64, Int32)

Affiche un aperçu asynchrone d’un lot de messages.

Receive()

Reçoit un message à l’aide de Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver.

Receive(Int64)

Reçoit un message différé à l’aide de Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver. Cette méthode fonctionne uniquement pour les messages différés, et non pour les messages réguliers.

Receive(TimeSpan)

Reçoit un message à l’aide de Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver.

ReceiveAsync()

Reçoit de manière asynchrone un message à l’aide de Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver.

ReceiveAsync(Int64)

Reçoit de manière asynchrone un message différé à l’aide de Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver. Cette méthode fonctionne uniquement pour les messages différés, et non pour les messages normaux.

ReceiveAsync(TimeSpan)

Reçoit de manière asynchrone un message à l’aide de Microsoft.ServiceBus.Messaging.QueueClient.InternalReceiver.

ReceiveBatch(IEnumerable<Int64>)

Reçoit un lot de messages.

ReceiveBatch(Int32)

Reçoit un lot de messages.

ReceiveBatch(Int32, TimeSpan)

Reçoit un lot de messages.

ReceiveBatchAsync(IEnumerable<Int64>)

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

ReceiveBatchAsync(Int32)

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

ReceiveBatchAsync(Int32, TimeSpan)

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

RegisterSessionHandler(Type)

Inscrit le gestionnaire de session avec un type spécifique.

RegisterSessionHandler(Type, SessionHandlerOptions)

Inscrit le gestionnaire de session avec des options de type et de gestionnaire spécifiques.

RegisterSessionHandlerAsync(Type)

Inscrit de manière asynchrone le gestionnaire de session avec un type spécifique.

RegisterSessionHandlerAsync(Type, SessionHandlerOptions)

Inscrit de manière asynchrone le gestionnaire de session avec des options de type et de gestionnaire spécifiques.

RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)

Inscrit une fabrique de gestionnaires de session de messages avec les options spécifiées.

RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)

Inscrit une fabrique de gestionnaires de session de messages avec les options spécifiées.

RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)

Inscrit de manière asynchrone une fabrique de gestionnaire de session de messages.

RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)

Inscrit de manière asynchrone une fabrique de gestionnaire de session de messages.

RenewMessageLock(Guid)

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

RenewMessageLockAsync(Guid)

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

ScheduleMessageAsync(BrokeredMessage, DateTimeOffset)

Envoie un message planifié

Send(BrokeredMessage)

Envoie un message à l’aide de Microsoft.ServiceBus.Messaging.QueueClient.InternalSender.

SendAsync(BrokeredMessage)

Envoie de manière asynchrone un message à l’aide de Microsoft.ServiceBus.Messaging.QueueClient.InternalSender.

SendBatch(IEnumerable<BrokeredMessage>)

Envoie un ensemble de messages réparti (pour le traitement par lots).

SendBatchAsync(IEnumerable<BrokeredMessage>)

Envoie de manière asynchrone un ensemble de messages répartités (pour le traitement par lots).

ThrowIfClosed()

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

(Hérité de ClientEntity)
ThrowIfDisposed()

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

(Hérité de ClientEntity)
ThrowIfDisposedOrImmutable()

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

(Hérité de ClientEntity)
ThrowIfDisposedOrNotOpen()

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

(Hérité de ClientEntity)
ThrowIfFaulted()

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

(Hérité de ClientEntity)

S’applique à