Source of file BeanstalkdConnector.php
Size: 0,716 Bytes - Last Modified: 2021-12-23T10:38:27+00:00
/var/www/docs.ssmods.com/process/src/src/Connectors/BeanstalkdConnector.php
12345678910111213141516171819202122232425 | <?php namespace StudioBonito\SilverStripe\Queue\Connectors; use Pheanstalk_Pheanstalk as Pheanstalk; use StudioBonito\SilverStripe\Queue\BeanstalkdQueue; class BeanstalkdConnector implements ConnectorInterface { /** * Establish a queue connection. * * @param array $config * * @return \StudioBonito\SilverStripe\Queue\QueueInterface */ public function connect(array $config) { $pheanstalk = new Pheanstalk($config['host']); $queue = isset($config['queue']) ? $config['queue'] : 'default'; $timeToRun = isset($config['ttr']) ? $config['ttr'] : Pheanstalk::DEFAULT_TTR; return new BeanstalkdQueue($pheanstalk, $queue, $timeToRun); } } |