Модифицированный брокер ActiveMQ

Я хочу написать модифицированный брокер ActiveMQ, который, когда он прослушивает сообщения производителей определенной темы, обрабатывает их альтернативно (например, использует API HDFS и не использует постоянное хранилище по умолчанию). У вас есть идеи, с чего начать?

заранее спасибо, Петруччи


person Andreas Petrucci    schedule 10.12.2010    source источник


Ответы (1)


Вы можете реализовать свой собственный ActiveMQ хранилище сообщений для HDFS, которое позволит ActiveMQ использовать HDFS в качестве постоянного хранилища, или вы можете создать ActiveMQ плагин для брокера, который позволит вам перехватывать сообщения при их поступлении в брокер. Оба подхода очень разные, поэтому выбор пути зависит от ваших требований.

Брюс

person bsnyder    schedule 10.12.2010
comment
как я вижу, подход с плагином брокера проще, не так ли? и использование этого плагина для брокера означает, что я должен собрать ActiveMQ с нуля, я прав? - person Andreas Petrucci; 11.12.2010
comment
Нет необходимости создавать ActiveMQ с нуля. Вам просто нужны соответствующие JAR-файлы ActiveMQ в вашем пути к классам, чтобы использовать правильные классы. - person bsnyder; 20.12.2010