\App\System\Queue\ConsumerMessageConsumer

后台内部消息队列消费处理 _Consumer(exchange="mineadmin", routingKey="message.routing", queue="message.queue", name="message.queue", nums=1)

Summary

Methods
Properties
Constants
consumeMessage()
isEnable()
No public properties found
No constants found
No protected methods found
$service
N/A
No private methods found
No private properties found
N/A

Properties

Methods

consumeMessage()

consumeMessage(  $data, \PhpAmqpLib\Message\AMQPMessage  $message) 

Parameters

$data
\PhpAmqpLib\Message\AMQPMessage $message

isEnable()

isEnable() : boolean

设置是否启动amqp

Returns

boolean