Partager via


TopicClient Classe

Définition

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

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

Exemples

// Create settings for the MessagingFactory (for rutime operations)
MessagingFactorySettings factorySettings = new MessagingFactorySettings()
{
   NetMessagingTransportSettings = new NetMessagingTransportSettings(),
   Credential = TransportClientCredentialBase.CreateSharedSecretCredential(IssuerName, IssuerKey),
};

// Create the MessagingFactory
MessagingFactory factory = 
MessagingFactory.Create(myServiceBusNamespace, factorySettings);

//********************************************************************************
//                          Sending messages to a Topic
//********************************************************************************

// Create topic client
TopicClient myTopicClient = factory.CreateTopicClient(myTopic);

// Create a sender
//MessageSender myMessageSender = myTopicClient.CreateSender(SendMode.Default);

// Send messages
List <object> Issues = new List <object>();
foreach (var issue in Issues)
{
   myMessageSender.Send(new BrokeredMessage(issue));
}

Propriétés

IsClosed

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)
IsSubQueue

Obtient ou définit une valeur qui indique si le récepteur de messages est créé à partir d’une sous-file d’attente.

MessagingFactory

Obtient ou définit la fabrique de messagerie utilisée pour créer cet TopicClient objet.

Path

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

(Hérité de MessagingEntityClient)
RetryPolicy

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)
ThisLock

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)

Méthodes

Abort()

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

(Hérité de ClientEntity)
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 manière asynchrone à Service Bus pour signaler la fin de l’utilisation d’une entité.

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

Crée une instance de TopicClient.

CreateFromConnectionString(String)

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

CreateFromConnectionString(String, String)

Crée une nouvelle instance d’utilisation de la chaîne de TopicClient connexion et du chemin d’accès à la rubrique 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, Nullable<TimeSpan>, TransportType)

Crée un instance du à l’aide du TopicClient rappel d’authentification .

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

Crée un instance de à l’aide de l’authentification TopicClient Azure Managed Identity.

Fault()

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

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

Méthode utilitaire qui, compte tenu du chemin d’accès de la rubrique et du nom de l’abonnement, forme un chemin d’accès complet qui pointe vers la file d’attente de lettres mortes de la rubrique de transfert de la rubrique.

OnAbort()

Exécute l’action d’abandon.

OnBeginClose(TimeSpan, AsyncCallback, Object)

Exécute l’action de début de fermeture.

OnBeginCreateSender(TimeSpan, AsyncCallback, Object)

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

OnBeginOpen(TimeSpan, AsyncCallback, Object)

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

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

Exécute l’action de fermeture.

OnClosed()

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

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

Exécute l’action de fermeture de fin.

OnEndCreateSender(IAsyncResult)

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

OnEndOpen(IAsyncResult)

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)
OnFaulted()

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

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

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)
OnOpened()

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)
Peek()

Affiche un brokeredMessage à partir de la file d’attente/de la rubrique actuelle.

Peek(Int64)

Affiche un brokeredMessage à partir de la file d’attente/de la rubrique actuelle.

PeekAsync()

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

PeekAsync(Int64)

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

PeekBatch(Int32)

Affiche un brokeredMessage à partir de la file d’attente/de la rubrique actuelle.

PeekBatch(Int64, Int32)

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

PeekBatchAsync(Int32)

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

PeekBatchAsync(Int64, Int32)

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

ScheduleMessageAsync(BrokeredMessage, DateTimeOffset)

Envoie un message planifié

Send(BrokeredMessage)

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

SendAsync(BrokeredMessage)

Envoie de manière asynchrone un message à l’aide de Microsoft.ServiceBus.Messaging.TopicClient.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()

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)
ThrowIfDisposed()

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)
ThrowIfDisposedOrImmutable()

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)
ThrowIfDisposedOrNotOpen()

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)
ThrowIfFaulted()

Classe d’ancre utilisée pour accéder à un TopicDescription pour effectuer des opérations d’exécution.

(Hérité de ClientEntity)

S’applique à

Voir aussi