@@ 12-41 (lines=30) @@ | ||
9 | use Psr\Log\LoggerInterface; |
|
10 | ||
11 | ||
12 | class Publisher extends DomainPublisher |
|
13 | { |
|
14 | /** |
|
15 | * Publisher constructor. |
|
16 | * @param string $host |
|
17 | * @param int $port |
|
18 | * @param string $user |
|
19 | * @param string $password |
|
20 | * @param string $vHost |
|
21 | * @param string $exchangeName |
|
22 | * @param LoggerInterface $logger |
|
23 | */ |
|
24 | public function __construct( |
|
25 | $host, |
|
26 | $port, |
|
27 | $user, |
|
28 | $password, |
|
29 | $vHost, |
|
30 | $exchangeName, |
|
31 | LoggerInterface $logger |
|
32 | ) |
|
33 | { |
|
34 | $queueWriter = new QueueWriter( |
|
35 | new AMQPLazyConnection($host, $port, $user, $password, $vHost), |
|
36 | new ExchangeConfig($exchangeName, 'topic', false, true, false), |
|
37 | $logger |
|
38 | ); |
|
39 | parent::__construct($queueWriter); |
|
40 | } |
|
41 | } |
@@ 12-41 (lines=30) @@ | ||
9 | use Psr\Log\LoggerInterface; |
|
10 | ||
11 | ||
12 | class Producer extends DomainProducer |
|
13 | { |
|
14 | /** |
|
15 | * Producer constructor. |
|
16 | * @param string $host |
|
17 | * @param int $port |
|
18 | * @param string $user |
|
19 | * @param string $password |
|
20 | * @param string $vHost |
|
21 | * @param string $exchangeName |
|
22 | * @param LoggerInterface $logger |
|
23 | */ |
|
24 | public function __construct( |
|
25 | $host, |
|
26 | $port, |
|
27 | $user, |
|
28 | $password, |
|
29 | $vHost, |
|
30 | $exchangeName, |
|
31 | LoggerInterface $logger |
|
32 | ) |
|
33 | { |
|
34 | $queueWriter = new QueueWriter( |
|
35 | new AMQPLazyConnection($host, $port, $user, $password, $vHost), |
|
36 | new ExchangeConfig($exchangeName, 'fanout', false, true, false), |
|
37 | $logger |
|
38 | ); |
|
39 | parent::__construct($queueWriter); |
|
40 | } |
|
41 | } |