Mosquitto-PHP（MQTTクライアント）にてタイマー設定

Question

Mosquitto-PHP（MQTTクライアント）にて、通信相手に送信（Publish）したら通信相手からのデータを受ける（subscribe/onMessage）プログラムを作ってます。
送信した後に相手から受信が１０秒間なかったらタイムアウトして切断（disconnect）したいですが、どのように記載すべきでしょうか？

以下の動作は
(1)connectで接続
(2)subscribeでTopicを受信状態（onConnect内で接続されたらsubscribeしています。）
(3)publishでメッセージ送信（onSubscribe内でsubscribe完了したら送信(publish)しています。）
(4)subscribeしているTopicのメッセージを受信（onMessage内）
という感じで進めています。

(3)のpublishで通信相手（subscribe）に通信が送信しています。
(4)で通信相手がpublishしてくれたものをsubscribeで受ける処理を想定しています。
ただ、通信相手が確実に送信（Publish）してくれるかはわかりませんので10秒程度
onMessage（subscribeしているTopic）で待っているけど何も届かない場合にタイムアウトして切断（disconnect）したいと考えています。

ご教授をお願いします。

<?php

$jobType = 0;
$cliId = 'client1';

$c = new Mosquitto\Client($cliId);
$c->onConnect(function($r) use ($c) {
  echo "I got code {$r}\n";
  if ( $r == 0 ) {
    $c->subscribe('recv1', 0);            // (2)
  } else {
    echo "connectErr {$r}\n";
    $c->disconnect();
    return;
  }
});
$c->onSubscribe(function() use ($c) {
  echo "Subscribed to a topic\n";
  $jobType = 1;
  $mid = $c->publish('send1', "Hello job1", 0, false);    // (3)
  echo "Sent1 message ID: {$mid}\n";
});
$c->onMessage(function($message) use ($c) {               // (4)
  printf("Got a message ID %d on topic %s with payload:\n%s\n\n", $message->mid, $message->topic, $message->payload);
  // jobType1
  if ( $jobType == 1 && $message->payload=='OK' ) {
    $jobType = 2;
    $mid = $c->publish('send1', "Hello job2", 0, false);
    echo "Sent2 message ID: {$mid}\n";
  // jobType2
  } else if ( $jobType == 2 && $message->payload=="OK" ) {
    echo "job2 Complete!\n";
    $c->disconnect();
  // Error
  } else {
    echo "job Error [$jobType]\n";
    $c->disconnect();
    return;
  }
});

$c->connect("a.mosq.net", 1883, 60);    // (1)  60:KeepAlive
$c->loopForever();

echo "Finished\n";

Comments

[m.ts10806]

現在のコードに起きている現象・問題、その現象・問題に対してやってみたこと調べてみたことを質問に追記してください（もし次の質問との関連性があるならその旨も）

[yamayamak]

補足させて頂きましたが不明点がありましたらご連絡をお願いします。

Answer 1

loopForeverをloopにして、時間を7秒間だけメッセージを待つようにしました。

$c = new Mosquitto\Client($cliId);
$c->onConnect(function($r) use ($c) {

〜省略〜

$c->connect("a.mosq.net", 1883, 60);    // (1)  60:KeepAlive

$startTs = time();
while (1) {
  if ( ( time() - $startTs ) < 7 ) {    // 7秒間はループしてメッセージを待つ
	$c->loop();
  } else {
	break;
  }
}

echo "Finished\n";