@@ -67,7 +67,7 @@ discard block |
||
| 67 | 67 | /** |
| 68 | 68 | * Removes the message from the queue |
| 69 | 69 | * |
| 70 | - * @param \Aimeos\MW\MQueue\Message\Iface $msg Message object |
|
| 70 | + * @param \Aimeos\MW\MQueue\Message\AMQP $msg Message object |
|
| 71 | 71 | * @throws \Aimeos\MW\MQueue\Exception |
| 72 | 72 | */ |
| 73 | 73 | public function del( \Aimeos\MW\MQueue\Message\Iface $msg ) |
@@ -83,7 +83,7 @@ discard block |
||
| 83 | 83 | /** |
| 84 | 84 | * Returns the next message from the queue |
| 85 | 85 | * |
| 86 | - * @return \Aimeos\MW\MQueue\Message\Iface|null Message object or null if none is available |
|
| 86 | + * @return \Aimeos\MW\MQueue\Message\AMQP|null Message object or null if none is available |
|
| 87 | 87 | * @throws \Aimeos\MW\MQueue\Exception |
| 88 | 88 | */ |
| 89 | 89 | public function get() |
@@ -53,7 +53,7 @@ discard block |
||
| 53 | 53 | /** |
| 54 | 54 | * Removes the message from the queue |
| 55 | 55 | * |
| 56 | - * @param \Aimeos\MW\MQueue\Message\Iface $msg Message object |
|
| 56 | + * @param \Aimeos\MW\MQueue\Message\Stomp $msg Message object |
|
| 57 | 57 | * @throws \Aimeos\MW\MQueue\Exception |
| 58 | 58 | */ |
| 59 | 59 | public function del( \Aimeos\MW\MQueue\Message\Iface $msg ) |
@@ -67,7 +67,7 @@ discard block |
||
| 67 | 67 | /** |
| 68 | 68 | * Returns the next message from the queue |
| 69 | 69 | * |
| 70 | - * @return \Aimeos\MW\MQueue\Message\Iface|null Message object or null if none is available |
|
| 70 | + * @return \Aimeos\MW\MQueue\Message\Stomp|null Message object or null if none is available |
|
| 71 | 71 | * @throws \Aimeos\MW\MQueue\Exception |
| 72 | 72 | */ |
| 73 | 73 | public function get() |