Я где-то видел message.nack()
, но я забыл это место.
Я ищу их в Google, но не получил никакой информации.
Мне нужны ссылки на документы о message.ack()
и message.nack()
.
Я прочитал книгу о google pub-sub
Вот код:
const pubsub = require('@google-cloud/pubsub')({
projectId: 'your-project-id'
});
const topic = pubsub.topic('first-topic');
const subscription = topic.subscription('first-subscription');
subscription.pull().then((data) => {
const message = data[0][0];
subscription.pull().then((data) => {
const message = data[0][0];
console.log('Got message', message.id, 'saying', message.data);
});
!console.log('Got message', message.id, 'saying', message.data);
message.ack().then(() => {
console.log('Acknowledged message ID', message.id, 'with ackId', message.ackId);
});
});
Я думаю, что есть две ошибки:
subscription
не имеет .pull()
метод
message.ack()
не возвращает promise
Я проверяю, используя "@google-cloud/pubsub": "^0.19.0",
Итак, я ищу официальные документы о message.ack()