Слушатель на атомной последовательности

Можно ли слушать, как Apache Ignite ставит, получает и увеличивает Atomic Sequence? Если нет, есть ли другой способ сделать это?

Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
Что такое управление транзакциями JDBC и как оно используется для поддержания согласованности данных?
Что такое управление транзакциями JDBC и как оно используется для поддержания согласованности данных?
Управление транзакциями JDBC - это мощная функция, которая позволяет рассматривать группу операций с базой данных как единую единицу работы. Оно...
Выполнение HTTP-запроса с помощью Spring WebClient: GET
Выполнение HTTP-запроса с помощью Spring WebClient: GET
WebClient - это реактивный веб-клиент, представленный в Spring 5. Это реактивное, неблокирующее решение, работающее по протоколу HTTP/1.1.
Gradle за прокси-сервером
Gradle за прокси-сервером
Создайте проект Gradle под сетевым прокси.
1
0
73
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Невозможно прослушивать события AtomicSequence, однако можно использовать обновление обычного кеша для каждого обновления последовательности, а затем прослушивать EVENT_CACHE_PUT, тем самым достигая той же функциональности.

Https://ignite.apache.org/docs/latest/data-structures/atomic-sequence

//create an atomic sequence
IgniteAtomicSequence seq = ignite.atomicSequence("seqName", // Sequence name.
        0, // Initial value for sequence.
        true // Create if it does not exist.
);

// Increment the atomic sequence.
for (int i = 0; i < 20; i++) {
    long currentValue = seq.get();
    long newValue = seq.incrementAndGet();

   //RECORD the sequence value in a regular cache
   ignite.getOrCreateCache("myCache").put(ignite.cluster().localNode().id(), newValue)
}

Затем прослушайте EVENT_CACHE_PUT, как описано здесь: https://ignite.apache.org/docs/latest/events/listening-to-events#listening-to-remote-events

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