Guest User

Untitled

a guest
Jun 21st, 2018
73
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.82 KB | None | 0 0
  1. [PhpAmqpLibExceptionAMQPRuntimeException] Invalid frame type 65
  2.  
  3. class MessageConsumer implements ConsumerInterface
  4. {
  5. /**
  6. * @var Sender
  7. */
  8. protected $sender;
  9.  
  10. /**
  11. * @return Sender
  12. */
  13. public function getSender()
  14. {
  15. return $this->sender;
  16. }
  17.  
  18. /**
  19. * @param Sender $sender
  20. * @return $this
  21. */
  22. public function setSender(Sender $sender)
  23. {
  24. $this->sender = $sender;
  25. return $this;
  26. }
  27.  
  28. /**
  29. * @param AMQPMessage $msg
  30. * @return void
  31. * @throws InvalidArgumentException
  32. * @throws DoctrineORMORMInvalidArgumentException
  33. * @throws DoctrineORMOptimisticLockException
  34. */
  35. public function execute(AMQPMessage $msg)
  36. {
  37. $messageId = $msg->getBody();
  38. $this->getSender()->process($messageId);
  39. }
  40. }
Add Comment
Please, Sign In to add comment