3

我在 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);
    });
});
4

0 回答 0