handling

open override fun handling(group: String, subscription: String, context: String, stream: EventStreamRecord, trace: Map<String, String>, topic: String?): Observation