Take the 2-minute tour ×

I wanto to write a modified ActiveMQ broker that when he listens to producers' messages of a specific topic to handle them alternatively (use HDFS API for example and not use default persisten store). Do you have any ideas where to start with?

thanks in advance, Petrucci

share|improve this question

1 Answer 1

You could either implement your own ActiveMQ message store for HDFS which would allow ActiveMQ to use HDFS as a persistence store, or you could create an ActiveMQ broker plugin which would allow you to intercept messages as they enter the broker. Both are very different approaches, so it really depends on your requirements as to which path to take.


share|improve this answer
as i can see the broker plugin approch is easier , isn't it? and using this broker plugin means that i should build activemq for scratch, am i right? –  Andreas Petrucci Dec 11 '10 at 4:20
There's no need to build ActiveMQ from scratch. You just need the appropriate ActiveMQ JARs in your classpath to utilize the correct classes. –  bsnyder Dec 20 '10 at 2:27

Your Answer


