5151 */
5252class AMQP extends Module implements RequiresPackage
5353{
54- /**
55- * @var array
56- */
57- protected $ config = [
54+ protected array $ config = [
5855 'host ' => 'localhost ' ,
5956 'username ' => 'guest ' ,
6057 'password ' => 'guest ' ,
@@ -72,14 +69,14 @@ class AMQP extends Module implements RequiresPackage
7269 /**
7370 * @var string[]
7471 */
75- protected $ requiredFields = ['host ' , 'username ' , 'password ' , 'vhost ' ];
72+ protected array $ requiredFields = ['host ' , 'username ' , 'password ' , 'vhost ' ];
7673
77- public function _requires ()
74+ public function _requires (): array
7875 {
7976 return [AMQPStreamConnection::class => '"php-amqplib/php-amqplib": "~2.4" ' ];
8077 }
8178
82- public function _initialize ()
79+ public function _initialize (): void
8380 {
8481 $ host = $ this ->config ['host ' ];
8582 $ port = $ this ->config ['port ' ];
@@ -94,7 +91,7 @@ public function _initialize()
9491 }
9592 }
9693
97- public function _before (TestInterface $ test )
94+ public function _before (TestInterface $ test ): void
9895 {
9996 if ($ this ->config ['cleanup ' ]) {
10097 $ this ->cleanup ();
@@ -111,10 +108,8 @@ public function _before(TestInterface $test)
111108 * $I->pushToExchange('exchange.emails', new AMQPMessage('Thanks!'));
112109 * $I->pushToExchange('exchange.emails', new AMQPMessage('Thanks!'), 'severity');
113110 * ```
114- *
115- * @param string|AMQPMessage $message
116111 */
117- public function pushToExchange (string $ exchange , $ message , string $ routing_key = null ): void
112+ public function pushToExchange (string $ exchange , string | AMQPMessage $ message , string $ routing_key = null ): void
118113 {
119114 $ message = $ message instanceof AMQPMessage
120115 ? $ message
@@ -130,10 +125,8 @@ public function pushToExchange(string $exchange, $message, string $routing_key =
130125 * $I->pushToQueue('queue.jobs', 'create user');
131126 * $I->pushToQueue('queue.jobs', new AMQPMessage('create'));
132127 * ```
133- *
134- * @param string|AMQPMessage $message
135128 */
136- public function pushToQueue (string $ queue , $ message ): void
129+ public function pushToQueue (string $ queue , string | AMQPMessage $ message ): void
137130 {
138131 $ message = $ message instanceof AMQPMessage
139132 ? $ message
0 commit comments