---
title: Messages
---

[Skip to content](#_top)

[API Reference](https://developers.cloudflare.com/api/go)

[Queues](https://developers.cloudflare.com/api/go/resources/queues)

Copy Markdown

Open in **Claude**Open in **ChatGPT**Open in **Cursor**

---

**Copy Markdown****View as Markdown**

# Messages

##### [Push Message](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/push)

client.Queues.Messages.Push(ctx, queueID, params) (\*[MessagePushResponse](<https://developers.cloudflare.com/api/go/resources/queues#(resource)%20queues.messages%20%3E%20(model)%20MessagePushResponse%20%3E%20(schema)>), error)

POST/accounts/{account\_id}/queues/{queue\_id}/messages

##### [Acknowledge + Retry Queue Messages](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/ack)

client.Queues.Messages.Ack(ctx, queueID, params) (\*[MessageAckResponse](<https://developers.cloudflare.com/api/go/resources/queues#(resource)%20queues.messages%20%3E%20(model)%20MessageAckResponse%20%3E%20(schema)>), error)

POST/accounts/{account\_id}/queues/{queue\_id}/messages/ack

##### [Pull Queue Messages](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/pull)

client.Queues.Messages.Pull(ctx, queueID, params) (\*[MessagePullResponse](<https://developers.cloudflare.com/api/go/resources/queues#(resource)%20queues.messages%20%3E%20(model)%20MessagePullResponse%20%3E%20(schema)>), error)

POST/accounts/{account\_id}/queues/{queue\_id}/messages/pull

##### [Push Message Batch](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/bulk_push)

client.Queues.Messages.BulkPush(ctx, queueID, params) (\*[MessageBulkPushResponse](<https://developers.cloudflare.com/api/go/resources/queues#(resource)%20queues.messages%20%3E%20(model)%20MessageBulkPushResponse%20%3E%20(schema)>), error)

POST/accounts/{account\_id}/queues/{queue\_id}/messages/batch

##### [Peek Queue Messages](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/peek)

client.Queues.Messages.Peek(ctx, queueID, params) (\*[MessagePeekResponse](<https://developers.cloudflare.com/api/go/resources/queues#(resource)%20queues.messages%20%3E%20(model)%20MessagePeekResponse%20%3E%20(schema)>), error)

POST/accounts/{account\_id}/queues/{queue\_id}/messages/peek

##### [Purge Peeked Queue Messages](https://developers.cloudflare.com/api/go/resources/queues/subresources/messages/methods/purge)

client.Queues.Messages.Purge(ctx, queueID, params) (\*[MessagePurgeResponse](<https://developers.cloudflare.com/api/go/resources/queues#(resource)%20queues.messages%20%3E%20(model)%20MessagePurgeResponse%20%3E%20(schema)>), error)

POST/accounts/{account\_id}/queues/{queue\_id}/messages/purge