改名
This commit is contained in:
@@ -32,30 +32,18 @@ class Consumer
|
|||||||
use \Psr\Log\LoggerAwareTrait;
|
use \Psr\Log\LoggerAwareTrait;
|
||||||
use \Kafka\LoggerTrait;
|
use \Kafka\LoggerTrait;
|
||||||
|
|
||||||
// {{{ consts
|
|
||||||
// }}}
|
|
||||||
// {{{ members
|
|
||||||
|
|
||||||
private $isRunning = false;
|
private $isRunning = false;
|
||||||
|
|
||||||
// }}}
|
|
||||||
// {{{ functions
|
|
||||||
// {{{ public function __construct()
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* __construct
|
* __construct
|
||||||
*
|
*
|
||||||
* @access public
|
* @access public
|
||||||
* @param $hostList
|
|
||||||
* @param null $timeout
|
|
||||||
*/
|
*/
|
||||||
public function __construct()
|
public function __construct()
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
// }}}
|
|
||||||
// {{{ public function start()
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* start consumer
|
* start consumer
|
||||||
*
|
*
|
||||||
@@ -80,7 +68,4 @@ class Consumer
|
|||||||
run();
|
run();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// }}}
|
|
||||||
// }}}
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user