TopicClient Classe

Definição

Namespace:

Microsoft.Azure.ServiceBus

Assembly:

Microsoft.Azure.ServiceBus.dll

Pacote:

Microsoft.Azure.ServiceBus v5.2.0

Origem:

TopicClient.cs

TopicClient pode ser usado para todas as interações básicas com um tópico do Barramento de Serviço.

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

Herança

Object

ClientEntity

TopicClient

Implementações

ISenderClient IClientEntity ITopicClient

Exemplos

Criar um novo TopicClient

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

Envie uma mensagem para o tópico:

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

Comentários

Ele usa o protocolo AMQP para se comunicar com o servicebus.

Construtores

TopicClient(ServiceBusConnection, String, RetryPolicy)	Cria uma nova instância do cliente Tópico em um determinado ServiceBusConnection
TopicClient(ServiceBusConnectionStringBuilder, RetryPolicy)	Cria uma instância de um novo TopicClient para executar operações em um tópico.
TopicClient(String, String, ITokenProvider, TransportType, RetryPolicy)	Cria uma nova instância do cliente Topic usando o ponto de extremidade, o caminho da entidade e o provedor de token especificados.
TopicClient(String, String, RetryPolicy)	Cria uma instância de um novo TopicClient para executar operações em um tópico.

Propriedades

ClientId	Obtém a ID para identificar esse cliente. Isso pode ser usado para correlacionar logs e exceções. (Herdado de ClientEntity)
IsClosedOrClosing	Retornará true se o cliente estiver fechado ou fechado. (Herdado de ClientEntity)
OperationTimeout	Duração após a qual as operações individuais atingirão o tempo limite.
OwnsConnection	Retornará true se a conexão for de propriedade e false se a conexão for compartilhada. (Herdado de ClientEntity)
Path	Obtém o nome do tópico.
RegisteredPlugins	Obtém uma lista de plug-ins registrados no momento para este TopicClient.
RetryPolicy	Obtém o RetryPolicy definido no cliente. (Herdado de ClientEntity)
ServiceBusConnection	Objeto de conexão com o namespace do barramento de serviço.
TopicName	Obtém o nome do tópico.

Métodos

CancelScheduledMessageAsync(Int64)	Cancela uma mensagem que foi agendada.
CloseAsync()	Fecha o Cliente. Fecha as conexões abertas por ela. (Herdado de ClientEntity)
OnClosingAsync()	TopicClient pode ser usado para todas as interações básicas com um tópico do Barramento de Serviço.
RegisterPlugin(ServiceBusPlugin)	Registra um ServiceBusPlugin a ser usado com este cliente de tópico.
ScheduleMessageAsync(Message, DateTimeOffset)	Agenda uma mensagem para aparecer no Barramento de Serviço posteriormente.
SendAsync(IList<Message>)	Envia uma lista de mensagens para o Barramento de Serviço. Quando chamado em entidades particionadas, as mensagens destinadas a partições diferentes não podem ser agrupadas em lote.
SendAsync(Message)	Envia uma mensagem para o Barramento de Serviço.
ThrowIfClosed()	Gere uma OperationCanceledException se o objeto estiver fechando. (Herdado de ClientEntity)
UnregisterPlugin(String)	Cancela o registro de um ServiceBusPlugin.