QueueClient.RegisterSessionHandler Methode

  • Referenz

Definition

Namespace:
Microsoft.Azure.ServiceBus
Assembly:
Microsoft.Azure.ServiceBus.dll
Paket:
Microsoft.Azure.ServiceBus v5.2.0

Überlädt

RegisterSessionHandler(Func<IMessageSession,Message,CancellationToken,Task>, SessionHandlerOptions)

Empfangen Sie fortlaufend Sitzungsnachrichten aus der Warteschlange. Registriert einen Nachrichtenhandler und beginnt einen neuen Thread zum Empfangen von Sitzungsmeldungen. Dieser handler(Func<T1,T2,T3,TResult>) wird jedes Mal erwartet, wenn eine neue Nachricht vom Warteschlangenclient empfangen wird.
RegisterSessionHandler(Func<IMessageSession,Message,CancellationToken,Task>, Func<ExceptionReceivedEventArgs,Task>)

Empfangen Sie fortlaufend Sitzungsnachrichten aus der Warteschlange. Registriert einen Nachrichtenhandler und beginnt einen neuen Thread zum Empfangen von Sitzungsmeldungen. Dieser handler(Func<T1,T2,T3,TResult>) wird jedes Mal erwartet, wenn eine neue Nachricht vom Warteschlangenclient empfangen wird.

RegisterSessionHandler(Func<IMessageSession,Message,CancellationToken,Task>, SessionHandlerOptions)

Quelle:
QueueClient.cs

Empfangen Sie fortlaufend Sitzungsnachrichten aus der Warteschlange. Registriert einen Nachrichtenhandler und beginnt einen neuen Thread zum Empfangen von Sitzungsmeldungen. Dieser handler(Func<T1,T2,T3,TResult>) wird jedes Mal erwartet, wenn eine neue Nachricht vom Warteschlangenclient empfangen wird.

public void RegisterSessionHandler (Func<Microsoft.Azure.ServiceBus.IMessageSession,Microsoft.Azure.ServiceBus.Message,System.Threading.CancellationToken,System.Threading.Tasks.Task> handler, Microsoft.Azure.ServiceBus.SessionHandlerOptions sessionHandlerOptions);
abstract member RegisterSessionHandler : Func<Microsoft.Azure.ServiceBus.IMessageSession, Microsoft.Azure.ServiceBus.Message, System.Threading.CancellationToken, System.Threading.Tasks.Task> * Microsoft.Azure.ServiceBus.SessionHandlerOptions -> unit
override this.RegisterSessionHandler : Func<Microsoft.Azure.ServiceBus.IMessageSession, Microsoft.Azure.ServiceBus.Message, System.Threading.CancellationToken, System.Threading.Tasks.Task> * Microsoft.Azure.ServiceBus.SessionHandlerOptions -> unit
Public Sub RegisterSessionHandler (handler As Func(Of IMessageSession, Message, CancellationToken, Task), sessionHandlerOptions As SessionHandlerOptions)

Parameter

handler
Func<IMessageSession,Message,CancellationToken,Task>

Eine Func<T1,T2,T3,TResult> , die Nachrichten verarbeitet. IMessageSession enthält die Sitzungsinformationen und muss zum Ausführen von Complete/Abandon/Deadletter oder anderen solchen Vorgängen für die Message

sessionHandlerOptions
SessionHandlerOptions

Optionen, die zum Konfigurieren der Einstellungen der Sitzungspumpe verwendet werden.

Implementiert

RegisterSessionHandler(Func<IMessageSession,Message,CancellationToken,Task>, SessionHandlerOptions)

Hinweise

Aktivieren Sie prefetch, um die Empfangsrate zu beschleunigen.

Gilt für:

RegisterSessionHandler(Func<IMessageSession,Message,CancellationToken,Task>, Func<ExceptionReceivedEventArgs,Task>)

Quelle:
QueueClient.cs

Empfangen Sie fortlaufend Sitzungsnachrichten aus der Warteschlange. Registriert einen Nachrichtenhandler und beginnt einen neuen Thread zum Empfangen von Sitzungsmeldungen. Dieser handler(Func<T1,T2,T3,TResult>) wird jedes Mal erwartet, wenn eine neue Nachricht vom Warteschlangenclient empfangen wird.

public void RegisterSessionHandler (Func<Microsoft.Azure.ServiceBus.IMessageSession,Microsoft.Azure.ServiceBus.Message,System.Threading.CancellationToken,System.Threading.Tasks.Task> handler, Func<Microsoft.Azure.ServiceBus.ExceptionReceivedEventArgs,System.Threading.Tasks.Task> exceptionReceivedHandler);
abstract member RegisterSessionHandler : Func<Microsoft.Azure.ServiceBus.IMessageSession, Microsoft.Azure.ServiceBus.Message, System.Threading.CancellationToken, System.Threading.Tasks.Task> * Func<Microsoft.Azure.ServiceBus.ExceptionReceivedEventArgs, System.Threading.Tasks.Task> -> unit
override this.RegisterSessionHandler : Func<Microsoft.Azure.ServiceBus.IMessageSession, Microsoft.Azure.ServiceBus.Message, System.Threading.CancellationToken, System.Threading.Tasks.Task> * Func<Microsoft.Azure.ServiceBus.ExceptionReceivedEventArgs, System.Threading.Tasks.Task> -> unit
Public Sub RegisterSessionHandler (handler As Func(Of IMessageSession, Message, CancellationToken, Task), exceptionReceivedHandler As Func(Of ExceptionReceivedEventArgs, Task))

Parameter

handler
Func<IMessageSession,Message,CancellationToken,Task>

Eine Func<T1,T2,T3,TResult> , die Nachrichten verarbeitet. IMessageSession enthält die Sitzungsinformationen und muss zum Ausführen von Complete/Abandon/Deadletter oder anderen solchen Vorgängen für die Message

exceptionReceivedHandler
Func<ExceptionReceivedEventArgs,Task>

Eine Func<T,TResult> , die während der Ausnahmen aufgerufen wird. ExceptionReceivedEventArgs enthält kontextbezogene Informationen zur Ausnahme.

Implementiert

RegisterSessionHandler(Func<IMessageSession,Message,CancellationToken,Task>, Func<ExceptionReceivedEventArgs,Task>)

Hinweise

Aktivieren Sie prefetch, um die Empfangsrate zu beschleunigen. Verwenden Sie RegisterSessionHandler(Func<IMessageSession,Message,CancellationToken,Task>, SessionHandlerOptions) , um die Einstellungen der Pumpe zu konfigurieren.

Gilt für: