Queues Examples
Guaranteed delivery with simple and streaming queue APIs for the KubeMQ Kotlin SDK.
Guaranteed delivery with simple and streaming queue API examples.
Send & Receive
Basic queue message send and receive with ack/reject
Ack All
Acknowledge all messages in a batch
Ack & Reject
Selectively acknowledge or reject messages
Batch Send
Send multiple messages in a single batch
Dead Letter Queue
Route failed messages to a dead letter queue
Delayed Messages
Send messages with delivery delay
Peek Messages
Non-destructive read of queue messages
Stream Send
Send messages via streaming transport
Stream Receive
Receive messages via streaming transport
Auto Ack
Automatic acknowledgement on delivery
Ack Range
Acknowledge a range of messages at once
Nack All
Reject all messages for redelivery
Requeue All
Move all messages to a different queue
Poll Mode
Pull-based message consumption
Dead Letter Policy
Configure dead letter queue routing policy
Delay Policy
Configure message delivery delay policy
Expiration Policy
Configure message TTL expiration
Was this page helpful?