src/Queue/Pull/PredisPullEventQueue.php 1 location
|
@@ 46-52 (lines=7) @@
|
43 |
|
* @param LoggerInterface $logger |
44 |
|
* @param string $queue_name |
45 |
|
*/ |
46 |
|
public function __construct(ClientInterface $client, Serializer $serializer, LoggerInterface $logger, $queue_name) |
47 |
|
{ |
48 |
|
$this->client = $client; |
49 |
|
$this->serializer = $serializer; |
50 |
|
$this->logger = $logger; |
51 |
|
$this->queue_name = $queue_name; |
52 |
|
} |
53 |
|
|
54 |
|
/** |
55 |
|
* Publish event to queue. |
src/Queue/Subscribe/PredisSubscribeEventQueue.php 1 location
|
@@ 56-66 (lines=11) @@
|
53 |
|
* @param LoggerInterface $logger |
54 |
|
* @param string $queue_name |
55 |
|
*/ |
56 |
|
public function __construct( |
57 |
|
RedisPubSubAdapter $client, |
58 |
|
Serializer $serializer, |
59 |
|
LoggerInterface $logger, |
60 |
|
$queue_name |
61 |
|
) { |
62 |
|
$this->client = $client; |
63 |
|
$this->serializer = $serializer; |
64 |
|
$this->logger = $logger; |
65 |
|
$this->queue_name = $queue_name; |
66 |
|
} |
67 |
|
|
68 |
|
/** |
69 |
|
* Publish event to queue. |