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