namespacepubsub=::google::cloud::pubsub;namespacepubsub_admin=::google::cloud::pubsub_admin;[](pubsub_admin::SubscriptionAdminClientclient,std::stringconst&project_id,std::stringconst&topic_id,std::stringconst&subscription_id,std::stringconst&endpoint){google::pubsub::v1::Subscriptionrequest;request.set_name(pubsub::Subscription(project_id,subscription_id).FullName());request.set_topic(pubsub::Topic(project_id,topic_id).FullName());request.mutable_push_config()->set_push_endpoint(endpoint);autosub=client.CreateSubscription(request);if(sub.status().code()==google::cloud::StatusCode::kAlreadyExists){std::cout <<"The subscription already exists\n";return;}if(!sub)throwstd::move(sub).status();std::cout <<"The subscription was successfully created: "            <<sub->DebugString() <<"\n";

usingGoogle.Cloud.PubSub.V1;publicclassCreatePushSubscriptionSample{publicSubscriptionCreatePushSubscription(stringprojectId,stringtopicId,stringsubscriptionId,stringpushEndpoint){SubscriberServiceApiClientsubscriber=SubscriberServiceApiClient.Create();TopicNametopicName=TopicName.FromProjectTopic(projectId,topicId);SubscriptionNamesubscriptionName=SubscriptionName.FromProjectSubscription(projectId,subscriptionId);PushConfigpushConfig=newPushConfig{PushEndpoint=pushEndpoint};// The approximate amount of time in seconds (on a best-effort basis) Pub/Sub waits for the// subscriber to acknowledge receipt before resending the message.varackDeadlineSeconds=60;varsubscription=subscriber.CreateSubscription(subscriptionName,topicName,pushConfig,ackDeadlineSeconds);returnsubscription;}}

import("context""fmt""io""cloud.google.com/go/pubsub/v2""cloud.google.com/go/pubsub/v2/apiv1/pubsubpb")funccreateWithEndpoint(wio.Writer,projectID,topic,subscription,endpointstring)error{// projectID := "my-project-id"// topic := "projects/my-project-id/topics/my-topic"// subscription := "projects/my-project/subscriptions/my-sub"// endpoint := "https://my-test-project.appspot.com/push"ctx:=context.Background()client,err:=pubsub.NewClient(ctx,projectID)iferr!=nil{returnfmt.Errorf("pubsub.NewClient: %w",err)}deferclient.Close()sub,err:=client.SubscriptionAdminClient.CreateSubscription(ctx,&pubsubpb.Subscription{Name:subscription,Topic:topic,AckDeadlineSeconds:10,PushConfig:&pubsubpb.PushConfig{PushEndpoint:endpoint},})iferr!=nil{returnfmt.Errorf("failed to create push sub: %w",err)}fmt.Fprintf(w,"Created push subscription: %v\n",sub)returnnil}

importcom.google.cloud.pubsub.v1.SubscriptionAdminClient;importcom.google.pubsub.v1.PushConfig;importcom.google.pubsub.v1.Subscription;importcom.google.pubsub.v1.SubscriptionName;importcom.google.pubsub.v1.TopicName;importjava.io.IOException;publicclassCreatePushSubscriptionExample{publicstaticvoidmain(String...args)throwsException{// TODO(developer): Replace these variables before running the sample.StringprojectId="your-project-id";StringsubscriptionId="your-subscription-id";StringtopicId="your-topic-id";StringpushEndpoint="https://my-test-project.appspot.com/push";createPushSubscriptionExample(projectId,subscriptionId,topicId,pushEndpoint);}publicstaticvoidcreatePushSubscriptionExample(StringprojectId,StringsubscriptionId,StringtopicId,StringpushEndpoint)throwsIOException{try(SubscriptionAdminClientsubscriptionAdminClient=SubscriptionAdminClient.create()){TopicNametopicName=TopicName.of(projectId,topicId);SubscriptionNamesubscriptionName=SubscriptionName.of(projectId,subscriptionId);PushConfigpushConfig=PushConfig.newBuilder().setPushEndpoint(pushEndpoint).build();// Create a push subscription with default acknowledgement deadline of 10 seconds.// Messages not successfully acknowledged within 10 seconds will get resent by the server.Subscriptionsubscription=subscriptionAdminClient.createSubscription(subscriptionName,topicName,pushConfig,10);System.out.println("Created push subscription: "+subscription.getName());}}}

/** * TODO(developer): Uncomment these variables before running the sample. */// const pushEndpoint = 'YOUR_ENDPOINT_URL';// const topicNameOrId = 'YOUR_TOPIC_NAME_OR_ID';// const subscriptionNameOrId = 'YOUR_SUBSCRIPTION_NAME_OR_ID';// Imports the Google Cloud client libraryconst{PubSub}=require('@google-cloud/pubsub');// Creates a client; cache this for further useconstpubSubClient=newPubSub();asyncfunctioncreatePushSubscription(pushEndpoint,topicNameOrId,subscriptionNameOrId,){constoptions={pushConfig:{// Set to an HTTPS endpoint of your choice. If necessary, register// (authorize) the domain on which the server is hosted.pushEndpoint,},};awaitpubSubClient.topic(topicNameOrId).createSubscription(subscriptionNameOrId,options);console.log(`Subscription${subscriptionNameOrId}created.`);}

/***TODO(developer):Uncommentthesevariablesbeforerunningthesample.*///constpushEndpoint='YOUR_ENDPOINT_URL';//consttopicNameOrId='YOUR_TOPIC_NAME_OR_ID';//constsubscriptionNameOrId='YOUR_SUBSCRIPTION_NAME_OR_ID';//ImportstheGoogleCloudclientlibraryimport{PubSub,CreateSubscriptionOptions}from'@google-cloud/pubsub';//Createsaclient;cachethisforfurtheruseconstpubSubClient=newPubSub();asyncfunctioncreatePushSubscription(pushEndpoint:string,topicNameOrId:string,subscriptionNameOrId:string,){constoptions:CreateSubscriptionOptions={pushConfig:{//SettoanHTTPSendpointofyourchoice.Ifnecessary,register//(authorize)thedomainonwhichtheserverishosted.pushEndpoint,},};awaitpubSubClient.topic(topicNameOrId).createSubscription(subscriptionNameOrId,options);console.log(`Subscription${subscriptionNameOrId}created.`);}

use Google\Cloud\PubSub\PubSubClient;/** * Creates a Pub/Sub push subscription. * * @param string $projectId  The Google project ID. * @param string $topicName  The Pub/Sub topic name. * @param string $subscriptionName  The Pub/Sub subscription name. * @param string $endpoint  The endpoint for the push subscription. */function create_push_subscription($projectId, $topicName, $subscriptionName, $endpoint){    $pubsub = new PubSubClient([        'projectId' => $projectId,    ]);    $topic = $pubsub->topic($topicName);    $subscription = $topic->subscription($subscriptionName);    $subscription->create([        'pushConfig' => ['pushEndpoint' => $endpoint]    ]);    printf('Subscription created: %s' . PHP_EOL, $subscription->name());}

fromgoogle.cloudimportpubsub_v1# TODO(developer)# project_id = "your-project-id"# topic_id = "your-topic-id"# subscription_id = "your-subscription-id"# endpoint = "https://my-test-project.appspot.com/push"publisher=pubsub_v1.PublisherClient()subscriber=pubsub_v1.SubscriberClient()topic_path=publisher.topic_path(project_id,topic_id)subscription_path=subscriber.subscription_path(project_id,subscription_id)push_config=pubsub_v1.types.PushConfig(push_endpoint=endpoint)# Wrap the subscriber in a 'with' block to automatically call close() to# close the underlying gRPC channel when done.withsubscriber:subscription=subscriber.create_subscription(request={"name":subscription_path,"topic":topic_path,"push_config":push_config,})print(f"Push subscription created:{subscription}.")print(f"Endpoint for subscription is:{endpoint}")

# topic_id          = "your-topic-id"# subscription_id   = "your-subscription-id"# endpoint          = "https://your-test-project.appspot.com/push"pubsub=Google::Cloud::PubSub.newsubscription_admin=pubsub.subscription_adminsubscription=subscription_admin.create_subscription\name:pubsub.subscription_path(subscription_id),topic:pubsub.topic_path(topic_id),push_config:{push_endpoint:endpoint}puts"Push subscription#{subscription_id} created."