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