Skip to content

Commit fb39f75

Browse files
add updates
1 parent e535efe commit fb39f75

4 files changed

Lines changed: 1456 additions & 0 deletions

File tree

src/Rocketmq/ChangeLog.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
2023-8-15 version: 1.0.0
2+
1. rocketmq

src/Rocketmq/RocketmqClient.php

Lines changed: 90 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,90 @@
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+
}

src/data/manifest.json.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -193,6 +193,10 @@
193193
'namespace' => 'Detection',
194194
'versions' => [ 'latest' => 'v3', ],
195195
],
196+
'rocketmq' => [
197+
'namespace' => 'Rocketmq',
198+
'versions' => [ 'latest' => 'v1', ],
199+
],
196200
'renewal' => [
197201
'namespace' => 'Renewal',
198202
'versions' => [ 'latest' => 'v2', ],

0 commit comments

Comments
 (0)