Guest User

Untitled

a guest
Jan 2nd, 2019
134
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.31 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. class ProcessingRequestConsumer implements ConsumerInterface
  36. {
  37. public function execute(AMQPMessage $msg)
  38. {
  39. //фоновый скрипт
  40. ...
  41. }
  42. }
  43.  
  44. ./app/console rabbitmq:consumer processing_request -vvv
  45.  
  46. public function indexAction()
  47. {
  48. $this->get('old_sound_rabbit_mq.processing_request_producer')->publish('Processing Request...');
  49. ...
  50. return $this->json(array('result' => 'success'));
  51. }
Add Comment
Please, Sign In to add comment