for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Gendoria\CommandQueueRabbitMqDriverBundle\Worker;
use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;
use PhpAmqpLib\Message\AMQPMessage;
/**
* "Dummy" class needed to create RabbitMQ reschedule queue.
*
* @author Tomasz Struczyński <[email protected]>
*/
class ServiceRescheduleWorker implements ConsumerInterface
{
* Class constructor - does nothing.
public function __construct()
}
* Process message, sending it back to queue.
* @param AMQPMessage $msg
* @return int Return self::MSG_REJECT_REQUEUE value to enforce message requeue.
public function execute(AMQPMessage $msg)
return self::MSG_REJECT_REQUEUE;
Gendoria /
command-queue-rabbitmq-bundle
