diff --git a/omniqueue/Cargo.toml b/omniqueue/Cargo.toml index 387f6ea..e3751fa 100644 --- a/omniqueue/Cargo.toml +++ b/omniqueue/Cargo.toml @@ -11,8 +11,8 @@ edition = "2021" [dependencies] async-trait = "0.1" -aws-config = { version = "0.55", optional = true } -aws-sdk-sqs = { version = "0.25", optional = true } +aws-config = { version = "1.1.5", features = ["behavior-version-latest"], optional = true } +aws-sdk-sqs = { version = "1.13.0", optional = true } bb8 = { version = "0.8", optional = true } bb8-redis = { version = "0.13", optional = true } futures-util = { version = "0.3.28", default-features = false, features = ["async-await", "std"], optional = true } diff --git a/omniqueue/src/backends/sqs.rs b/omniqueue/src/backends/sqs.rs index 5970807..cd916a8 100644 --- a/omniqueue/src/backends/sqs.rs +++ b/omniqueue/src/backends/sqs.rs @@ -272,7 +272,6 @@ impl QueueConsumer for SqsQueueConsumer { .map_err(QueueError::generic)?; out.messages() - .unwrap_or_default() .iter() .map(|message| -> Result { Ok(self.wrap_message(message)) }) .next() @@ -298,7 +297,6 @@ impl QueueConsumer for SqsQueueConsumer { Ok(out .messages() - .unwrap_or_default() .iter() .map(|message| -> Result { Ok(self.wrap_message(message)) }) .collect::, _>>()?)