MessageSender Classe

Referência

Definição

Namespace:: Microsoft.Azure.ServiceBus.Core

Assembly:: Microsoft.Azure.ServiceBus.dll

Pacote:: Microsoft.Azure.ServiceBus v5.2.0

Origem:: MessageSender.cs

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

O MessageSender pode ser usado para enviar mensagens para Filas ou Tópicos.

public class MessageSender : Microsoft.Azure.ServiceBus.ClientEntity, Microsoft.Azure.ServiceBus.Core.IMessageSender

type MessageSender = class
    inherit ClientEntity
    interface IMessageSender
    interface ISenderClient
    interface IClientEntity

Public Class MessageSender
Inherits ClientEntity
Implements IMessageSender

Herança: Object

ClientEntity
MessageSender

Implementações: IMessageSender ISenderClient IClientEntity

Exemplos

Criar um novo MessageSender para enviar para uma fila

IMessageSender messageSender = new MessageSender(
    namespaceConnectionString,
    queueName)

Enviar mensagem

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

Comentários

Isso usa o protocolo AMQP para se comunicar com o serviço.

Construtores

MessageSender(ServiceBusConnection, String, RetryPolicy)	Cria um novo MESSAGESender AMQP em um determinado ServiceBusConnection
MessageSender(ServiceBusConnection, String, String, RetryPolicy)	Cria um ViaMessageSender. Isso pode ser usado para enviar mensagens para uma entidade de destino por meio de outra entidade.
MessageSender(ServiceBusConnectionStringBuilder, RetryPolicy)	Cria um novo MESSAGESender AMQP.
MessageSender(String, String, ITokenProvider, TransportType, RetryPolicy)	Cria um novo MessageSender
MessageSender(String, String, RetryPolicy)	Cria um novo MESSAGESender AMQP.

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 caminho da entidade do MessageSender. No caso de um via remetente, isso retorna o caminho do via entidade.
RegisteredPlugins	Obtém uma lista de plug-ins registrados no momento para esse remetente.
RetryPolicy	Obtém o RetryPolicy definido no cliente. (Herdado de ClientEntity)
ServiceBusConnection	Objeto de conexão com o namespace do barramento de serviço.
TransferDestinationPath	No caso de um via remetente, obtém o caminho de destino final das mensagens; nulo caso contrário.
ViaEntityPath	No caso de um via remetente, a mensagem é enviada por TransferDestinationPath meio ViaEntityPathde ; caso contrário, nulo.

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()	Encerra a conexão.
RegisterPlugin(ServiceBusPlugin)	Registra um ServiceBusPlugin a ser usado com esse remetente.
ScheduleMessageAsync(Message, DateTimeOffset)	Agenda uma mensagem para aparecer no Barramento de Serviço posteriormente.
SendAsync(IList<Message>)	Envia uma lista de mensagens para a entidade, conforme descrito por Path. 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 a entidade conforme descrito por Path.
ThrowIfClosed()	Gere uma OperationCanceledException se o objeto estiver fechando. (Herdado de ClientEntity)
UnregisterPlugin(String)	Cancela o registro de um ServiceBusPlugin.

Aplica-se a

Partilhar via