We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a345de8 commit 054699cCopy full SHA for 054699c
php-amqp/new_task.php
@@ -35,6 +35,6 @@
35
$exchange = new AMQPExchange($channel);
36
$exchange->publish($message, $routing_key);
37
38
-echo " [x] Sent {$data}", PHP_EOL;
+echo " [x] Sent {$message}", PHP_EOL;
39
40
$connection->disconnect();
php-amqp/worker.php
@@ -15,7 +15,7 @@
15
16
$callback_func = function(AMQPEnvelope $message, AMQPQueue $q) use (&$max_jobs) {
17
echo " [x] Received: ", $message->getBody(), PHP_EOL;
18
- sleep(1);
+ sleep(sleep(substr_count($message->getBody(), '.')));
19
echo " [X] Done", PHP_EOL;
20
$q->ack($message->getDeliveryTag());
21
};
0 commit comments