你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

TopicClient 类

定义

命名空间:

Microsoft.ServiceBus.Messaging

程序集:

Microsoft.ServiceBus.dll

包:

WindowsAzure.ServiceBus v6.2.2

用于访问 TopicDescription 以执行运行时操作的定位点类。

public abstract class TopicClient : Microsoft.ServiceBus.Messaging.MessagingEntityClient

type TopicClient = class
    inherit MessagingEntityClient

Public MustInherit Class TopicClient
Inherits MessagingEntityClient

继承

Object

ClientEntity

MessagingEntityClient

TopicClient

示例

// 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()	向服务总线发送清理消息，以指示实体的使用完成。 (继承自 ClientEntity)
CloseAsync()	以异步方式将清理消息发送到服务总线，以指示实体的使用完成。 (继承自 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 托管标识身份验证创建 的新 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)	执行结束创建发件人操作。
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)

另请参阅

• MessagingFactory