for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Cmobi\RabbitmqBundle\Transport\Rpc;
use Cmobi\RabbitmqBundle\Queue\CmobiAMQPMessage;
use Cmobi\RabbitmqBundle\Queue\QueueCallbackInterface;
use Cmobi\RabbitmqBundle\Queue\QueueServiceInterface;
use PhpAmqpLib\Message\AMQPMessage;
class RpcQueueCallback implements QueueCallbackInterface
{
private $queueService;
public function __construct(QueueServiceInterface $queueService)
$this->queueService = $queueService;
}
/**
* @return QueueServiceInterface
*/
public function getQueueService()
return $this->queueService;
* @return \Closure
public function toClosure()
return function (AMQPMessage $message) {
$response = $this->getQueueService()->handle($message);
$amqpResponse = new CmobiAMQPMessage(
(string) $response,
['correlation_id' => $message->get('correlation_id')]
);
$message->delivery_info['channel']->basic_publish(
$amqpResponse,
'',
$message->get('reply_to')
$message->delivery_info['channel']->basic_ack(
$message->delivery_info['delivery_tag']
object<PhpAmqpLib\Channel\AMQPChannel>
string
It seems like the type of the argument is not accepted by the function/method which you are calling.
In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug.
We suggest to add an explicit type cast like in the following example:
function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x);
};
contamobi /
CmobiRabbitmqBundle
It seems like the type of the argument is not accepted by the function/method which you are calling.
In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug.
We suggest to add an explicit type cast like in the following example: