@@ -78,6 +78,9 @@ |
||
78 | 78 | return $this->channel; |
79 | 79 | } |
80 | 80 | |
81 | + /** |
|
82 | + * @param EventInterface $event |
|
83 | + */ |
|
81 | 84 | private function createMessage($event): AMQPMessage |
82 | 85 | { |
83 | 86 | if (!$event instanceof \JsonSerializable) { |
@@ -78,6 +78,9 @@ |
||
78 | 78 | return $this->channel; |
79 | 79 | } |
80 | 80 | |
81 | + /** |
|
82 | + * @param EventInterface $event |
|
83 | + */ |
|
81 | 84 | private function createMessage($event): AMQPMessage |
82 | 85 | { |
83 | 86 | if (!$event instanceof \JsonSerializable) { |
@@ -63,6 +63,9 @@ |
||
63 | 63 | ]); |
64 | 64 | } |
65 | 65 | |
66 | + /** |
|
67 | + * @param string $path |
|
68 | + */ |
|
66 | 69 | public static function requestHiam($path, $data) |
67 | 70 | { |
68 | 71 | $scheme = 'https'; |
@@ -26,6 +26,9 @@ |
||
26 | 26 | return $this->getRepository($command)->findOneOrFail($this->buildSpecification($command)); |
27 | 27 | } |
28 | 28 | |
29 | + /** |
|
30 | + * @return Specification |
|
31 | + */ |
|
29 | 32 | protected function buildSpecification(EntityCommandInterface $command) |
30 | 33 | { |
31 | 34 | return $this->createSpecification()->where(['id' => $command->id])->limit(1); |