Using direct reflection for MessageProducer and Rate. Using exchanges instead of queues. It will be changed for Topics.