message deleted from queue

Question

I have used BlockingQueue implementation to process my events by services from a queue. However in case if the server goes down, all my events from that queue are getting deleted and hence I am missing events to process. (I am looking for some internal DB where server can store the event/messages from queue and if server goes down and up again, it can load all events/messages to process again, without manually intervention).

Any help on this. I am not sure if I should use Apache ActiveMQ. I am using apache servicemix.

Thanks in advance.

Answer 1

I can not answer about how to do this with BlockingQueue.

But ActiveMQ has two features that you will benefit from:

Persistent Queues and possibly you might also want to look at Durable Queues

It has a built in database that just does this under the hood and allows messages to be persisted in queue even if broker or consumer has to restart.