1+ <?php
2+ /**
3+ * Rocketmq
4+ *
5+ * @category Jdcloud
6+ * @package Jdcloud\Rocketmq
7+ * @author Jdcloud <jdcloud-api@jd.com>
8+ * @license Apache-2.0 http://www.apache.org/licenses/LICENSE-2.0
9+ * @link https://www.jdcloud.com/help/faq
10+ */
11+
12+ namespace Jdcloud \Rocketmq ;
13+
14+ use Jdcloud \JdCloudClient ;
15+ use Jdcloud \Api \Service ;
16+ use Jdcloud \Api \DocModel ;
17+ use Jdcloud \Api \ApiProvider ;
18+ use Jdcloud \PresignUrlMiddleware ;
19+
20+ /**
21+ * Client used to interact with rocketmq.
22+ *
23+ * @method \Jdcloud\Result describeConsumerGroups(array $args = [])
24+ * @method \GuzzleHttp\Promise\Promise describeConsumerGroupsAsync(array $args = [])
25+ * @method \Jdcloud\Result createConsumerGroup(array $args = [])
26+ * @method \GuzzleHttp\Promise\Promise createConsumerGroupAsync(array $args = [])
27+ * @method \Jdcloud\Result updateConsumerGroup(array $args = [])
28+ * @method \GuzzleHttp\Promise\Promise updateConsumerGroupAsync(array $args = [])
29+ * @method \Jdcloud\Result describeConsumerGroupNames(array $args = [])
30+ * @method \GuzzleHttp\Promise\Promise describeConsumerGroupNamesAsync(array $args = [])
31+ * @method \Jdcloud\Result deleteConsumerGroup(array $args = [])
32+ * @method \GuzzleHttp\Promise\Promise deleteConsumerGroupAsync(array $args = [])
33+ * @method \Jdcloud\Result describeConsumerAllTopics(array $args = [])
34+ * @method \GuzzleHttp\Promise\Promise describeConsumerAllTopicsAsync(array $args = [])
35+ * @method \Jdcloud\Result describeConsumerGroupStatus(array $args = [])
36+ * @method \GuzzleHttp\Promise\Promise describeConsumerGroupStatusAsync(array $args = [])
37+ * @method \Jdcloud\Result describeConsumerSubTopics(array $args = [])
38+ * @method \GuzzleHttp\Promise\Promise describeConsumerSubTopicsAsync(array $args = [])
39+ * @method \Jdcloud\Result resetOffset(array $args = [])
40+ * @method \GuzzleHttp\Promise\Promise resetOffsetAsync(array $args = [])
41+ * @method \Jdcloud\Result describeMessages(array $args = [])
42+ * @method \GuzzleHttp\Promise\Promise describeMessagesAsync(array $args = [])
43+ * @method \Jdcloud\Result sendMessage(array $args = [])
44+ * @method \GuzzleHttp\Promise\Promise sendMessageAsync(array $args = [])
45+ * @method \Jdcloud\Result describeMessageByMsgId(array $args = [])
46+ * @method \GuzzleHttp\Promise\Promise describeMessageByMsgIdAsync(array $args = [])
47+ * @method \Jdcloud\Result describeProduceTrace(array $args = [])
48+ * @method \GuzzleHttp\Promise\Promise describeProduceTraceAsync(array $args = [])
49+ * @method \Jdcloud\Result describeConsumeTrace(array $args = [])
50+ * @method \GuzzleHttp\Promise\Promise describeConsumeTraceAsync(array $args = [])
51+ * @method \Jdcloud\Result describeConsumeTraceDetail(array $args = [])
52+ * @method \GuzzleHttp\Promise\Promise describeConsumeTraceDetailAsync(array $args = [])
53+ * @method \Jdcloud\Result describeTopics(array $args = [])
54+ * @method \GuzzleHttp\Promise\Promise describeTopicsAsync(array $args = [])
55+ * @method \Jdcloud\Result createTopic(array $args = [])
56+ * @method \GuzzleHttp\Promise\Promise createTopicAsync(array $args = [])
57+ * @method \Jdcloud\Result describeTopicNames(array $args = [])
58+ * @method \GuzzleHttp\Promise\Promise describeTopicNamesAsync(array $args = [])
59+ * @method \Jdcloud\Result describeTopic(array $args = [])
60+ * @method \GuzzleHttp\Promise\Promise describeTopicAsync(array $args = [])
61+ * @method \Jdcloud\Result updateTopicDescription(array $args = [])
62+ * @method \GuzzleHttp\Promise\Promise updateTopicDescriptionAsync(array $args = [])
63+ * @method \Jdcloud\Result deleteTopic(array $args = [])
64+ * @method \GuzzleHttp\Promise\Promise deleteTopicAsync(array $args = [])
65+ * @method \Jdcloud\Result describeConsumersByTopic(array $args = [])
66+ * @method \GuzzleHttp\Promise\Promise describeConsumersByTopicAsync(array $args = [])
67+ */
68+ class RocketmqClient extends JdCloudClient
69+ {
70+ public function __construct (array $ args )
71+ {
72+ $ args ['with_resolved ' ] = function (array $ args ) {
73+ $ this ->getHandlerList ()->appendInit (
74+ PresignUrlMiddleware::wrap (
75+ $ this ,
76+ $ args ['endpoint_provider ' ],
77+ [
78+ 'operations ' => [
79+ ],
80+ 'service ' => 'rocketmq ' ,
81+ 'presign_param ' => 'PresignedUrl ' ,
82+ ]
83+ ),
84+ 'rocketmq '
85+ );
86+ };
87+
88+ parent ::__construct ($ args );
89+ }
90+ }
0 commit comments