Changed ActiveMQ to using queues instead of topics