Class EnsureAuthenticatedBrokeredMessagingBehavior

A distributed message processing behavior ensuring that the bearer token is transformed to an .

Inheritance
System.Object
Loggable
MessagingBehaviorBase<IBrokeredMessage>
EnsureAuthenticatedBrokeredMessagingBehavior
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Kephas.Messaging.Distributed.Behaviors
Assembly: Kephas.Messaging.dll
Syntax
[MessagingBehavior(MessageTypeMatching.TypeOrHierarchy)]
[ProcessingPriority(Priority.Highest)]
public class EnsureAuthenticatedBrokeredMessagingBehavior : MessagingBehaviorBase<IBrokeredMessage>, ILoggable, IMessagingBehavior<IBrokeredMessage>, IMessagingBehavior

Constructors

| Improve this Doc View Source

EnsureAuthenticatedBrokeredMessagingBehavior(IAuthenticationService)

Initializes a new instance of the EnsureAuthenticatedBrokeredMessagingBehavior class.

Declaration
public EnsureAuthenticatedBrokeredMessagingBehavior(IAuthenticationService authenticationService)
Parameters
Type Name Description
IAuthenticationService authenticationService

The authentication service.

Methods

| Improve this Doc View Source

BeforeProcessAsync(IBrokeredMessage, IMessagingContext, CancellationToken)

Interception called before invoking the handler to process the message.

Declaration
public override Task BeforeProcessAsync(IBrokeredMessage message, IMessagingContext context, CancellationToken token)
Parameters
Type Name Description
IBrokeredMessage message

The message.
IMessagingContext context

The processing context.
System.Threading.CancellationToken token

The cancellation token.
Returns
Type Description
System.Threading.Tasks.Task

A task.
Overrides
Kephas.Messaging.Behaviors.MessagingBehaviorBase<Kephas.Messaging.Distributed.IBrokeredMessage>.BeforeProcessAsync(Kephas.Messaging.Distributed.IBrokeredMessage, Kephas.Messaging.IMessagingContext, System.Threading.CancellationToken)

Implements

Extension Methods