ActiveMQ Modified Broker

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 A开发者_StackOverflowPI for example and not use default persisten store). Do you have any ideas where to start with?

thanks in advance, Petrucci

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.

Bruce