@@ -72,7 +72,7 @@  | 
                                                    ||
| 72 | 72 | /**  | 
                                                        
| 73 | 73 | * Decode the message and return array  | 
                                                        
| 74 | 74 | *  | 
                                                        
| 75 | - * @param $message  | 
                                                        |
| 75 | + * @param AMQPMessage $message  | 
                                                        |
| 76 | 76 | * @return array  | 
                                                        
| 77 | 77 | */  | 
                                                        
| 78 | 78 | private function decodeQueueMessage($message)  |