TopicClient クラス

定義

名前空間:

Microsoft.Azure.ServiceBus

アセンブリ:

Microsoft.Azure.ServiceBus.dll

パッケージ:

Microsoft.Azure.ServiceBus v5.2.0

ソース:

TopicClient.cs

TopicClient は、Service Bus トピックとのすべての基本的な操作に使用できます。

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

継承

Object

ClientEntity

TopicClient

実装

ISenderClient IClientEntity ITopicClient

例

新しい TopicClient を作成する

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

トピックにメッセージを送信します。

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

注釈

サービスバスとの通信には AMQP プロトコルが使用されます。

コンストラクター

TopicClient(ServiceBusConnection, String, RetryPolicy)	特定の にトピック クライアントの新しいインスタンスを作成します。 ServiceBusConnection
TopicClient(ServiceBusConnectionStringBuilder, RetryPolicy)	新しい を TopicClient インスタンス化して、トピックに対する操作を実行します。
TopicClient(String, String, ITokenProvider, TransportType, RetryPolicy)	指定したエンドポイント、エンティティ パス、トークン プロバイダーを使用して、Topic クライアントの新しいインスタンスを作成します。
TopicClient(String, String, RetryPolicy)	新しい を TopicClient インスタンス化して、トピックに対する操作を実行します。

プロパティ

ClientId	このクライアントを識別する ID を取得します。 これは、ログと例外を関連付けるために使用できます。 (継承元 ClientEntity)
IsClosedOrClosing	クライアントが閉じているか閉じている場合は true を返します。 (継承元 ClientEntity)
OperationTimeout	個々の操作がタイムアウトする期間。
OwnsConnection	接続が所有されている場合は true、接続が共有されている場合は false を返します。 (継承元 ClientEntity)
Path	トピックの名前を取得します。
RegisteredPlugins	この TopicClient の現在登録されているプラグインの一覧を取得します。
RetryPolicy	クライアントで定義されている RetryPolicy を取得します。 (継承元 ClientEntity)
ServiceBusConnection	Service Bus 名前空間への接続オブジェクト。
TopicName	トピックの名前を取得します。

メソッド

CancelScheduledMessageAsync(Int64)	スケジュールされたメッセージを取り消します。
CloseAsync()	クライアントを閉じます。 その接続によって開かれた接続を閉じます。 (継承元 ClientEntity)
OnClosingAsync()	TopicClient は、Service Bus トピックとのすべての基本的な操作に使用できます。
RegisterPlugin(ServiceBusPlugin)	ServiceBusPluginこのトピック クライアントで使用する を登録します。
ScheduleMessageAsync(Message, DateTimeOffset)	後で Service Bus にメッセージを表示するようにスケジュールします。
SendAsync(IList<Message>)	メッセージの一覧を Service Bus に送信します。 パーティション分割されたエンティティで呼び出されると、異なるパーティション用のメッセージを一緒にバッチ処理することはできません。
SendAsync(Message)	Service Bus にメッセージを送信します。
ThrowIfClosed()	オブジェクトが Closing の場合は、OperationCanceledException をスローします。 (継承元 ClientEntity)
UnregisterPlugin(String)	の登録を ServiceBusPlugin解除します。