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