Skip to content
English

DistributedPubSubOptionsBuilder

Defined in: src/cluster/pubsub/DistributedPubSubOptions.ts:43

Fluent builder for DistributedPubSubOptionsType. The mediator is normally spawned by the DistributedPubSub extension, which injects the cluster and forwards the operator’s tuning choices.

new DistributedPubSubOptionsBuilder(): DistributedPubSubOptionsBuilder

DistributedPubSubOptionsBuilder

OptionsBuilder.constructor

build(): Partial<T>

Defined in: src/util/OptionsBuilder.ts:51

Snapshot the set fields as an independent Partial<T> (own props only).

Partial<T>

OptionsBuilder.build


withCluster(cluster): this

Defined in: src/cluster/pubsub/DistributedPubSubOptions.ts:50

The cluster this mediator lives in — drives membership + gossip peers.

Cluster

this


withGossipIntervalMs(ms): this

Defined in: src/cluster/pubsub/DistributedPubSubOptions.ts:55

Gossip interval in ms between anti-entropy pushes. Default gossip interval.

number

this


withMaxRemoteNodesPerTopic(maxRemoteNodesPerTopic): this

Defined in: src/cluster/pubsub/DistributedPubSubOptions.ts:70

Cap on the remote nodes that may claim subscribers for one topic.

number

this


withMaxSubscribersPerTopic(maxSubscribersPerTopic): this

Defined in: src/cluster/pubsub/DistributedPubSubOptions.ts:60

Cap on the local subscribers a single topic may hold.

number

this


withMaxTopics(maxTopics): this

Defined in: src/cluster/pubsub/DistributedPubSubOptions.ts:65

Cap on the distinct topics this mediator tracks.

number

this


withSendToDeadLettersWhenNoSubscribers(sendToDeadLettersWhenNoSubscribers): this

Defined in: src/cluster/pubsub/DistributedPubSubOptions.ts:75

Send a publish that reached no subscriber to system.deadLetters.

boolean

this


static create(): DistributedPubSubOptionsBuilder

Defined in: src/cluster/pubsub/DistributedPubSubOptions.ts:45

Start a fresh builder.

DistributedPubSubOptionsBuilder