Можно ли увидеть, получал ли подписчик "последнее" сообщение при использовании nats-streaming?
У меня есть клиентское приложение публикации (Java), которое в случае сбоя клиента я хотел бы добавить к существующим опубликованным сообщениям. Например, он должен видеть, что отправил 1000 сообщений, и продолжить с номера 1001.
В настоящее время я начинаю издателя, сначала создав подписчика, запрашивающего последнее опубликованное сообщение (Java:StartPosition.LastReceived
) и таким образом получает последнее опубликованное сообщение.
Проблема в том, когда нет сообщений. Есть ли другой способ, кроме использования тайм-аута, чтобы проверить, есть ли еще какие-либо сообщения, готовые к приему для подписчика?