@@ -15,6 +15,10 @@ discard block |
||
15 | 15 | // boolean, whether the message body will be encoded in base64 |
16 | 16 | private $base64; |
17 | 17 | |
18 | + /** |
|
19 | + * @param string $messageBody |
|
20 | + * @param integer $delaySeconds |
|
21 | + */ |
|
18 | 22 | public function __construct($messageBody, $delaySeconds = NULL, $priority = NULL, $base64 = TRUE) |
19 | 23 | { |
20 | 24 | parent::__construct('post', NULL); |
@@ -26,6 +30,9 @@ discard block |
||
26 | 30 | $this->base64 = $base64; |
27 | 31 | } |
28 | 32 | |
33 | + /** |
|
34 | + * @param boolean $base64 |
|
35 | + */ |
|
29 | 36 | public function setBase64($base64) |
30 | 37 | { |
31 | 38 | $this->base64 = $base64; |
@@ -3,7 +3,6 @@ |
||
3 | 3 | |
4 | 4 | use AliyunMNS\Constants; |
5 | 5 | use AliyunMNS\Requests\BaseRequest; |
6 | -use AliyunMNS\Model\QueueAttributes; |
|
7 | 6 | use AliyunMNS\Traits\MessagePropertiesForSend; |
8 | 7 | |
9 | 8 | class SendMessageRequest extends BaseRequest |
@@ -59,6 +59,9 @@ discard block |
||
59 | 59 | } |
60 | 60 | } |
61 | 61 | |
62 | + /** |
|
63 | + * @param \XMLReader $xmlReader |
|
64 | + */ |
|
62 | 65 | private function parseBatchDeleteErrorResponse($xmlReader) |
63 | 66 | { |
64 | 67 | $ex = new BatchDeleteFailException($this->statusCode, "BatchDeleteMessage Failed For Some ReceiptHandles"); |
@@ -71,6 +74,9 @@ discard block |
||
71 | 74 | throw $ex; |
72 | 75 | } |
73 | 76 | |
77 | + /** |
|
78 | + * @param \XMLReader $xmlReader |
|
79 | + */ |
|
74 | 80 | private function parseNormalErrorResponse($xmlReader) |
75 | 81 | { |
76 | 82 | $result = XMLParser::parseNormalError($xmlReader); |
@@ -83,6 +83,9 @@ discard block |
||
83 | 83 | } |
84 | 84 | } |
85 | 85 | |
86 | + /** |
|
87 | + * @param \XMLReader $xmlReader |
|
88 | + */ |
|
86 | 89 | private function parseBatchSendErrorResponse($xmlReader) |
87 | 90 | { |
88 | 91 | $ex = new BatchSendFailException($this->statusCode, "BatchSendMessage Failed For Some Messages"); |
@@ -95,6 +98,9 @@ discard block |
||
95 | 98 | throw $ex; |
96 | 99 | } |
97 | 100 | |
101 | + /** |
|
102 | + * @param \XMLReader $xmlReader |
|
103 | + */ |
|
98 | 104 | private function parseNormalErrorResponse($xmlReader) |
99 | 105 | { |
100 | 106 | $result = XMLParser::parseNormalError($xmlReader); |
@@ -10,7 +10,6 @@ |
||
10 | 10 | use AliyunMNS\Responses\BaseResponse; |
11 | 11 | use AliyunMNS\Common\XMLParser; |
12 | 12 | use AliyunMNS\Model\SendMessageResponseItem; |
13 | -use AliyunMNS\Traits\MessageIdAndMD5; |
|
14 | 13 | |
15 | 14 | class BatchSendMessageResponse extends BaseResponse |
16 | 15 | { |
@@ -5,7 +5,6 @@ |
||
5 | 5 | use AliyunMNS\Model\QueueAttributes; |
6 | 6 | use AliyunMNS\Exception\MnsException; |
7 | 7 | use AliyunMNS\Exception\QueueNotExistException; |
8 | -use AliyunMNS\Exception\InvalidArgumentException; |
|
9 | 8 | use AliyunMNS\Responses\BaseResponse; |
10 | 9 | use AliyunMNS\Common\XMLParser; |
11 | 10 |
@@ -73,6 +73,9 @@ |
||
73 | 73 | } |
74 | 74 | } |
75 | 75 | |
76 | + /** |
|
77 | + * @param string $queueURL |
|
78 | + */ |
|
76 | 79 | private function getQueueNameFromQueueURL($queueURL) |
77 | 80 | { |
78 | 81 | $pieces = explode("/", $queueURL); |
@@ -77,6 +77,9 @@ |
||
77 | 77 | } |
78 | 78 | } |
79 | 79 | |
80 | + /** |
|
81 | + * @param string $subscriptionURL |
|
82 | + */ |
|
80 | 83 | private function getSubscriptionNameFromSubscriptionURL($subscriptionURL) |
81 | 84 | { |
82 | 85 | $pieces = explode("/", $subscriptionURL); |
@@ -78,6 +78,9 @@ |
||
78 | 78 | } |
79 | 79 | } |
80 | 80 | |
81 | + /** |
|
82 | + * @param string $topicURL |
|
83 | + */ |
|
81 | 84 | private function getTopicNameFromTopicURL($topicURL) |
82 | 85 | { |
83 | 86 | $pieces = explode("/", $topicURL); |
@@ -3,7 +3,6 @@ |
||
3 | 3 | |
4 | 4 | use GuzzleHttp\Promise\PromiseInterface; |
5 | 5 | use AliyunMNS\Responses\BaseResponse; |
6 | -use AliyunMNS\Exception\MnsException; |
|
7 | 6 | use GuzzleHttp\Exception\TransferException; |
8 | 7 | use Psr\Http\Message\ResponseInterface; |
9 | 8 |
@@ -2,7 +2,6 @@ |
||
2 | 2 | namespace AliyunMNS; |
3 | 3 | |
4 | 4 | use AliyunMNS\Http\HttpClient; |
5 | -use AliyunMNS\AsyncCallback; |
|
6 | 5 | use AliyunMNS\Model\TopicAttributes; |
7 | 6 | use AliyunMNS\Model\SubscriptionAttributes; |
8 | 7 | use AliyunMNS\Model\UpdateSubscriptionAttributes; |