<?php
namespace Illuminate\Queue\Connectors;
use Illuminate\Queue\BeanstalkdQueue;
use Pheanstalk\Contract\SocketFactoryInterface;
use Pheanstalk\Pheanstalk;
use Pheanstalk\Values\Timeout;
class BeanstalkdConnector implements ConnectorInterface
{
/**
* Establish a queue connection.
*
* @param array $config
* @return \Illuminate\Contracts\Queue\Queue
*/
public function connect(array $config)
{
return new BeanstalkdQueue(
$this->pheanstalk($config),
$config['queue'],
$config['retry_after'] ?? Pheanstalk::DEFAULT_TTR,
$config['block_for'] ?? 0,
$config['after_commit'] ?? null
);
}
/**
* Create a Pheanstalk instance.
*
* @param array $config
* @return \Pheanstalk\Pheanstalk
*/
protected function pheanstalk(array $config)
{
return Pheanstalk::create(
$config['host'],
$config['port'] ?? SocketFactoryInterface::DEFAULT_PORT,
isset($config['timeout']) ? new Timeout($config['timeout']) : null,
);
}
}