The transport uses Beanstalkd job manager. The transport uses Pheanstalk library internally.
$ composer require enqueue/pheanstalk
<?php
use Enqueue\Pheanstalk\PheanstalkConnectionFactory;
// connects to localhost:11300
$factory = new PheanstalkConnectionFactory();
// same as above
$factory = new PheanstalkConnectionFactory('beanstalk:');
// connects to example host and port 5555
$factory = new PheanstalkConnectionFactory('beanstalk://example:5555');
// same as above but configured by array
$factory = new PheanstalkConnectionFactory([
'host' => 'example',
'port' => 5555
]);
$psrContext = $factory->createContext();
// if you have enqueue/enqueue library installed you can use a factory to build context from DSN
$psrContext = (new \Enqueue\ConnectionFactoryFactory())->create('beanstalk:')->createContext();
<?php
/** @var \Enqueue\Pheanstalk\PheanstalkContext $psrContext */
$fooTopic = $psrContext->createTopic('aTopic');
$message = $psrContext->createMessage('Hello world!');
$psrContext->createProducer()->send($fooTopic, $message);
<?php
/** @var \Enqueue\Pheanstalk\PheanstalkContext $psrContext */
$fooQueue = $psrContext->createQueue('aQueue');
$message = $psrContext->createMessage('Hello world!');
$psrContext->createProducer()->send($fooQueue, $message);
<?php
/** @var \Enqueue\Pheanstalk\PheanstalkContext $psrContext */
$fooQueue = $psrContext->createQueue('aQueue');
$consumer = $psrContext->createConsumer($fooQueue);
$message = $consumer->receive(2000); // wait for 2 seconds
$message = $consumer->receiveNoWait(); // fetch message or return null immediately
// process a message
$consumer->acknowledge($message);
// $consumer->reject($message);