Function dataflow::source::s3::release_messages [−][src]
async fn release_messages(
client: &SqsClient,
message: Option<SqsMessage>,
messages: impl Iterator<Item = SqsMessage>,
queue_url: String,
source_id: &str,
failed_key: Option<String>
)
Expand description
Set the SQS visibility timeout back to zero, allowing the messages to be sent to other clients