Client SDKsPythonReference
Queues
Durable queues, polling, and streaming — KubeMQ Python SDK reference.
Send messages with send_queue_message, receive them through receive_queue_messages, and extend flows with streaming helpers (see SDK examples for stream send/receive patterns).
Simple Queues
send_queue_message
await client.send_queue_message(message: QueueMessage) -> QueueSendResultQueueMessage fields:
| Field | Type | Required | Description |
|---|---|---|---|
channel | str | Yes | Queue channel |
body | bytes | Conditional | Payload |
metadata | str | Conditional | Metadata |
tags | dict[str, str] | No | Routing tags |
delay_in_seconds | int | No | Initial delay |
expiration_in_seconds | int | No | TTL |
max_receive_count | int | No | Retry budget |
max_receive_queue | str | No | DLQ channel |
receive_queue_messages
await client.receive_queue_messages(
channel: str,
max_messages: int,
wait_timeout_seconds: int,
auto_ack: bool = False,
) -> QueuesPollResponsePolls for messages with optional visibility and auto-ack semantics.
Queue Streaming
Streaming queue APIs (send/receive streams, ack ranges, nack/requeue) follow the same semantics as other SDKs but are exposed through Python-specific helpers. Refer to the Queues examples for the exact async methods available in your SDK version.
Quick Usage
msg = QueueMessage(channel="jobs", body=b"task")
await client.send_queue_message(msg)See Also
Was this page helpful?