Google Cloud PubSub – 实现拉

我在nodejs中使用google pub sub。
我有一个发布消息的服务,然后是一个监听消息并在消息上实现一些进程的工作者。
现在我想要我的服务一次拉五个订阅,并在完成处理时拉另一个订阅。 我如何实现这个?

这是我的开始代码,我该如何继续?

var pubsubClient = require('google-cloud').pubsub({ projectId: 'my-project' }); var topic = pubsubClient.topic('my-first-pub-sub'); var options = { reuseExisting: true, ackDeadlineSeconds: 90, autoAck: true, interval: 5000 }; topic.subscribe('MySub', options, function(err, subscription, apiResponse) { // Register listeners to start pulling for messages. function onError(err) { console.log("err", err); } function onMessage(message) { console.log("subscription", message); } // subscription.on('error', onError); // // subscription.on('message', onMessage); // var opts = { maxResults: 1 }; subscription.pull(opts, function(err, message) { console.log("subscription", err); console.log("subscription", message); }); });