--- title: Create Event Subscription --- [Skip to content](#_top) [API Reference](https://developers.cloudflare.com/api/go) [Queues](https://developers.cloudflare.com/api/go/resources/queues) [Subscriptions](https://developers.cloudflare.com/api/go/resources/queues/subresources/subscriptions) Copy Markdown Open in **Claude**Open in **ChatGPT**Open in **Cursor** --- **Copy Markdown****View as Markdown** # Create Event Subscription client.Queues.Subscriptions.New(ctx, params) (\*[SubscriptionNewResponse](), error) POST/accounts/{account\_id}/event\_subscriptions/subscriptions Creates an event subscription for a Queue. ##### Security
API Token The preferred authorization scheme for interacting with the Cloudflare API. Create a token. **Example:**Authorization: Bearer Sn3lZJTBX6kkg7OdcBUAxOO963GEIyGQqnFTOFYY
API Email + API Key The previous authorization scheme for interacting with the Cloudflare API, used in conjunction with a Global API key. **Example:**X-Auth-Email: user@example.com The previous authorization scheme for interacting with the Cloudflare API. When possible, use API tokens instead of Global API keys. **Example:**X-Auth-Key: 144c9defac04969c7bfad8efaa8ea194
##### Accepted Permissions (at least one required) `Queues Write``Workers Scripts Write` ##### ParametersExpand Collapse
params SubscriptionNewParams AccountID param.Field\[string] Path param: A Resource identifier. maxLength32 Link to this property
Destination param.Field\[SubscriptionNewParamsDestination]Optional Body param: Destination configuration for the subscription QueueID string ID of the target queue Link to this property Type SubscriptionNewParamsDestinationType Type of destination Link to this property
Link to this property Enabled param.Field\[bool]Optional Body param: Whether the subscription is active Link to this property Events param.Field\[\[]string]Optional Body param: List of event types this subscription handles Link to this property Name param.Field\[string]Optional Body param: Name of the subscription Link to this property
Source param.Field\[SubscriptionNewParamsSource]Optional Body param: Source configuration for the subscription
type SubscriptionNewParamsSourceMqEventSourceImages struct{…} Type SubscriptionNewParamsSourceMqEventSourceImagesTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewParamsSourceMqEventSourceKV struct{…} Type SubscriptionNewParamsSourceMqEventSourceKVTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewParamsSourceMqEventSourceR2 struct{…} Type SubscriptionNewParamsSourceMqEventSourceR2TypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewParamsSourceMqEventSourceSuperSlurper struct{…} Type SubscriptionNewParamsSourceMqEventSourceSuperSlurperTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewParamsSourceMqEventSourceVectorize struct{…} Type SubscriptionNewParamsSourceMqEventSourceVectorizeTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewParamsSourceMqEventSourceWorkersAIModel struct{…} ModelName stringOptional Name of the Workers AI model Link to this property Type SubscriptionNewParamsSourceMqEventSourceWorkersAIModelTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewParamsSourceMqEventSourceWorkersBuildsWorker struct{…} Type SubscriptionNewParamsSourceMqEventSourceWorkersBuildsWorkerTypeOptional Type of source Link to this property WorkerName stringOptional Name of the worker Link to this property
Link to this property
type SubscriptionNewParamsSourceMqEventSourceWorkersScript struct{…} ScriptTag stringOptional Tag of the Worker script Link to this property Type SubscriptionNewParamsSourceMqEventSourceWorkersScriptTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewParamsSourceMqEventSourceWorkflowsWorkflow struct{…} Type SubscriptionNewParamsSourceMqEventSourceWorkflowsWorkflowTypeOptional Type of source Link to this property WorkflowName stringOptional Name of the workflow Link to this property
Link to this property
Link to this property
[Link to this property](<#(resource)%20queues.subscriptions%20%3E%20(method)%20create%20%3E%20(params)%20default>) ##### ReturnsExpand Collapse
type SubscriptionNewResponse struct{…} ID string Unique identifier for the subscription Link to this property CreatedAt Time When the subscription was created formatdate-time Link to this property
Destination SubscriptionNewResponseDestination Destination configuration for the subscription QueueID string ID of the target queue Link to this property Type SubscriptionNewResponseDestinationType Type of destination Link to this property
Link to this property Enabled bool Whether the subscription is active Link to this property Events \[]string List of event types this subscription handles Link to this property ModifiedAt Time When the subscription was last modified formatdate-time Link to this property Name string Name of the subscription Link to this property
Source SubscriptionNewResponseSource Source configuration for the subscription One of the following:
type SubscriptionNewResponseSourceMqEventSourceImages struct{…} Type SubscriptionNewResponseSourceMqEventSourceImagesTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewResponseSourceMqEventSourceKV struct{…} Type SubscriptionNewResponseSourceMqEventSourceKVTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewResponseSourceMqEventSourceR2 struct{…} Type SubscriptionNewResponseSourceMqEventSourceR2TypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewResponseSourceMqEventSourceSuperSlurper struct{…} Type SubscriptionNewResponseSourceMqEventSourceSuperSlurperTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewResponseSourceMqEventSourceVectorize struct{…} Type SubscriptionNewResponseSourceMqEventSourceVectorizeTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewResponseSourceMqEventSourceWorkersAIModel struct{…} ModelName stringOptional Name of the Workers AI model Link to this property Type SubscriptionNewResponseSourceMqEventSourceWorkersAIModelTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewResponseSourceMqEventSourceWorkersBuildsWorker struct{…} Type SubscriptionNewResponseSourceMqEventSourceWorkersBuildsWorkerTypeOptional Type of source Link to this property WorkerName stringOptional Name of the worker Link to this property
Link to this property
type SubscriptionNewResponseSourceMqEventSourceWorkersScript struct{…} ScriptTag stringOptional Tag of the Worker script Link to this property Type SubscriptionNewResponseSourceMqEventSourceWorkersScriptTypeOptional Type of source Link to this property
Link to this property
type SubscriptionNewResponseSourceMqEventSourceWorkflowsWorkflow struct{…} Type SubscriptionNewResponseSourceMqEventSourceWorkflowsWorkflowTypeOptional Type of source Link to this property WorkflowName stringOptional Name of the workflow Link to this property
Link to this property
Link to this property
[Link to this property](<#(resource)%20queues.subscriptions%20%3E%20(model)%20SubscriptionNewResponse%20%3E%20(schema)>) ### Create Event Subscription Go HTTPTypeScriptPythonGoTerraform ``` 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"), ) subscription, err := client.Queues.Subscriptions.New(context.TODO(), queues.SubscriptionNewParams{ AccountID: cloudflare.F("023e105f4ecef8ad9ca31a8372d0c353"), }) if err != nil { panic(err.Error()) } fmt.Printf("%+v\n", subscription.ID) } ``` 200 example ``` { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "id": "id", "created_at": "2019-12-27T18:11:19.117Z", "destination": { "queue_id": "queue_id", "type": "queues.queue" }, "enabled": true, "events": [ "string" ], "modified_at": "2019-12-27T18:11:19.117Z", "name": "name", "source": { "type": "images" } }, "success": true } ``` ##### Returns Examples 200 example ``` { "errors": [ { "code": 7003, "message": "No route for the URI", "documentation_url": "documentation_url", "source": { "pointer": "pointer" } } ], "messages": [ "string" ], "result": { "id": "id", "created_at": "2019-12-27T18:11:19.117Z", "destination": { "queue_id": "queue_id", "type": "queues.queue" }, "enabled": true, "events": [ "string" ], "modified_at": "2019-12-27T18:11:19.117Z", "name": "name", "source": { "type": "images" } }, "success": true } ```