Struct SqsAdapter 

pub struct SqsAdapter { /* private fields */ }

Implementations

impl SqsAdapter

pub async fn new(config: SqsConfig) -> Result<Self>

pub async fn publish( &self, topic: impl Into<String>, payload: Value, ) -> Result<()>

pub async fn subscribe<H>( &self, topic: impl Into<String>, handler: Arc<H>, ) -> Result<()>

where H: MessageHandler + 'static,

pub async fn subscribe_fn<F, Fut>( &self, topic: impl Into<String>, handler: F, ) -> Result<()>

where F: Fn(Message) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

pub async fn list_topics(&self) -> Vec<String>