|
@@ -24,8 +24,9 @@ class InformConsumer implements ConsumerInterface
|
|
|
public function execute(AMQPMessage $msg)
|
|
public function execute(AMQPMessage $msg)
|
|
|
{
|
|
{
|
|
|
$data = unserialize($msg->body);
|
|
$data = unserialize($msg->body);
|
|
|
- $userType = $data['userType'];
|
|
|
|
|
print_r($data);
|
|
print_r($data);
|
|
|
|
|
+ return ConsumerInterface::MSG_ACK;
|
|
|
|
|
+ $userType = $data['userType'];
|
|
|
if ($userType == 'user') {
|
|
if ($userType == 'user') {
|
|
|
$return = InformUserService::consumeInformQueue($data);
|
|
$return = InformUserService::consumeInformQueue($data);
|
|
|
if ($return) {
|
|
if ($return) {
|
shish