|
|
@ -14,9 +14,9 @@ use Hyperf\DbConnection\Db; |
|
|
use PhpAmqpLib\Message\AMQPMessage; |
|
|
use PhpAmqpLib\Message\AMQPMessage; |
|
|
use Hyperf\Di\Annotation\Inject; |
|
|
use Hyperf\Di\Annotation\Inject; |
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* @Consumer(exchange="devicOrder", routingKey="devicOrder", queue="devicOrder", nums=4) |
|
|
|
|
|
*/ |
|
|
|
|
|
|
|
|
// /**
|
|
|
|
|
|
// * @Consumer(exchange="devicOrder", routingKey="devicOrder", queue="devicOrder", nums=4)
|
|
|
|
|
|
// */
|
|
|
class DevicOrderConsumer extends ConsumerMessage |
|
|
class DevicOrderConsumer extends ConsumerMessage |
|
|
{ |
|
|
{ |
|
|
/** |
|
|
/** |
|
|
|