for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace RabbitMqModule\Service\Connection;
use RabbitMqModule\Options\Connection as ConnectionOptions;
use PhpAmqpLib\Connection\AMQPSocketConnection;
/**
* Class SocketConnectionFactory.
*/
class SocketConnectionFactory implements ConnectionFactoryInterface
{
* @codeCoverageIgnore
*
* @param ConnectionOptions $options
* @return AMQPSocketConnection
public function createConnection(ConnectionOptions $options)
return new AMQPSocketConnection(
$options->getHost(),
$options->getPort(),
$options->getUsername(),
$options->getPassword(),
$options->getVhost(),
$options->isInsist(),
$options->getLoginMethod(),
null,
$options->getLocale(),
$options->getReadWriteTimeout(),
$options->isKeepAlive()
);
}