src/ClaimCheck/Sns/SnsExtendedClient.php 1 location
|
@@ 52-63 (lines=12) @@
|
49 |
|
* @return Result |
50 |
|
* @throws ExceptionInterface |
51 |
|
*/ |
52 |
|
private function publishClaimCheck(array $args = []) |
53 |
|
{ |
54 |
|
$claimCheckSerializer = $this->configuration->getClaimCheckSerializer(); |
55 |
|
|
56 |
|
$message = array_key_exists('Message', $args) ? $args['Message'] : ''; |
57 |
|
|
58 |
|
$claimCheck = $this->storeMessageInS3($message); |
59 |
|
|
60 |
|
$args['Message'] = $claimCheckSerializer->serialize($claimCheck); |
61 |
|
|
62 |
|
return $this->snsClient->publish($args); |
63 |
|
} |
64 |
|
|
65 |
|
/** |
66 |
|
* @param string $message |
src/ClaimCheck/Sqs/SqsExtendedClient.php 1 location
|
@@ 65-76 (lines=12) @@
|
62 |
|
* @return Result |
63 |
|
* @throws ExceptionInterface |
64 |
|
*/ |
65 |
|
private function sendSqsMessage(array $args = []) |
66 |
|
{ |
67 |
|
$claimCheckSerializer = $this->configuration->getClaimCheckSerializer(); |
68 |
|
|
69 |
|
$message = array_key_exists('MessageBody', $args) ? $args['MessageBody'] : ''; |
70 |
|
|
71 |
|
$claimCheck = $this->storeMessageInS3($message); |
72 |
|
|
73 |
|
$args['MessageBody'] = $claimCheckSerializer->serialize($claimCheck); |
74 |
|
|
75 |
|
return $this->sqsClient->sendMessage($args); |
76 |
|
} |
77 |
|
|
78 |
|
/** |
79 |
|
* @param mixed[] $args |