## Acknowledge + Retry Queue Messages `queues.messages.ack(strqueue_id, MessageAckParams**kwargs) -> MessageAckResponse` **post** `/accounts/{account_id}/queues/{queue_id}/messages/ack` Acknowledge + Retry messages from a Queue ### Parameters - `account_id: str` A Resource identifier. - `queue_id: str` A Resource identifier. - `acks: Optional[Iterable[Ack]]` - `lease_id: Optional[str]` An ID that represents an "in-flight" message that has been pulled from a Queue. You must hold on to this ID and use it to acknowledge this message. - `retries: Optional[Iterable[Retry]]` - `delay_seconds: Optional[float]` The number of seconds to delay before making the message available for another attempt. - `lease_id: Optional[str]` An ID that represents an "in-flight" message that has been pulled from a Queue. You must hold on to this ID and use it to acknowledge this message. ### Returns - `class MessageAckResponse: …` - `ack_count: Optional[float]` The number of messages that were succesfully acknowledged. - `retry_count: Optional[float]` The number of messages that were succesfully retried. - `warnings: Optional[List[str]]` ### Example ```python import os from cloudflare import Cloudflare client = Cloudflare( api_token=os.environ.get("CLOUDFLARE_API_TOKEN"), # This is the default and can be omitted ) response = client.queues.messages.ack( queue_id="023e105f4ecef8ad9ca31a8372d0c353", account_id="023e105f4ecef8ad9ca31a8372d0c353", ) print(response.ack_count) ``` #### Response ```json { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "ackCount": 5, "retryCount": 5, "warnings": [ "string" ] }, "success": true } ```