Есть ли провайдер Message Bus, который позволяет подписчикам на длительный срок и полному воспроизведению?

Question

Я пытаюсь найти поставщика шины сообщений, который поддерживает Durable Subscribeers и позволяет мне воспроизводить по порядку, на основе метки времени сообщения, все сообщения для данной темы. Кроме того, я хотел бы, чтобы шина сообщений сбрасывала контрольную точку каждого потребителя длительного пользования, когда сообщение приходит с опозданием. Э.Г.

1. Клиент подписывается на тему 1 в 2009-12-22 12: 00: 00
2. Пришло сообщение 1, отметка времени 2009-12-22
3. Клиент получает сообщение 1
4. Клиент отключается
5. Пришло сообщение 2, отметка времени 2009-12-21 18: 00: 00
6. Клиент подключается
7. Клиент получает Сообщение 2, затем Сообщение 1

Я бы сильно предпочел поставщика с открытым исходным кодом. Кто-нибудь знает провайдера шины сообщений, который поддерживает это? Я пытался прочитать вступительную документацию по ActiveMQ, Mass Transit и т. Д., Но должен признать, что я не согласен с терминологией шины сообщений, поэтому многое из этого вышло у меня из головы.

Answer 1

вы можете посмотреть на проект интеграции весны.

http://www.springsource.org/spring-integration

Answer 2

AMQP (реализовано RabbitMQ и др.) Позволяет вам определять длительные очереди и прикреплять их к одному и тому же обмену. Каждый клиент, который хочет получать сообщения, сначала устанавливает свою собственную длительную очередь, которая будет хранить сообщения, полученные от обмена, даже когда клиент отключен.

Единственным ограничением этого является то, что клиенты, которые никогда не подключались и которые неожиданно прибывают на сцену, не могут запоздало установить очередь и запросить дамп всех предыдущих сообщений. AMQP 1.0 может позволить такое универсальное постоянство, но я не очень хорошо знаю новую модель, поэтому не могу сказать наверняка.