File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 13
13
require_once $ autoload ;
14
14
15
15
use Symfony \Component \EventDispatcher \EventDispatcher ;
16
+ use Symfony \Component \Messenger \Bridge \Amqp \Transport \AmqpReceiver ;
17
+ use Symfony \Component \Messenger \Bridge \Amqp \Transport \Connection ;
16
18
use Symfony \Component \Messenger \Envelope ;
17
19
use Symfony \Component \Messenger \EventListener \DispatchPcntlSignalListener ;
18
20
use Symfony \Component \Messenger \EventListener \StopWorkerOnSigtermSignalListener ;
19
21
use Symfony \Component \Messenger \MessageBusInterface ;
20
- use Symfony \Component \Messenger \Bridge \Amqp \Transport \AmqpReceiver ;
21
- use Symfony \Component \Messenger \Bridge \Amqp \Transport \Connection ;
22
22
use Symfony \Component \Messenger \Transport \Serialization \Serializer ;
23
23
use Symfony \Component \Messenger \Worker ;
24
24
use Symfony \Component \Serializer as SerializerComponent ;
40
40
public function dispatch ($ envelope , array $ stamps = []): Envelope
41
41
{
42
42
echo 'Get envelope with message: ' .get_class ($ envelope ->getMessage ())."\n" ;
43
- echo sprintf ("with stamps: %s \n" , json_encode (array_keys ($ envelope ->all ()), JSON_PRETTY_PRINT ));
43
+ echo sprintf ("with stamps: %s \n" , json_encode (array_keys ($ envelope ->all ()), \ JSON_PRETTY_PRINT ));
44
44
45
45
sleep (30 );
46
46
echo "Done. \n" ;
You can’t perform that action at this time.
0 commit comments