|
@@ 47-49 (lines=3) @@
|
| 44 |
|
|
| 45 |
|
try{ |
| 46 |
|
|
| 47 |
|
if (!isset($message['Body'])) { |
| 48 |
|
throw new InvalidJSONMessageException('Undefined index key Body: ' . print_r($message, true)); |
| 49 |
|
} |
| 50 |
|
|
| 51 |
|
$body = json_decode($message['Body'], true); |
| 52 |
|
|
|
@@ 53-55 (lines=3) @@
|
| 50 |
|
|
| 51 |
|
$body = json_decode($message['Body'], true); |
| 52 |
|
|
| 53 |
|
if (!isset($body['Message'])) { |
| 54 |
|
throw new InvalidJSONMessageException('Undefined index key Message: ' . print_r($body, true)); |
| 55 |
|
} |
| 56 |
|
|
| 57 |
|
return call_user_func($this->callback, $this->jsonMessageFactory->create($body['Message'])); |
| 58 |
|
|