TopicClient Klasse

Definition

Namespace:

Microsoft.Azure.ServiceBus

Assembly:

Microsoft.Azure.ServiceBus.dll

Paket:

Microsoft.Azure.ServiceBus v5.2.0

Quelle:

TopicClient.cs

TopicClient kann für alle grundlegenden Interaktionen mit einem Service Bus-Thema verwendet werden.

public class TopicClient : Microsoft.Azure.ServiceBus.ClientEntity, Microsoft.Azure.ServiceBus.ITopicClient

type TopicClient = class
    inherit ClientEntity
    interface ITopicClient
    interface ISenderClient
    interface IClientEntity

Public Class TopicClient
Inherits ClientEntity
Implements ITopicClient

Vererbung

Object

ClientEntity

TopicClient

Implementiert

ISenderClient IClientEntity ITopicClient

Beispiele

Erstellen eines neuen TopicClient

ITopicClient topicClient = new TopicClient(
    namespaceConnectionString,
    topicName,
    RetryExponential);

Senden Sie eine Nachricht an das Thema:

byte[] data = GetData();
await topicClient.SendAsync(data);

Hinweise

Es verwendet das AMQP-Protokoll für die Kommunikation mit servicebus.

Konstruktoren

TopicClient(ServiceBusConnection, String, RetryPolicy)	Erstellt eine neue instance des Topic-Clients für eine bestimmteServiceBusConnection
TopicClient(ServiceBusConnectionStringBuilder, RetryPolicy)	Instanziiert ein neues TopicClient , um Vorgänge zu einem Thema auszuführen.
TopicClient(String, String, ITokenProvider, TransportType, RetryPolicy)	Erstellt eine neue instance des Topic-Clients unter Verwendung des angegebenen Endpunkts, Entitätspfads und Tokenanbieters.
TopicClient(String, String, RetryPolicy)	Instanziiert ein neues TopicClient , um Vorgänge zu einem Thema auszuführen.

Eigenschaften

ClientId	Ruft die ID ab, um diesen Client zu identifizieren. Dies kann verwendet werden, um Protokolle und Ausnahmen zu korrelieren. (Geerbt von ClientEntity)
IsClosedOrClosing	Gibt true zurück, wenn der Client geschlossen oder geschlossen ist. (Geerbt von ClientEntity)
OperationTimeout	Dauer, nach der für einzelne Vorgänge ein Timeout auftritt.
OwnsConnection	Gibt true zurück, wenn die Verbindung im Besitz ist, und false, wenn die Verbindung freigegeben wird. (Geerbt von ClientEntity)
Path	Ruft den Namen des Themas ab.
RegisteredPlugins	Ruft eine Liste der aktuell registrierten Plugins für diesen TopicClient ab.
RetryPolicy	Ruft die RetryPolicy auf dem Client definierte ab. (Geerbt von ClientEntity)
ServiceBusConnection	Verbindungsobjekt mit dem Service Bus-Namespace.
TopicName	Ruft den Namen des Themas ab.

Methoden

CancelScheduledMessageAsync(Int64)	Bricht eine geplante Nachricht ab.
CloseAsync()	Schließt den Client. Schließt die von ihr geöffneten Verbindungen. (Geerbt von ClientEntity)
OnClosingAsync()	TopicClient kann für alle grundlegenden Interaktionen mit einem Service Bus-Thema verwendet werden.
RegisterPlugin(ServiceBusPlugin)	Registriert einen ServiceBusPlugin , der mit diesem Themenclient verwendet werden soll.
ScheduleMessageAsync(Message, DateTimeOffset)	Plant, dass eine Nachricht zu einem späteren Zeitpunkt in Service Bus angezeigt wird.
SendAsync(IList<Message>)	Sendet eine Liste von Nachrichten an Service Bus. Wenn für partitionierte Entitäten aufgerufen wird, können Nachrichten, die für verschiedene Partitionen bestimmt sind, nicht im Batch zusammengefasst werden.
SendAsync(Message)	Sendet eine Nachricht an Service Bus.
ThrowIfClosed()	Lösen Sie eine OperationCanceledException aus, wenn das Objekt Geschlossen ist. (Geerbt von ClientEntity)
UnregisterPlugin(String)	Hebt die Registrierung eines auf ServiceBusPlugin.