@@ -67,8 +67,8 @@ public function testWaitForMessages()
67
67
{
68
68
$ this ->assertArraySubset (['queue ' => ['consumers_wait_for_messages ' => 1 ]], $ this ->config );
69
69
70
- foreach ($ this ->messages as $ msg ) {
71
- $ this ->publishMessage ($ msg );
70
+ foreach ($ this ->messages as $ message ) {
71
+ $ this ->publishMessage ($ message );
72
72
}
73
73
74
74
$ this ->waitForAsynchronousResult (count ($ this ->messages ), $ this ->logFilePath );
@@ -94,8 +94,8 @@ public function testNotWaitForMessages(): void
94
94
$ this ->writeConfig ($ config );
95
95
96
96
$ this ->assertArraySubset (['queue ' => ['consumers_wait_for_messages ' => 0 ]], $ this ->loadConfig ());
97
- foreach ($ this ->messages as $ msg ) {
98
- $ this ->publishMessage ($ msg );
97
+ foreach ($ this ->messages as $ message ) {
98
+ $ this ->publishMessage ($ message );
99
99
}
100
100
101
101
$ this ->publisherConsumerController ->startConsumers ();
@@ -113,11 +113,11 @@ public function testNotWaitForMessages(): void
113
113
}
114
114
115
115
/**
116
- * @param string $msg
116
+ * @param string $message
117
117
*/
118
- private function publishMessage (string $ msg ): void
118
+ private function publishMessage (string $ message ): void
119
119
{
120
- $ this ->msgObject ->setValue ($ msg );
120
+ $ this ->msgObject ->setValue ($ message );
121
121
$ this ->msgObject ->setTextFilePath ($ this ->logFilePath );
122
122
$ this ->publisher ->publish ('multi.topic.queue.topic.c ' , $ this ->msgObject );
123
123
}
0 commit comments