for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace RemiSan\TransactionManager\Amqp;
use Burrow\QueuePublisher;
use RemiSan\TransactionManager\Transactional;
class TransactionalQueuePublisher implements QueuePublisher, Transactional
{
/** @var QueuePublisher */
private $publisher;
/** @var array */
private $messages;
/**
* Constructor.
*
* @param QueuePublisher $publisher
*/
public function __construct(QueuePublisher $publisher)
$this->publisher = $publisher;
$this->messages = array();
}
* {@inheritdoc}
public function publish($data, $routingKey = "")
$this->messages[] = array(
'data' => $data,
'routingKey' => $routingKey
);
public function beginTransaction()
public function commit()
foreach ($this->messages as $message) {
$this->publisher->publish($message['data'], $message['routingKey']);
public function rollback()
remi-san /
transaction-manager
