php - 関数で使用できないオブジェクト

Question

MQTT ブローカーのトピックにサブスクライブするアプリケーションがあります。メッセージが受信されたら、メッセージ内のデータを処理し、別のトピックで同じブローカーに戻す必要があります。PHPMQTT のライトニング ブランチは適切に管理されているため ( github repo ) 使用しています。

私のスクリプトは次のとおりです。

<?php
require("./vendor/autoload.php");
/**
 * An example callback function that is not inline.
 * @param  \Lightning\Response $response
 */
function callbackFunction($response) {
    $topic = $response->getRoute();
    $wildcard = $response->getWildcard();
    $message = $response->getMessage();
    echo "Message recieved:\n =============\n Topic: $topic\n Wildcard: $wildcard\n Message:\n $message\n\n";
}
$host = "m21.cloudmqtt.com";
$port = 18256;
$clientID = md5(uniqid()); // use a unique client id for each connection
$username = ''; // username is optional
$password = ''; // password is optional
$mqtt = new \Lightning\App($host, $port, $clientID, $username, $password);
// Optional debugging
$mqtt->debug(true);
if (!$mqtt->connect()) {
    echo "Failed to connect\n";
    exit;
}
// Add a new subscription for each topic that is needed
$mqtt->subscribe('net/raw/#', 0, function ($response) {
    $topic = $response->getRoute();
    $message = $response->getMessage();
    $attributes = $response->getAttributes(); // Returns all the attributes received
    $id = $response->attr('id'); // Gets a specific attribute by key. Returns null if not present.
    echo "Message recieved:\n =============\n Topic: $topic\n Attribute - id: $id\n Message:\n $message\n\n";

  $topic_id = 524;
  $message = "0A";
  $mqtt->publish("test/request/yes".$topic_id, $message, 1);
});
// Callback functions can be inline or by name as a string
$mqtt->subscribe('test/request/#', 0, 'callbackFunction');
// Call listen to begin polling for messages
$mqtt->listen();
?>

「net/raw」を問題なく購読できます。加工もバッチリ。それをブローカーに公開するときに問題が発生します。18 行目で開始された接続が関数で使用できず、次のエラーが発生した場合:

注意: 未定義の変数: C:\wamp64\www\sub.php の 35 行目の mqtt

Fatal error: Uncaught Error: Call to a member function publish() on null in C:\wamp64\www\sub.php:35 スタック トレース: 0 [内部関数]: {closure}(Object(Lightning\Response)) 1 C:\wamp64\www\vendor\brandonhudson\lightning\Lightning\App.php(353): call_user_func(Object(Closure), Object(Lightning\Response)) 2 C:\wamp64\www\vendor\brandonhudson\lightning\ Lightning\App.php(424): Lightning\App->message('0A') 3 C:\wamp64\www\sub.php(40): Lightning\App->listen() 4 {main} C でスロー:\wamp64\www\sub.php 35 行目

関数内で新しい接続を作成できますが、十分なはずのときに新しい接続を開いたり閉じたりしたくありません。関数内で接続を使用できるようにするにはどうすればよいですか?