$queuesOptions =
$amqpOptions['queues'
];
unset($amqpOptions['queues'
],
$amqpOptions['exchange'
]);
if (isset($amqpOptions['auto_setup'
])) { $amqpOptions['auto_setup'
] =
filter_var($amqpOptions['auto_setup'
], \FILTER_VALIDATE_BOOL
);
} $queuesOptions =
array_map(function D
$queueOptions) { if (!\
is_array($queueOptions)) { $queueOptions =
[];
} if (\
is_array($queueOptions['arguments'
] ?? false
)) { $queueOptions['arguments'
] = self::
normalizeQueueArguments($queueOptions['arguments'
]);
} return $queueOptions;
},
$queuesOptions);
if (!
$useAmqps) { unset($amqpOptions['cacert'
],
$amqpOptions['cert'
],
$amqpOptions['key'
],
$amqpOptions['verify'
]);
} if ($useAmqps && !self::
hasCaCertConfigured($amqpOptions)) { throw new InvalidArgumentException('No CA certificate has been provided. Set "amqp.cacert" in your php.ini or pass the "cacert" parameter in the DSN to use SSL. Alternatively, you can use amqp:// to use without SSL.'
);
}