Dequeue reads from the queue. It reads into buf until buf is full or another criteria is fulfilled.
(ctx context.Context, q Handle, buf []Message, opts DequeueOpts)
| 98 | // Dequeue reads from the queue. |
| 99 | // It reads into buf until buf is full or another criteria is fulfilled. |
| 100 | Dequeue(ctx context.Context, q Handle, buf []Message, opts DequeueOpts) (int, error) |
| 101 | // Insert adds the messages to the end of the queue. |
| 102 | Enqueue(ctx context.Context, q Handle, msgs []Message) (*InsertResp, error) |
| 103 | } |