MessageSender Clase

Referencia

Definición

Espacio de nombres:: Microsoft.Azure.ServiceBus.Core

Ensamblado:: Microsoft.Azure.ServiceBus.dll

Paquete:: Microsoft.Azure.ServiceBus v5.2.0

Source:: MessageSender.cs

Importante

Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.

MessageSender se puede usar para enviar mensajes a colas o temas.

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

Herencia: Object

ClientEntity
MessageSender

Implementaciones: IMessageSender ISenderClient IClientEntity

Ejemplos

Creación de un nuevo messageSender para enviar a una cola

IMessageSender messageSender = new MessageSender(
    namespaceConnectionString,
    queueName)

Enviar mensaje

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

Comentarios

Esto usa el protocolo AMQP para comunicarse con el servicio.

Constructores

MessageSender(ServiceBusConnection, String, RetryPolicy)	Crea un nuevo messageSender de AMQP en un determinado ServiceBusConnection
MessageSender(ServiceBusConnection, String, String, RetryPolicy)	Crea un viaMessageSender. Se puede usar para enviar mensajes a una entidad de destino a través de otra entidad.
MessageSender(ServiceBusConnectionStringBuilder, RetryPolicy)	Crea un nuevo messageSender de AMQP.
MessageSender(String, String, ITokenProvider, TransportType, RetryPolicy)	Crea un nuevo messageSender
MessageSender(String, String, RetryPolicy)	Crea un nuevo messageSender de AMQP.

Propiedades

ClientId	Obtiene el identificador para identificar este cliente. Se puede usar para correlacionar registros y excepciones. (Heredado de ClientEntity)
IsClosedOrClosing	Devuelve true si el cliente está cerrado o cerrado. (Heredado de ClientEntity)
OperationTimeout	Duración después de la cual se expirarán las operaciones individuales.
OwnsConnection	Devuelve true si la conexión es propiedad y false si se comparte la conexión. (Heredado de ClientEntity)
Path	Obtiene la ruta de acceso de entidad de MessageSender. En el caso de un via-sender, devuelve la ruta de acceso de la entidad via.
RegisteredPlugins	Obtiene una lista de complementos registrados actualmente para este remitente.
RetryPolicy	Obtiene el RetryPolicy definido en el cliente. (Heredado de ClientEntity)
ServiceBusConnection	Objeto de conexión al espacio de nombres de Service Bus.
TransferDestinationPath	En el caso de un via-sender, obtiene la ruta de acceso de destino final de los mensajes; Null en caso contrario.
ViaEntityPath	En el caso de un via-sender, el mensaje se envía a TransferDestinationPath a través ViaEntityPathde ; en caso contrario, null.

Métodos

CancelScheduledMessageAsync(Int64)	Cancela un mensaje programado.
CloseAsync()	Cierra el cliente. Cierra las conexiones abiertas por ella. (Heredado de ClientEntity)
OnClosingAsync()	Cierra la conexión.
RegisterPlugin(ServiceBusPlugin)	Registra un ServiceBusPlugin objeto que se va a usar con este remitente.
ScheduleMessageAsync(Message, DateTimeOffset)	Programa un mensaje para que aparezca en Service Bus más adelante.
SendAsync(IList<Message>)	Envía una lista de mensajes a la entidad tal y como se describe en Path. Cuando se llama a en entidades con particiones, los mensajes destinados a distintas particiones no se pueden procesar por lotes juntos.
SendAsync(Message)	Envía un mensaje a la entidad como se describe en Path.
ThrowIfClosed()	Inicie una operationCanceledException si el objeto es Closing. (Heredado de ClientEntity)
UnregisterPlugin(String)	Anula el registro de un ServiceBusPluginobjeto .

Se aplica a

Compartir a través de