const{PubSub}=require('@google-cloud/pubsub');

constpubsub=newPubSub();

constpubsub=newPubSub({projectId:'your-project-id',keyFilename:'/path/to/keyfile.json'});

// Imports the Google Cloud client libraryimport{PubSub}from'@google-cloud/pubsub';asyncfunctionquickstart(projectId='your-project-id',// Your Google Cloud Platform project IDtopicNameOrId='my-topic',// Name for the new topic to createsubscriptionName='my-sub'// Name for the new subscription to create){// Instantiates a clientconstpubsub=newPubSub({projectId});// Creates a new topicconst[topic]=awaitpubsub.createTopic(topicNameOrId);console.log(`Topic${topic.name} created.`);// Creates a subscription on that new topicconst[subscription]=awaittopic.createSubscription(subscriptionName);// Receive callbacks for new messages on the subscriptionsubscription.on('message',message=>{console.log('Received message:',message.data.toString());process.exit(0);});// Receive callbacks for errors on the subscriptionsubscription.on('error',error=>{console.error('Received error:',error);process.exit(1);});// Send a message to the topictopic.publishMessage({data:Buffer.from('Test message!')});}

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();awaitpubsub.createSchema('messageType',SchemaTypes.Avro,'{...avro definition...}');

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();consttopic='messageCenter';constname='newMessages';constcallback=function(err,subscription,apiResponse){};pubsub.createSubscription(topic,name,callback);

pubsub.createSubscription(topic,name).then(function(data){constsubscription=data[0];constapiResponse=data[1];});

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();pubsub.createTopic('my-new-topic',function(err,topic,apiResponse){if(!err){// The topic was created successfully.}});//-// If the callback is omitted, we'll return a Promise.//-pubsub.createTopic('my-new-topic').then(function(data){consttopic=data[0];constapiResponse=data[1];});

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();pubsub.detachSubscription('my-sub',(err,topic,apiResponse)=>{if(!err){// The topic was created successfully.}});//-// If the callback is omitted, we'll return a Promise.//-pubsub.detachSubscription('my-sub').then(data=>{constapiResponse=data[0];});

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();pubsub.getSnapshots(function(err,snapshots){if(!err){// snapshots is an array of Snapshot objects.}});//-// If the callback is omitted, we'll return a Promise.//-pubsub.getSnapshots().then(function(data){constsnapshots=data[0];});

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();pubsub.getSubscriptions(function(err,subscriptions){if(!err){// subscriptions is an array of Subscription objects.}});//-// If the callback is omitted, we'll return a Promise.//-pubsub.getSubscriptions().then(function(data){constsubscriptions=data[0];});

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();pubsub.getTopics(function(err,topics){if(!err){// topics is an array of Topic objects.}});//-// Customize the query.//-pubsub.getTopics({pageSize:3},function(err,topics){});//-// If the callback is omitted, we'll return a Promise.//-pubsub.getTopics().then(function(data){consttopics=data[0];});

forawait(constsofpubsub.listSchemas()){constmoreInfo=awaits.get();}

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();constschema=pubsub.schema('my-schema');

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();constsnapshot=pubsub.snapshot('my-snapshot');

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();constsubscription=pubsub.subscription('my-subscription');// Register a listener for `message` events.subscription.on('message',function(message){// Called every time a message is received.// message.id = ID of the message.// message.ackId = ID used to acknowledge the message receival.// message.data = Contents of the message.// message.attributes = Attributes of the message.// message.publishTime = Date when Pub/Sub received the message.});

const{PubSub}=require('@google-cloud/pubsub');constpubsub=newPubSub();consttopic=pubsub.topic('my-topic');