wow-core/me.ahoo.wow.messaging/MessageSubscription

MessageSubscription

data class MessageSubscription(val namedAggregates: Set<NamedAggregate>, val receiverGroup: String = DEFAULT_RECEIVER_GROUP)

Describes a message bus subscription.

Constructors

MessageSubscription

constructor(namedAggregates: Set<NamedAggregate>, receiverGroup: String = DEFAULT_RECEIVER_GROUP)

constructor(namedAggregate: NamedAggregate, receiverGroup: String = DEFAULT_RECEIVER_GROUP)

Types

object Companion

Properties

namedAggregates

val namedAggregates: Set<NamedAggregate>

Aggregates whose messages should be received.

val receiverGroup: String

Logical receiver group used by distributed buses for consumer coordination.