connector-azure-queue-storage/com.river.connector.azure.queue.storage

Package-level declarations

Functions

Link copied to clipboard
suspend fun QueueMessageItem.delete()

Delete the message from the Azure Storage Queue.

Link copied to clipboard
fun QueueAsyncClient.deleteMessagesFlow(upstream: Flow<QueueMessageItem>, concurrency: Int = 100): Flow<Unit>

Deletes messages from an Azure Storage Queue using an upstream flow of QueueMessageItem objects.

Link copied to clipboard
fun QueueAsyncClient.receiveMessagesAsFlow(    concurrency: ConcurrencyStrategy = ConcurrencyStrategy.disabled,     pollSize: Int = 32,     visibilityTimeout: Duration = 30.seconds,     stopOnEmptyList: Boolean = false): Flow<QueueMessageItem>

Continuously receives messages from an Azure Storage Queue using the provided QueueAsyncClient. The received messages are returned as a Flow of QueueMessageItem objects.

Link copied to clipboard
fun QueueAsyncClient.sendMessagesFlow(upstream: Flow<SendMessageRequest>, concurrency: Int = 100): Flow<SendMessageResult>

Sends messages to an Azure Storage Queue using an upstream flow of SendMessageRequest objects.