## Push Message Batch `client.Queues.Messages.BulkPush(ctx, queueID, params) (*MessageBulkPushResponse, error)` **post** `/accounts/{account_id}/queues/{queue_id}/messages/batch` Push a batch of message to a Queue ### Parameters - `queueID string` A Resource identifier. - `params MessageBulkPushParams` - `AccountID param.Field[string]` Path param: A Resource identifier. - `DelaySeconds param.Field[float64]` Body param: The number of seconds to wait for attempting to deliver this batch to consumers - `Messages param.Field[[]MessageBulkPushParamsMessage]` Body param - `type MessageBulkPushParamsMessagesMqQueueMessageText struct{…}` - `Body string` - `ContentType MessageBulkPushParamsMessagesMqQueueMessageTextContentType` - `const MessageBulkPushParamsMessagesMqQueueMessageTextContentTypeText MessageBulkPushParamsMessagesMqQueueMessageTextContentType = "text"` - `DelaySeconds float64` The number of seconds to wait for attempting to deliver this message to consumers - `type MessageBulkPushParamsMessagesMqQueueMessageJson struct{…}` - `Body unknown` - `ContentType MessageBulkPushParamsMessagesMqQueueMessageJsonContentType` - `const MessageBulkPushParamsMessagesMqQueueMessageJsonContentTypeJson MessageBulkPushParamsMessagesMqQueueMessageJsonContentType = "json"` - `DelaySeconds float64` The number of seconds to wait for attempting to deliver this message to consumers ### Returns - `type MessageBulkPushResponse struct{…}` - `Metadata MessageBulkPushResponseMetadata` - `Metrics MessageBulkPushResponseMetadataMetrics` Best-effort metrics for the queue. Values may be approximate due to the distributed nature of queues. - `BacklogBytes float64` The size in bytes of unacknowledged messages in the queue. - `BacklogCount float64` The number of unacknowledged messages in the queue. - `OldestMessageTimestampMs float64` Unix timestamp in milliseconds of the oldest unacknowledged message in the queue. Returns 0 if unknown. ### Example ```go package main import ( "context" "fmt" "github.com/cloudflare/cloudflare-go" "github.com/cloudflare/cloudflare-go/option" "github.com/cloudflare/cloudflare-go/queues" ) func main() { client := cloudflare.NewClient( option.WithAPIToken("Sn3lZJTBX6kkg7OdcBUAxOO963GEIyGQqnFTOFYY"), ) response, err := client.Queues.Messages.BulkPush( context.TODO(), "023e105f4ecef8ad9ca31a8372d0c353", queues.MessageBulkPushParams{ AccountID: cloudflare.F("023e105f4ecef8ad9ca31a8372d0c353"), }, ) if err != nil { panic(err.Error()) } fmt.Printf("%+v\n", response.Metadata) } ``` #### Response ```json { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "metadata": { "metrics": { "backlog_bytes": 1024, "backlog_count": 5, "oldest_message_timestamp_ms": 1710950954154 } } }, "success": true } ```