Add getConnection() for AMQPExchange and AMQPQueue