Broken pipe or closed connection

[yuebin1009]

code:
Tail::listen($queue, function($message) use ($callbackClass, $callbackFunc) {
call_user_func([$callbackClass, $callbackFunc], $message);
});

exception:
Broken pipe or closed connection {"exception":"[object] (PhpAmqpLib\Exception\AMQPRuntimeException(code: 0): Broken pipe or closed connection at /srv/deploy/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Wire/IO/StreamIO.php:214)