TopicClient Klasse

Definition

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

public abstract class TopicClient : Microsoft.ServiceBus.Messaging.MessagingEntityClient
type TopicClient = class
    inherit MessagingEntityClient
Public MustInherit Class TopicClient
Inherits MessagingEntityClient
Vererbung

Beispiele

// Create settings for the MessagingFactory (for rutime operations)
MessagingFactorySettings factorySettings = new MessagingFactorySettings()
{
   NetMessagingTransportSettings = new NetMessagingTransportSettings(),
   Credential = TransportClientCredentialBase.CreateSharedSecretCredential(IssuerName, IssuerKey),
};

// Create the MessagingFactory
MessagingFactory factory = 
MessagingFactory.Create(myServiceBusNamespace, factorySettings);

//********************************************************************************
//                          Sending messages to a Topic
//********************************************************************************

// Create topic client
TopicClient myTopicClient = factory.CreateTopicClient(myTopic);

// Create a sender
//MessageSender myMessageSender = myTopicClient.CreateSender(SendMode.Default);

// Send messages
List <object> Issues = new List <object>();
foreach (var issue in Issues)
{
   myMessageSender.Send(new BrokeredMessage(issue));
}

Eigenschaften

IsClosed

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
IsSubQueue

Ruft einen Wert ab, der angibt, ob der Nachrichtenempfänger aus einer Unterwarteschlange erstellt wird, oder legt diesen fest.

MessagingFactory

Ruft die Messagingfactory ab, die beim Erstellen dieses Objekts verwendet wurde, oder legt sie TopicClient fest.

Path

Ruft den Pfad der Warteschlange, des Themas oder des Abonnements relativ zur MessagingFactory Basisadresse ab.

(Geerbt von MessagingEntityClient)
RetryPolicy

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
ThisLock

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)

Methoden

Abort()

Führt abbruchfunktionen für die Messagingentität aus.

(Geerbt von ClientEntity)
CancelScheduledMessageAsync(Int64)

Bricht eine geplante Nachricht ab.

Close()

Sendet eine Bereinigungsnachricht an Service Bus, um den Abschluss der Verwendung einer Entität zu signalisieren.

(Geerbt von ClientEntity)
CloseAsync()

Sendet eine Bereinigungsnachricht asynchron an Service Bus, um den Abschluss der Verwendung einer Entität zu signalisieren.

(Geerbt von ClientEntity)
Create(String)

Erstellt eine neue Instanz von TopicClient.

CreateFromConnectionString(String)

Erstellt eine neue instance der TopicClient Verwendung der angegebenen Verbindungszeichenfolge.

CreateFromConnectionString(String, String)

Erstellt eine neue instance der TopicClient Verwendung der angegebenen Verbindungszeichenfolge und des Pfads zum Thema. Verwenden Sie diese Überladung nur, wenn die Verbindungszeichenfolge die EntityPath -Eigenschaft nicht verwendet.

CreateWithAzureActiveDirectory(Uri, String, AzureActiveDirectoryTokenProvider+AuthenticationCallback, String, Nullable<TimeSpan>, TransportType)

Erstellt mithilfe des Authentifizierungsrückrufs eine neue instance von TopicClient .

CreateWithManagedIdentity(Uri, String, Nullable<TimeSpan>, TransportType)

Erstellt eine neue instance von mithilfe der TopicClient Azure Managed Identity-Authentifizierung.

Fault()

Nur zur internen Verwendung. Verhindern Sie das Erben von dieser Klasse.

(Geerbt von ClientEntity)
FormatTransferDeadLetterPath(String)

Eine Hilfsprogrammmethode, die anhand des Themenpfads und des Abonnementnamens einen vollständigen Pfad bildet, der auf die Warteschlange für unzustellbare Nachrichten des Themas zum Übertragen des Themas verweist.

OnAbort()

Führt die Abbruchaktion aus.

OnBeginClose(TimeSpan, AsyncCallback, Object)

Führt die Aktion "Schließen beginnen" aus.

OnBeginCreateSender(TimeSpan, AsyncCallback, Object)

Führt die Aktion Start create sender aus.

OnBeginOpen(TimeSpan, AsyncCallback, Object)

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
OnClose(TimeSpan)

Führt die Schließen-Aktion aus.

OnClosed()

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
OnEndClose(IAsyncResult)

Führt die Aktion zum Beenden des Schließens aus.

OnEndCreateSender(IAsyncResult)

Führt die End create sender-Aktion aus.

OnEndOpen(IAsyncResult)

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
OnFaulted()

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
OnOpen(TimeSpan)

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
OnOpened()

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
Peek()

Einsehen einer BrokeredMessage aus der aktuellen Warteschlange/dem aktuellen Thema.

Peek(Int64)

Einsehen einer BrokeredMessage aus der aktuellen Warteschlange/dem aktuellen Thema.

PeekAsync()

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

PeekAsync(Int64)

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

PeekBatch(Int32)

Einsehen einer BrokeredMessage aus der aktuellen Warteschlange/dem aktuellen Thema.

PeekBatch(Int64, Int32)

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

PeekBatchAsync(Int32)

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

PeekBatchAsync(Int64, Int32)

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

ScheduleMessageAsync(BrokeredMessage, DateTimeOffset)

Sendet eine geplante Nachricht.

Send(BrokeredMessage)

Sendet eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.TopicClient.InternalSender.

SendAsync(BrokeredMessage)

Sendet asynchron eine Nachricht mithilfe von Microsoft.ServiceBus.Messaging.TopicClient.InternalSender.

SendBatch(IEnumerable<BrokeredMessage>)

Sendet eine Reihe von Brokernachrichten (für die Batchverarbeitung).

SendBatchAsync(IEnumerable<BrokeredMessage>)

Sendet asynchron einen Satz von Brokernachrichten (für die Batchverarbeitung).

ThrowIfClosed()

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
ThrowIfDisposed()

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
ThrowIfDisposedOrImmutable()

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
ThrowIfDisposedOrNotOpen()

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)
ThrowIfFaulted()

Eine Ankerklasse, die für den Zugriff auf ein TopicDescription verwendet wird, um Laufzeitvorgänge auszuführen.

(Geerbt von ClientEntity)

Gilt für:

Weitere Informationen