TenantPublishFilter<TKey> class

Namespace: Tenantry.Pro.MassTransit.Filters · Package: Tenantry.Pro.MassTransit · API reference

MassTransit pipeline filter that adds the current tenant ID as a message header when a message is published.

Wire this filter into the bus configuration via cfg.UseTenantryPro<TKey>(ctx).

public sealed class TenantPublishFilter<TKey> : IFilter<PublishContext>, IProbeSite where TKey : IEquatable<TKey>, IParsable<TKey>

Type parametersCopy Anchor Link

• TKey: The tenant identifier type.

Implements IFilter<PublishContext>, IProbeSite.

ConstructorsCopy Anchor Link

TenantPublishFilter(ITenantContext<TKey>)Copy Anchor Link

MassTransit pipeline filter that adds the current tenant ID as a message header when a message is published.

public TenantPublishFilter(ITenantContext<TKey> tenantContext)

Parameters:

• tenantContext ITenantContext<TKey>: Supplies the current tenant, written to each published message's headers.

Wire this filter into the bus configuration via cfg.UseTenantryPro<TKey>(ctx).

FieldsCopy Anchor Link

HeaderKeyCopy Anchor Link

The MassTransit message header key used to carry the tenant identifier.

public const string HeaderKey = "tenantry-tenant-id"

Returns: string

MethodsCopy Anchor Link

Probe(ProbeContext)Copy Anchor Link

Adds this filter to MassTransit's diagnostic probe, which describes the publish pipeline.

public void Probe(ProbeContext context)

Parameters:

• context ProbeContext: The probe context to add to.

Send(PublishContext, IPipe<PublishContext>)Copy Anchor Link

Sends a context to a filter, such that it can be processed and then passed to the specified output pipe for further processing.

public Task Send(PublishContext context, IPipe<PublishContext> next)

Parameters:

• context PublishContext: The pipe context type
• next IPipe<PublishContext>: The next pipe in the pipeline

Returns: Task: An awaitable Task