@@ -34,17 +34,20 @@ The producer has two types on send methods:
34
34
``` php
35
35
<?php
36
36
37
+ use Enqueue\Client\ProducerInterface;
38
+ use Enqueue\Client\SpoolProducer;
39
+
37
40
/** @var Symfony\Component\DependencyInjection\ContainerInterface $container */
38
41
39
42
/** @var \Enqueue\Client\ProducerInterface $producer */
40
- $producer = $container->get('enqueue.producer' );
43
+ $producer = $container->get(ProducerInterface::class );
41
44
42
45
// message is being sent right now
43
46
$producer->sendEvent('a_topic', 'Hello there!');
44
47
45
48
46
49
/** @var \Enqueue\Client\SpoolProducer $spoolProducer */
47
- $spoolProducer = $container->get('enqueue.spool_producer' );
50
+ $spoolProducer = $container->get(SpoolProducer::class );
48
51
49
52
// message is being sent on console.terminate or kernel.terminate event
50
53
$spoolProducer->sendEvent('a_topic', 'Hello there!');
@@ -58,10 +61,13 @@ $spoolProducer->flush();
58
61
``` php
59
62
<?php
60
63
64
+ use Enqueue\Client\ProducerInterface;
65
+ use Enqueue\Client\SpoolProducer;
66
+
61
67
/** @var Symfony\Component\DependencyInjection\ContainerInterface $container */
62
68
63
69
/** @var \Enqueue\Client\ProducerInterface $producer */
64
- $producer = $container->get('enqueue.producer' );
70
+ $producer = $container->get(ProducerInterface::class );
65
71
66
72
// message is being sent right now, we use it as RPC
67
73
$promise = $producer->sendCommand('a_processor_name', 'Hello there!', $needReply = true);
@@ -70,7 +76,7 @@ $replyMessage = $promise->receive();
70
76
71
77
72
78
/** @var \Enqueue\Client\SpoolProducer $spoolProducer */
73
- $spoolProducer = $container->get('enqueue.spool_producer' );
79
+ $spoolProducer = $container->get(SpoolProducer::class );
74
80
75
81
// message is being sent on console.terminate or kernel.terminate event
76
82
$spoolProducer->sendCommand('a_processor_name', 'Hello there!');
0 commit comments