for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace RabbitMqModule\Options;
use Zend\Serializer\Serializer;
use Zend\Serializer\Adapter\AdapterInterface as SerializerInterface;
/**
* Class RpcServer
* @package RabbitMqModule\Options
*/
class RpcServer extends Consumer
{
* @var SerializerInterface
protected $serializer;
* @return mixed
public function getSerializer()
return $this->serializer;
}
* @param null|string|array|SerializerInterface $serializer
*
* @return $this
* @throws \InvalidArgumentException
public function setSerializer($serializer = null)
if (is_array($serializer)) {
if (!array_key_exists('name', $serializer)) {
throw new \InvalidArgumentException('A serializer name should be provided');
$name = $serializer['name'];
$options = array_key_exists('options', $serializer) ? $serializer['options'] : null;
$serializer = Serializer::factory($name, $options);
} elseif (is_string($serializer)) {
$serializer = Serializer::factory($serializer);
if (null !== $serializer && !$serializer instanceof SerializerInterface) {
throw new \InvalidArgumentException('Invalid serializer instance or options');
$this->serializer = $serializer;
return $this;
astepin /
RabbitMqModule
