Struct QueueWrapper 

pub struct QueueWrapper { /* private fields */ }

Implementations

impl QueueWrapper

pub fn new(provider: MqProvider) -> Self

pub async fn publish(&self, topic: &str, message: &[u8]) -> Result<(), MqError>

pub async fn consume(&self, topic: &str) -> Result<Option<Message>, MqError>

pub async fn ack(&self, message_id: &str) -> Result<(), MqError>

pub async fn subscribe(&self, topic: &str) -> Result<(), MqError>