TopicClient クラス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。
public abstract class TopicClient : Microsoft.ServiceBus.Messaging.MessagingEntityClient
type TopicClient = class
inherit MessagingEntityClient
Public MustInherit Class TopicClient
Inherits MessagingEntityClient
- 継承
例
// 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));
}
プロパティ
IsClosed |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
IsSubQueue |
メッセージ レシーバーがサブキューから作成されるかどうかを示す値を取得または設定します。 |
MessagingFactory |
この TopicClient オブジェクトの作成に使用されたメッセージング ファクトリを取得または設定します。 |
Path |
ベース アドレスに対するキュー、トピック、またはサブスクリプションのパスを MessagingFactory 取得します。 (継承元 MessagingEntityClient) |
RetryPolicy |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
ThisLock |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
メソッド
Abort() |
メッセージング エンティティに対して中止機能を実行します。 (継承元 ClientEntity) |
CancelScheduledMessageAsync(Int64) |
スケジュールされたメッセージを取り消します |
Close() |
クリーンアップ メッセージを Service Bus に送信して、エンティティの使用の完了を通知します。 (継承元 ClientEntity) |
CloseAsync() |
クリーンアップ メッセージを Service Bus に非同期的に送信して、エンティティの使用の完了を通知します。 (継承元 ClientEntity) |
Create(String) |
TopicClient の新しいインスタンスを作成します。 |
CreateFromConnectionString(String) |
指定した接続文字列を使用して の TopicClient 新しいインスタンスを作成します。 |
CreateFromConnectionString(String, String) |
指定した接続文字列とトピックへのパスを使用して、 の TopicClient 新しいインスタンスを作成します。 このオーバーロードは、接続文字列で プロパティが使用されていない場合にのみ使用 EntityPath します。 |
CreateWithAzureActiveDirectory(Uri, String, AzureActiveDirectoryTokenProvider+AuthenticationCallback, String, Nullable<TimeSpan>, TransportType) |
認証コールバック を使用して の TopicClient 新しいインスタンスを作成します。 |
CreateWithManagedIdentity(Uri, String, Nullable<TimeSpan>, TransportType) |
Azure マネージド ID 認証を使用して の TopicClient 新しいインスタンスを作成します。 |
Fault() |
内部使用専用です。 このクラスから継承しないでください。 (継承元 ClientEntity) |
FormatTransferDeadLetterPath(String) |
トピックパスとサブスクリプション名を指定すると、トピックの転送トピックの配信不能キューを指す完全なパスを形成するユーティリティ メソッド。 |
OnAbort() |
中止アクションを実行します。 |
OnBeginClose(TimeSpan, AsyncCallback, Object) |
終了開始アクションを実行します。 |
OnBeginCreateSender(TimeSpan, AsyncCallback, Object) |
送信者の作成開始アクションを実行します。 |
OnBeginOpen(TimeSpan, AsyncCallback, Object) |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
OnClose(TimeSpan) |
閉じるアクションを実行します。 |
OnClosed() |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
OnEndClose(IAsyncResult) |
終了終了アクションを実行します。 |
OnEndCreateSender(IAsyncResult) |
end create sender アクションを実行します。 |
OnEndOpen(IAsyncResult) |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
OnFaulted() |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
OnOpen(TimeSpan) |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
OnOpened() |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
Peek() |
現在のキュー/トピックから BrokeredMessage をピークします。 |
Peek(Int64) |
現在のキュー/トピックから BrokeredMessage をピークします。 |
PeekAsync() |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 |
PeekAsync(Int64) |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 |
PeekBatch(Int32) |
現在のキュー/トピックから BrokeredMessage をピークします。 |
PeekBatch(Int64, Int32) |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 |
PeekBatchAsync(Int32) |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 |
PeekBatchAsync(Int64, Int32) |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 |
ScheduleMessageAsync(BrokeredMessage, DateTimeOffset) |
スケジュールされたメッセージを送信する |
Send(BrokeredMessage) |
を使用してメッセージを送信します Microsoft.ServiceBus.Messaging.TopicClient.InternalSender。 |
SendAsync(BrokeredMessage) |
を使用してメッセージを非同期に送信します Microsoft.ServiceBus.Messaging.TopicClient.InternalSender。 |
SendBatch(IEnumerable<BrokeredMessage>) |
ブローカー メッセージのセットを送信します (バッチ処理用)。 |
SendBatchAsync(IEnumerable<BrokeredMessage>) |
一連のブローカー メッセージを非同期的に送信します (バッチ処理用)。 |
ThrowIfClosed() |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
ThrowIfDisposed() |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
ThrowIfDisposedOrImmutable() |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
ThrowIfDisposedOrNotOpen() |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
ThrowIfFaulted() |
ランタイム操作を実行するために にアクセス TopicDescription するために使用されるアンカー クラス。 (継承元 ClientEntity) |
適用対象
こちらもご覧ください
Azure SDK for .NET