Added event emitter to connection's onMethod to match the event emitted by the queue and exchange