Можно ли увидеть, получал ли подписчик "последнее" сообщение при использовании nats-streaming?

У меня есть клиентское приложение публикации (Java), которое в случае сбоя клиента я хотел бы добавить к существующим опубликованным сообщениям. Например, он должен видеть, что отправил 1000 сообщений, и продолжить с номера 1001.

В настоящее время я начинаю издателя, сначала создав подписчика, запрашивающего последнее опубликованное сообщение (Java:StartPosition.LastReceived) и таким образом получает последнее опубликованное сообщение.

Проблема в том, когда нет сообщений. Есть ли другой способ, кроме использования тайм-аута, чтобы проверить, есть ли еще какие-либо сообщения, готовые к приему для подписчика?

0 ответов

Другие вопросы по тегам