3

nodejsでgoogle pub subを使用しています。
メッセージを発行するサービスと、メッセージをリッスンしてメッセージにいくつかのプロセスを実装するワーカーがあります。
ここで、サービスで一度に 5 つのサブスクリプションを取得し、処理が終了したら別のサブスクリプションを取得する必要があります。これを実装するにはどうすればよいですか?

これが私の開始コードです。どうすれば続行できますか?

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