for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Mouf\AmqpClient;
class Consumer extends AbstractConsumer
{
/**
* @var callable
*/
private $callback;
* Consumer constructor.
*
* @param callable $callback
public function __construct(callable $callback)
$this->callback = $callback;
}
public function setCallback($callback)
public function onMessageReceived($msg)
$callback = $this->callback;
$callback($msg);
thecodingmachine /
oo-amqp-client
