Crate rabbitmq_stream_protocol