Skip to content

Commit

Permalink
Upgrade SQS dependencies
Browse files Browse the repository at this point in the history
  • Loading branch information
svix-jplatte committed Feb 16, 2024
1 parent 1616a7d commit 85e9297
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
4 changes: 2 additions & 2 deletions omniqueue/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -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 }
Expand Down
2 changes: 0 additions & 2 deletions omniqueue/src/backends/sqs.rs
Original file line number Diff line number Diff line change
Expand Up @@ -272,7 +272,6 @@ impl QueueConsumer for SqsQueueConsumer {
.map_err(QueueError::generic)?;

out.messages()
.unwrap_or_default()
.iter()
.map(|message| -> Result<Delivery, QueueError> { Ok(self.wrap_message(message)) })
.next()
Expand All @@ -298,7 +297,6 @@ impl QueueConsumer for SqsQueueConsumer {

Ok(out
.messages()
.unwrap_or_default()
.iter()
.map(|message| -> Result<Delivery, QueueError> { Ok(self.wrap_message(message)) })
.collect::<Result<Vec<_>, _>>()?)
Expand Down

0 comments on commit 85e9297

Please sign in to comment.