Modify reference implementation for usage ActiveMQ