@@ 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 |