Complete REST API reference for OKMQ queues, streams, messages, and topics.
| Method | Path | Summary |
|---|---|---|
GET | /account | Get account information |
GET | /queues | List all queues |
POST | /queues | Create a queue |
DELETE | /queues/{queue} | Delete a queue |
GET | /queues/{queue} | Get queue details |
PATCH | /queues/{queue} | Update queue settings |
POST | /queues/{queue}/ack | Acknowledge or nack messages |
DELETE | /queues/{queue}/messages | Delete messages from queue |
GET | /queues/{queue}/messages | Read messages from queue |
POST | /queues/{queue}/messages | Enqueue messages |
DELETE | /queues/{queue}/messages/{id} | Delete a specific message |
GET | /queues/{queue}/messages/{id} | Get a specific message |
POST | /queues/{queue}/resetfailed | Reset failed messages |
GET | /queues/{queue}/stats | Get queue statistics |
GET | /streams | List all streams |
POST | /streams | Create a stream |
DELETE | /streams/{stream} | Delete a stream |
GET | /streams/{stream} | Get stream details |
PATCH | /streams/{stream} | Update stream settings |
POST | /streams/{stream}/commit | Commit stream offset |
DELETE | /streams/{stream}/messages | Delete messages from stream |
GET | /streams/{stream}/messages | Consume messages from stream |
POST | /streams/{stream}/messages | Produce messages to stream |
POST | /topics/{topic}/messages | Publish messages to topic |