Constant STREAM_SUBJECT 

pub const STREAM_SUBJECT: &str = "cellos.events.>";

Subject filter for every CloudEvent. The MVP supervisor publishes to cellos.events.<entity>.<id>.<phase>; the wildcard captures all of them.