Table of Contents

Struct MessageBrokerFilterExpressionContext

Namespace
LfrlAnvil.MessageBroker.Server
Assembly
LfrlAnvil.MessageBroker.Server.dll

Represents a context for a single message filter predicate applied by a MessageBrokerChannelListenerBinding.

public readonly struct MessageBrokerFilterExpressionContext
Inherited Members

Properties

Data

Binary message data.

public MessageBrokerFilterExpressionContext.Span Data { get; }

Property Value

MessageBrokerFilterExpressionContext.Span

Listener

MessageBrokerChannelListenerBinding that filters the message.

public MessageBrokerChannelListenerBinding Listener { get; }

Property Value

MessageBrokerChannelListenerBinding

MessageId

Unique message id.

public ulong MessageId { get; }

Property Value

ulong

Publisher

IMessageBrokerMessagePublisher that pushed the message.

public IMessageBrokerMessagePublisher Publisher { get; }

Property Value

IMessageBrokerMessagePublisher

PushedAt

Moment of registration of this message in the MessageBrokerStream.

public Timestamp PushedAt { get; }

Property Value

Timestamp

Methods

AsMemory()

Converts binary message data to ReadOnlyMemory<T>.

[Pure]
public ReadOnlyMemory<byte> AsMemory()

Returns

ReadOnlyMemory<byte>

New ReadOnlyMemory<T> instance.

AsSpan()

Converts binary message data to ReadOnlySpan<T>.

[Pure]
public ReadOnlySpan<byte> AsSpan()

Returns

ReadOnlySpan<byte>

New ReadOnlySpan<T> instance.