namespacepubsub_admin=::google::cloud::pubsub_admin;namespacepubsub=::google::cloud::pubsub;[](pubsub_admin::SubscriptionAdminClientclient,std::stringconst&project_id,std::stringconst&subscription_id,std::stringconst&endpoint){google::pubsub::v1::ModifyPushConfigRequestrequest;request.set_subscription(pubsub::Subscription(project_id,subscription_id).FullName());request.mutable_push_config()->set_push_endpoint(endpoint);autostatus=client.ModifyPushConfig(request);if(!status.ok())throwstd::runtime_error(status.message());std::cout <<"The subscription push configuration was successfully"            <<" modified\n";}

usingGoogle.Cloud.PubSub.V1;publicclassUpdatePushConfigurationSample{publicvoidUpdatePushConfiguration(stringprojectId,stringsubscriptionId,stringpushEndpoint){SubscriberServiceApiClientsubscriber=SubscriberServiceApiClient.Create();SubscriptionNamesubscriptionName=SubscriptionName.FromProjectSubscription(projectId,subscriptionId);PushConfigpushConfig=newPushConfig{PushEndpoint=pushEndpoint};subscriber.ModifyPushConfig(subscriptionName,pushConfig);}}

import("context""fmt""io""cloud.google.com/go/pubsub/v2""cloud.google.com/go/pubsub/v2/apiv1/pubsubpb""google.golang.org/protobuf/types/known/fieldmaskpb")funcupdateEndpoint(wio.Writer,projectID,subscriptionName,endpointstring)error{// projectID := "my-project-id"// subscriptionName := "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()req:=&pubsubpb.UpdateSubscriptionRequest{Subscription:&pubsubpb.Subscription{Name:subscriptionName,PushConfig:&pubsubpb.PushConfig{PushEndpoint:endpoint,},},UpdateMask:&fieldmaskpb.FieldMask{Paths:[]string{"push_config"},},}subConfig,err:=client.SubscriptionAdminClient.UpdateSubscription(ctx,req)iferr!=nil{returnfmt.Errorf("Update: %w",err)}fmt.Fprintf(w,"Updated subscription config: %v\n",subConfig)returnnil}

importcom.google.cloud.pubsub.v1.SubscriptionAdminClient;importcom.google.pubsub.v1.PushConfig;importcom.google.pubsub.v1.Subscription;importcom.google.pubsub.v1.SubscriptionName;importjava.io.IOException;publicclassUpdatePushConfigurationExample{publicstaticvoidmain(String...args)throwsException{// TODO(developer): Replace these variables before running the sample.StringprojectId="your-project-id";StringsubscriptionId="your-subscription-id";StringpushEndpoint="https://my-test-project.appspot.com/push";updatePushConfigurationExample(projectId,subscriptionId,pushEndpoint);}publicstaticvoidupdatePushConfigurationExample(StringprojectId,StringsubscriptionId,StringpushEndpoint)throwsIOException{try(SubscriptionAdminClientsubscriptionAdminClient=SubscriptionAdminClient.create()){SubscriptionNamesubscriptionName=SubscriptionName.of(projectId,subscriptionId);PushConfigpushConfig=PushConfig.newBuilder().setPushEndpoint(pushEndpoint).build();subscriptionAdminClient.modifyPushConfig(subscriptionName,pushConfig);Subscriptionsubscription=subscriptionAdminClient.getSubscription(subscriptionName);System.out.println("Updated push endpoint to: "+subscription.getPushConfig().getPushEndpoint());}}}

/** * TODO(developer): Uncomment these variables before running the sample. */// 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();asyncfunctionmodifyPushConfig(topicNameOrId,subscriptionNameOrId){constoptions={// Set to an HTTPS endpoint of your choice. If necessary, register// (authorize) the domain on which the server is hosted.pushEndpoint:`https://${pubSubClient.projectId}.appspot.com/push`,};awaitpubSubClient.topic(topicNameOrId).subscription(subscriptionNameOrId).modifyPushConfig(options);console.log(`Modifiedpushconfigforsubscription${subscriptionNameOrId}.`);}

/***TODO(developer):Uncommentthesevariablesbeforerunningthesample.*///consttopicNameOrId='YOUR_TOPIC_NAME_OR_ID';//constsubscriptionNameOrId='YOUR_SUBSCRIPTION_NAME_OR_ID';//ImportstheGoogleCloudclientlibraryimport{PubSub,CreateSubscriptionOptions}from'@google-cloud/pubsub';//Createsaclient;cachethisforfurtheruseconstpubSubClient=newPubSub();asyncfunctionmodifyPushConfig(topicNameOrId:string,subscriptionNameOrId:string,){constoptions:CreateSubscriptionOptions={//SettoanHTTPSendpointofyourchoice.Ifnecessary,register//(authorize)thedomainonwhichtheserverishosted.pushEndpoint:`https://${pubSubClient.projectId}.appspot.com/push`,};awaitpubSubClient.topic(topicNameOrId).subscription(subscriptionNameOrId).modifyPushConfig(options);console.log(`Modifiedpushconfigforsubscription${subscriptionNameOrId}.`);}

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"subscriber=pubsub_v1.SubscriberClient()subscription_path=subscriber.subscription_path(project_id,subscription_id)push_config=pubsub_v1.types.PushConfig(push_endpoint=endpoint)subscription=pubsub_v1.types.Subscription(name=subscription_path,topic=topic_id,push_config=push_config)update_mask={"paths":{"push_config"}}# Wrap the subscriber in a 'with' block to automatically call close() to# close the underlying gRPC channel when done.withsubscriber:result=subscriber.update_subscription(request={"subscription":subscription,"update_mask":update_mask})print(f"Subscription updated:{subscription_path}")print(f"New endpoint for subscription is:{result.push_config}.")

# subscription_id   = "your-subscription-id"# new_endpoint      = "Endpoint where your app receives messages""pubsub=Google::Cloud::PubSub.newsubscription_admin=pubsub.subscription_adminsubscription=subscription_admin.get_subscription\subscription:pubsub.subscription_path(subscription_id)subscription.push_config=Google::Cloud::PubSub::V1::PushConfig.new\push_endpoint:new_endpointsubscription_admin.update_subscriptionsubscription:subscription,update_mask:{paths:["push_config"]}puts"Push endpoint updated."