MessageSender Classe

Définition

MessageSender peut être utilisé pour envoyer des messages à des files d’attente ou des rubriques.

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
Héritage
MessageSender
Implémente

Exemples

Créer un messageSender à envoyer à une file d’attente

IMessageSender messageSender = new MessageSender(
    namespaceConnectionString,
    queueName)

Envoyer un message

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

Remarques

Cela utilise le protocole AMQP pour communiquer avec le service.

Constructeurs

MessageSender(ServiceBusConnection, String, RetryPolicy)

Crée un messageSender AMQP sur un objet donné ServiceBusConnection

MessageSender(ServiceBusConnection, String, String, RetryPolicy)

Crée un ViaMessageSender. Cela peut être utilisé pour envoyer des messages à une entité de destination via une autre entité.

MessageSender(ServiceBusConnectionStringBuilder, RetryPolicy)

Crée un messageSender AMQP.

MessageSender(String, String, ITokenProvider, TransportType, RetryPolicy)

Crée un messageSender

MessageSender(String, String, RetryPolicy)

Crée un messageSender AMQP.

Propriétés

ClientId

Obtient l’ID permettant d’identifier ce client. Cela peut être utilisé pour mettre en corrélation les journaux et les exceptions.

(Hérité de ClientEntity)
IsClosedOrClosing

Retourne true si le client est fermé ou fermé.

(Hérité de ClientEntity)
OperationTimeout

Durée après laquelle les opérations individuelles expirent.

OwnsConnection

Retourne true si la connexion est détenue et false si la connexion est partagée.

(Hérité de ClientEntity)
Path

Obtient le chemin d’accès de l’entité de MessageSender. Dans le cas d’un expéditeur via, cela retourne le chemin d’accès de l’entité via.

RegisteredPlugins

Obtient la liste des plug-ins actuellement inscrits pour cet expéditeur.

RetryPolicy

Obtient le RetryPolicy défini sur le client.

(Hérité de ClientEntity)
ServiceBusConnection

Objet de connexion à l’espace de noms service bus.

TransferDestinationPath

Dans le cas d’un expéditeur via, obtient le chemin de destination final des messages ; Null dans le cas contraire.

ViaEntityPath

Dans le cas d’un expéditeur via, le message est envoyé à TransferDestinationPath via ViaEntityPath; null sinon.

Méthodes

CancelScheduledMessageAsync(Int64)

Annule un message qui a été planifié.

CloseAsync()

Ferme le client. Ferme les connexions ouvertes par celui-ci.

(Hérité de ClientEntity)
OnClosingAsync()

Ferme la connexion.

RegisterPlugin(ServiceBusPlugin)

Inscrit un ServiceBusPlugin à utiliser avec cet expéditeur.

ScheduleMessageAsync(Message, DateTimeOffset)

Planifie l’affichage ultérieur d’un message dans Service Bus.

SendAsync(IList<Message>)

Envoie une liste de messages à l’entité comme décrit par Path. Lorsqu’ils sont appelés sur des entités partitionnées, les messages destinés à différentes partitions ne peuvent pas être traités par lot.

SendAsync(Message)

Envoie un message à l’entité comme décrit par Path.

ThrowIfClosed()

Lève une exception OperationCanceledException si l’objet est Closing.

(Hérité de ClientEntity)
UnregisterPlugin(String)

Annule l’inscription d’un ServiceBusPlugin.

S’applique à