for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace OldSound\RabbitMqBundle\Declarations;
class DeclarationsRegistry
{
/** @var ExchangeDeclaration[] */
public $exchanges;
/** @var QueueDeclaration[] */
public $queues;
/** @var BindingDeclaration[] */
public $bindings = [];
public function addExchange(ExchangeDeclaration $exchangeDeclaration)
if (isset($this->exchanges[$exchangeDeclaration->name])) {
throw new \InvalidArgumentException(sprintf('Exchange declartion with %s name already registerd', $exchangeDeclaration->name));
}
$this->exchanges[$exchangeDeclaration->name] = $exchangeDeclaration;
public function addQueue(QueueDeclaration $queueDeclaration)
$this->queues[] = $queueDeclaration;
public function addBinding(BindingDeclaration $bindingDeclaration)
$this->bindings[] = $bindingDeclaration;
/**
* @param ExchangeDeclaration $exchange
* @return BindingDeclaration[]
*/
public function getBindingsByExchange(ExchangeDeclaration $exchange): array
return array_filter($this->bindings, function ($binding) use ($exchange) {
return $binding->exchange === $exchange->name || ($binding->destinationIsExchange && $binding->destination === $exchange->name);
});
eMAGTechLabs /
RabbitMqBundle
