SnapshotSubscription
constructor(context: String, models: Collection<AggregateModel<*>>, store: SnapshotStore, kernel: Kernel, log: EventLog, codec: EventCodec = EventCodec(), views: SharedStates? = null, capacity: Int = SharedStateOptions.DEFAULT_CAPACITY, name: String = Hop.SNAPSHOT_SUBSCRIPTION, answers: (AggregateType) -> Boolean = { true }, active: (AggregateType) -> Boolean = { true }, writeBatch: Int = SnapshotOptions.DEFAULT_WRITE_BATCH, gate: ReplayGate = ReplayGate.OPEN)