Guest User

Untitled

a guest
Jan 2nd, 2019
155
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.40 KB | None | 0 0
  1. public function registerBundles()
  2. {
  3. $bundles = array(
  4. new OldSoundRabbitMqBundleOldSoundRabbitMqBundle(),
  5. );
  6. }
  7.  
  8. old_sound_rabbit_mq:
  9. connections:
  10. default:
  11. host: 'localhost'
  12. port: 5672
  13. user: 'guest'
  14. password: 'guest'
  15. vhost: '/'
  16. lazy: false
  17. connection_timeout: 3
  18. read_write_timeout: 3
  19. keepalive: false
  20. heartbeat: 0
  21. use_socket: true
  22.  
  23. producers:
  24. processing_request:
  25. connection: default
  26. exchange_options: {name: 'processing_request', type: direct}
  27.  
  28. consumers:
  29. processing_request:
  30. connection: default
  31. exchange_options: {name: 'processing_request', type: direct}
  32. queue_options: {name: 'processing_request'}
  33. callback: processing_request_service
  34.  
  35. use OldSoundRabbitMqBundleRabbitMqConsumerInterface;
  36. use PhpAmqpLibMessageAMQPMessage;
  37.  
  38. class ProcessingRequestConsumer implements ConsumerInterface
  39. {
  40. public function execute(AMQPMessage $msg)
  41. {
  42. //фоновый скрипт
  43. ...
  44. }
  45. }
  46.  
  47. ./app/console rabbitmq:consumer processing_request -vvv &
  48.  
  49. public function indexAction()
  50. {
  51. $this->get('old_sound_rabbit_mq.processing_request_producer')->publish('Processing Request...');
  52. ...
  53. return $this->json(array('result' => 'success'));
  54. }
Add Comment
Please, Sign In to add comment