Roman Mirr Here is the code, the endpoint in the symphony, the data comes into it and from there goes into the rabbitmq queue
$connection = new AMQPStreamConnection(
$_ENV['RABBIT_IP'],
$_ENV['RABBIT_PORT'],
$_ENV['RABBIT_USER'],
$_ENV['RABBIT_PASSWORD'],
'/',
false,
'AMQPLAIN',
null,
'en_US',
30, //Connection Timeout
30, // Read/Write Timeout
null,
false,
60
);
$channel = $connection->channel();
$channel->queue_declare('RequestLog', false, false, false, false);
$msg = new AMQPMessage($request->getContent());
$channel->basic_publish($msg, 'clickhouse-exchange', 'RequestLog');
$channel->close();
$connection->close();