请问这个跟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 ]); } }); });