for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
/*
* This file is part of forecast.it.fill project.
* (c) Patrick Jaja <[email protected]>
* This source file is subject to the MIT license that is bundled
* with this source code in the file LICENSE.
*/
namespace ForecastAutomation\AmqpClient\Shared\Plugin;
use ForecastAutomation\Kernel\Shared\Plugin\AbstractPlugin;
use ForecastAutomation\QueueClient\Shared\Dto\MessageCollectionDto;
use ForecastAutomation\QueueClient\Shared\Plugin\AdapterPluginInterface;
/**
* @method \ForecastAutomation\AmqpClient\AmqpClientFacade getFacade()
class AmqpAdapterPluginPlugin extends AbstractPlugin implements AdapterPluginInterface
{
public function sendMessages(string $queueName, MessageCollectionDto $messageCollectionDto): void
$this->getFacade()->sendMessages($queueName, $messageCollectionDto);
}
public function consume(string $queueName): void
$this->getFacade()->consume($queueName);
patrickjaja /
forecast.it.fill
