次の方法で共有


TopicClient クラス

定義

ランタイム操作を実行するために にアクセス 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)

適用対象

こちらもご覧ください