pub trait FormatSpecificDecode { // Required method fn decode(&self, bytes: Bytes) -> Result<AnyMessage, AnyError>; }