Portiny\RabbitMQ\Producer\AbstractProducer

Complexity

Total Complexity

4

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	produce()	0	11	1
	getExchangeName()	0	1	?
	getRoutingKey()	0	1	?
A	getHeaders()	0	4	1
A	isMandatory()	0	4	1
A	isImmediate()	0	4	1

<?php declare(strict_types=1);

namespace Portiny\RabbitMQ\Producer;

use Bunny\Channel;
use React\Promise\PromiseInterface;

abstract class AbstractProducer
{
	/**
	 * @var int
	 */
	public const DELIVERY_MODE_NON_PERSISTENT = 1;

	/**
	 * @var int
	 */
	public const DELIVERY_MODE_PERSISTENT = 2;

	/**
	 * @var string
	 */
	public const CONTENT_TYPE_APPLICATION_JSON = 'application/json';

	/**
	 * @return bool|int|PromiseInterface
	 */
	final public function produce(Channel $channel, $body)
	{
		return $channel->publish(
			$body,
			$this->getHeaders(),
			$this->getExchangeName(),
			$this->getRoutingKey(),
			$this->isMandatory(),
			$this->isImmediate()
		);
	}

	abstract protected function getExchangeName(): string;

	abstract protected function getRoutingKey(): string;

	protected function getHeaders(): array
	{
		return [];
	}

	protected function isMandatory(): bool
	{
		return false;
	}

	protected function isImmediate(): bool
	{
		return false;
	}
}