MessageSubscription
data class MessageSubscription(val namedAggregates: Set<NamedAggregate>, val receiverGroup: String = DEFAULT_RECEIVER_GROUP, val runtimeOwned: Boolean = false)
Describes a message bus subscription.
Constructors
Link copied to clipboard
constructor(namedAggregates: Set<NamedAggregate>, receiverGroup: String = DEFAULT_RECEIVER_GROUP, runtimeOwned: Boolean = false)
constructor(namedAggregate: NamedAggregate, receiverGroup: String = DEFAULT_RECEIVER_GROUP, runtimeOwned: Boolean = false)
Properties
Link copied to clipboard
Aggregates whose messages should be received.
Link copied to clipboard
Logical receiver group used by distributed buses for consumer coordination.
Link copied to clipboard
The subscriber is a me.ahoo.wow.runtime.WowRuntime dispatcher: it opens processing only once the runtime is ready and confirms or rejects every local delivery it is handed (confirmLocalDelivery, rejectLocalDelivery). A local bus routes local-first deliveries only through such receivers; any other subscriber just observes the messages. Built-in dispatchers set it; a custom consumer leaves it false unless it implements the same protocol.