Apache ActiveMQ Artemis - это брокер сообщений, который является частью проекта ActiveMQ.Однако он не похож на «классическую» кодовую базу брокера ActiveMQ.Он основан на более новом, принципиально неблокирующем дизайне и поддерживает все протоколы и практически те же функции, что и ActiveMQ 5.x.В настоящее время целью сообщества ActiveMQ является то, что Артемида станет версией ActiveMQ 6.x.
- Повторяющиеся задачи (ActiveMQ)
Вы может использовать запланированную доставку, но это относится только к одному сообщению.Как только это сообщение доставлено и потреблено, оно исчезло, что означает, что вам нужно отправить другое запланированное сообщение.Не происходит автоматической повторной доставки одного и того же сообщения.
Что-то вроде кварцевого планировщика может быть хорошим решением здесь, потому что вы можете планировать все задачи с ним, а запланированная задача можетотправьте сообщение в очередь, которая отслеживается вашими распределенными работниками.Таким образом, вы можете отделить планирование от распределения работы.
Обнаружение дублирующихся задач (Artemis)
Artemis поддерживает нечто, называемое «очередью последнего значения», где вы можете установить специальное свойство сообщения для определенного значения (например, для задачи).ID) и всякий раз, когда вы отправляете сообщение в очередь с тем же значением, оно заменяет существующее сообщение тем, которое вы отправили.Другими словами, он всегда имеет отправленное вами значение last .Подробнее об этом можно прочитать в документации Artemis об очередях с последними значениями .
. Существует также классическое обнаружение дубликатов, в котором вы можете установить дубликат идентификатора в сообщении, и если брокер увидит повторныйдубликат идентификатора будет отклонять сообщение с повторяющимся идентификатором.Подробнее об этом можно прочитать в документации Artemis по обнаружению дубликатов .
Постоянство данных
По умолчанию любое сообщение, помеченное как durable (или persistent в терминах JMS), которое отправляется в долговременную очередь (очереди по умолчанию долговечны) будетбыть сохраненным на диск.
Изменение сообщения - удалить из очереди или изменить задержку повторения
Сообщения в очереди являются неизменяемыми, поэтому вы не можете редактировать их технически, но вы можете использовать семантику последнего-значение очереди для получения аналогичного поведения (например, отправка измененного сообщения с тем же свойством last-value, и оно заменит существующее сообщение).
Интеграция Spring
ActiveMQ Artemis - это реализация JMS, поэтому все классы интеграции JMS, доступные в Spring, будут отлично работать.