Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- [PhpAmqpLibExceptionAMQPRuntimeException] Invalid frame type 65
- class MessageConsumer implements ConsumerInterface
- {
- /**
- * @var Sender
- */
- protected $sender;
- /**
- * @return Sender
- */
- public function getSender()
- {
- return $this->sender;
- }
- /**
- * @param Sender $sender
- * @return $this
- */
- public function setSender(Sender $sender)
- {
- $this->sender = $sender;
- return $this;
- }
- /**
- * @param AMQPMessage $msg
- * @return void
- * @throws InvalidArgumentException
- * @throws DoctrineORMORMInvalidArgumentException
- * @throws DoctrineORMOptimisticLockException
- */
- public function execute(AMQPMessage $msg)
- {
- $messageId = $msg->getBody();
- $this->getSender()->process($messageId);
- }
- }
Add Comment
Please, Sign In to add comment