MessageSender Klasse

Definition

Namespace:

Microsoft.Azure.ServiceBus.Core

Assembly:

Microsoft.Azure.ServiceBus.dll

Paket:

Microsoft.Azure.ServiceBus v5.2.0

Quelle:

MessageSender.cs

Der MessageSender kann verwendet werden, um Nachrichten an Warteschlangen oder Themen zu senden.

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

Vererbung

Object

ClientEntity

MessageSender

Implementiert

IMessageSender ISenderClient IClientEntity

Beispiele

Erstellen eines neuen MessageSender zum Senden an eine Warteschlange

IMessageSender messageSender = new MessageSender(
    namespaceConnectionString,
    queueName)

Nachricht senden

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

Hinweise

Dabei wird das AMQP-Protokoll für die Kommunikation mit dem Dienst verwendet.

Konstruktoren

MessageSender(ServiceBusConnection, String, RetryPolicy)	Erstellt einen neuen AMQP MessageSender für einen bestimmten ServiceBusConnection
MessageSender(ServiceBusConnection, String, String, RetryPolicy)	Erstellt einen ViaMessageSender. Dies kann verwendet werden, um Nachrichten über eine andere Entität an eine Zielentität zu senden.
MessageSender(ServiceBusConnectionStringBuilder, RetryPolicy)	Erstellt einen neuen AMQP MessageSender.
MessageSender(String, String, ITokenProvider, TransportType, RetryPolicy)	Erstellt einen neuen MessageSender.
MessageSender(String, String, RetryPolicy)	Erstellt einen neuen AMQP MessageSender.

Eigenschaften

ClientId	Ruft die ID ab, um diesen Client zu identifizieren. Dies kann verwendet werden, um Protokolle und Ausnahmen zu korrelieren. (Geerbt von ClientEntity)
IsClosedOrClosing	Gibt true zurück, wenn der Client geschlossen oder geschlossen wird. (Geerbt von ClientEntity)
OperationTimeout	Dauer, nach der für einzelne Vorgänge ein Timeout auftritt.
OwnsConnection	Gibt true zurück, wenn die Verbindung im Besitz ist, und false, wenn die Verbindung freigegeben ist. (Geerbt von ClientEntity)
Path	Ruft den Entitätspfad des MessageSender ab. Im Fall eines via-Senders gibt dies den Pfad der via-Entität zurück.
RegisteredPlugins	Ruft eine Liste der aktuell registrierten Plug-Ins für diesen Absender ab.
RetryPolicy	Ruft die RetryPolicy auf dem Client definierte ab. (Geerbt von ClientEntity)
ServiceBusConnection	Verbindungsobjekt mit dem Service Bus-Namespace.
TransferDestinationPath	Ruft im Fall eines Via-Senders den endgültigen Zielpfad der Nachrichten ab; andernfalls null.
ViaEntityPath	Im Fall eines Übersenders wird die Nachricht über TransferDestinationPathViaEntityPathgesendet, andernfalls NULL.

Methoden

CancelScheduledMessageAsync(Int64)	Bricht eine geplante Nachricht ab.
CloseAsync()	Schließt den Client. Schließt die von ihr geöffneten Verbindungen. (Geerbt von ClientEntity)
OnClosingAsync()	Schließen der Verbindung.
RegisterPlugin(ServiceBusPlugin)	Registriert eine ServiceBusPlugin , die mit diesem Absender verwendet werden soll.
ScheduleMessageAsync(Message, DateTimeOffset)	Plant, dass eine Nachricht zu einem späteren Zeitpunkt in Service Bus angezeigt wird.
SendAsync(IList<Message>)	Sendet eine Liste von Nachrichten an die Entität, wie von Pathbeschrieben. Wenn sie für partitionierte Entitäten aufgerufen werden, können Nachrichten, die für verschiedene Partitionen bestimmt sind, nicht in einem Batch zusammengefasst werden.
SendAsync(Message)	Sendet eine Nachricht an die Entität, wie von Pathbeschrieben.
ThrowIfClosed()	Löst eine OperationCanceledException aus, wenn das Objekt Closing ist. (Geerbt von ClientEntity)
UnregisterPlugin(String)	Hebt die Registrierung eines auf ServiceBusPlugin.