PartitionedRouter

constructor(groups: Collection<PartitionOwnership>, channel: ClusterChannel, options: ClusterOptions = ClusterOptions(), observer: Observer = Observer.NONE, clock: Clock = Clock.systemUTC())