MessageSender Klasse
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
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
- Implementiert
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. |
Gilt für:
Azure SDK for .NET