请问这个跟swoole怎么结合使用？

[kirachen1991]

go( function() use ( &$consumer, &$messages ){
$consumer->start( function( $topic, $part, $message ) use ( &$messages ){
// 完全不会收到任何的message
if( isset( $messages[ $topic ] ) ){
$messages[ $topic ][] = $message;
}else{
Log::error([
$topic, $part, $message
]);
}
});
});