Download the PHP package mle86/wq-amqp without Composer
On this page you can find all versions of the php package mle86/wq-amqp. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Download mle86/wq-amqp
More information about mle86/wq-amqp
Files in mle86/wq-amqp
Package wq-amqp
Short Description An AMQP module for mle86/wq using the php-amqplib connector
License MIT
FAQ
Example:
In general, it is recommended to use always a project to download your libraries. In an application normally there is more than one library needed.
- Some hosting areas are not accessible by a terminal or SSH. Then it is not possible to use Composer.
- To use Composer is sometimes complicated. Especially for beginners.
- Composer needs much resources. Sometimes they are not available on a simple webspace.
- If you are using private repositories you don't need to share your credentials. You can set up everything on our site and then you provide a simple download link to your team member.
- Simplify your Composer build process. Use our own command line tool to download the vendor folder as binary. This makes your build process faster and you don't need to expose your credentials for private repositories.
Informations about the package wq-amqp
WQ-AMQP (mle86/wq-amqp)
This package contains the PHP class
mle86\WQ\WorkServerAdapter\AMQPWorkServer.
It supplements the
mle86/wq package
by implementing its WorkServerAdapter interface.
It connects to an AMQP server such as RabbitMQ using the php-amqplib/php-amqplib package.
It creates durable queues in the default exchange (“”) for immediate-delivery jobs
and the durable “_phpwq._delayed” queue in the custom “_phpwq._delay_exchange” exchange for delayed jobs.
Jobs stored with storeJob() are always durable as well.
Empty queues or exchanges won't be deleted automatically.
Version and Compatibility
This is
version 1.4.0
of mle86/wq-amqp.
It was developed for
version 1.0.0
of mle86/wq
and should be compatible
with all of its future 1.x versions as well.
Installation and Dependencies
It requires PHP 8.0+.
It depends on mle86/wq and php-amqplib/php-amqplib, which in turn requires the mbstring, sockets, and bcmath PHP extensions.
Class reference
class mle86\WQ\WorkServerAdapter\AMQPWorkServer implements WorkServerAdapter
public function __construct (AMQPStreamConnection $connection)
Constructor. Takes an already-configuredAMQPStreamConnectioninstance to work with. Does not attempt to establish a connection itself – use theconnect()factory method for that instead.public static function connect ($host = 'localhost', $port = 5672, $user = 'guest', $password = 'guest', $vhost = '/', $insist = false, $login_method = 'AMQPLAIN', $login_response = null, $locale = 'en_US', $connection_timeout = 3.0, $read_write_timeout = 3.0, $context = null, $keepalive = false, $heartbeat = 0)
Factory method. See AMQPStreamConnection::__construct for the parameter descriptions.
Interface methods
which are documented in the WorkServerAdapter interface:
public function storeJob (string $workQueue, Job $job, int $delay = 0)public function getNextQueueEntry ($workQueue, int $timeout = DEFAULT_TIMEOUT): ?QueueEntrypublic function buryEntry (QueueEntry $entry)public function requeueEntry (QueueEntry $entry, int $delay, string $workQueue = null)public function deleteEntry (QueueEntry $entry)
Usage example
This executes all jobs available in the local AMQP server's “mail” queue, forever.
It will however abort if one of the jobs throws an exception –
you might want to add a logging try-catch block around the processNextJob() call
as shown in WQ's “Quick Start” example.
All versions of wq-amqp with dependencies
mle86/wq Version ^v1.0.0 || >=v0.21.0 <1.0.0
php-amqplib/php-amqplib Version ^3 || ^2.20