if (isset($params[self::AMQP_KEY])) {
            if ($invalidConfigParams = array_diff_key($params[self::AMQP_KEY], self::$defaultAMQPParams)) {
                throw new TestingException(
                    'The following elements are not valid AMQP configuration params: ' . json_encode($invalidConfigParams)
                );