This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-schema-registry.git
The following commit(s) were added to refs/heads/main by this push:
new 886b6ec release 1.0.0 (#70)
886b6ec is described below
commit 886b6ec01bed65636829777abacc5ab148c817cc
Author: HuiTong <[email protected]>
AuthorDate: Fri Oct 7 08:18:07 2022 +0800
release 1.0.0 (#70)
---
client/pom.xml | 2 +-
common/pom.xml | 2 +-
core/pom.xml | 2 +-
example/pom.xml | 2 +-
pom.xml | 2 +-
storage-rocketmq/pom.xml | 2 +-
.../schema/registry/storage/rocketmq/RocketmqClient.java | 13 +++++++------
war/pom.xml | 2 +-
8 files changed, 14 insertions(+), 13 deletions(-)
diff --git a/client/pom.xml b/client/pom.xml
index 44ae748..300d7d4 100644
--- a/client/pom.xml
+++ b/client/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>rocketmq-schema-registry-all</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>0.0.5-SNAPSHOT</version>
+ <version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/common/pom.xml b/common/pom.xml
index 198f15d..f5940a1 100644
--- a/common/pom.xml
+++ b/common/pom.xml
@@ -22,7 +22,7 @@
<parent>
<artifactId>rocketmq-schema-registry-all</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>0.0.5-SNAPSHOT</version>
+ <version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/core/pom.xml b/core/pom.xml
index 4f43656..7014d7b 100644
--- a/core/pom.xml
+++ b/core/pom.xml
@@ -22,7 +22,7 @@
<parent>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-schema-registry-all</artifactId>
- <version>0.0.5-SNAPSHOT</version>
+ <version>1.0.0</version>
</parent>
<packaging>jar</packaging>
diff --git a/example/pom.xml b/example/pom.xml
index 2930a0c..dfbe15a 100644
--- a/example/pom.xml
+++ b/example/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>rocketmq-schema-registry-all</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>0.0.5-SNAPSHOT</version>
+ <version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git a/pom.xml b/pom.xml
index e035bde..52460cd 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-schema-registry-all</artifactId>
- <version>0.0.5-SNAPSHOT</version>
+ <version>1.0.0</version>
<packaging>pom</packaging>
<description>rocketmq-schema-registry</description>
diff --git a/storage-rocketmq/pom.xml b/storage-rocketmq/pom.xml
index 9cccc78..31ab4e2 100644
--- a/storage-rocketmq/pom.xml
+++ b/storage-rocketmq/pom.xml
@@ -22,7 +22,7 @@
<parent>
<artifactId>rocketmq-schema-registry-all</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>0.0.5-SNAPSHOT</version>
+ <version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
diff --git
a/storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java
b/storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java
index 7eb90ae..1f5e252 100644
---
a/storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java
+++
b/storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java
@@ -85,7 +85,7 @@ import static
org.apache.rocketmq.schema.registry.storage.rocketmq.configs.Rocke
public class RocketmqClient {
private DefaultMQProducer producer;
- private DefaultMQPushConsumer scheduleConsumer;
+ private DefaultMQPushConsumer consumer;
private DefaultMQAdminExt mqAdminExt;
private String storageTopic;
private boolean useCompactTopic;
@@ -197,9 +197,10 @@ public class RocketmqClient {
try {
producer.start();
- scheduleConsumer.subscribe(storageTopic, "*");
- scheduleConsumer.registerMessageListener(new MessageListener());
- scheduleConsumer.start();
+ consumer.subscribe(storageTopic, "*");
+ consumer.registerMessageListener(new MessageListener());
+ consumer.start();
+ log.info("push consumer for local cache start, gid={}",
consumer.getConsumerGroup());
} catch (MQClientException e) {
throw new SchemaException("Rocketmq client start failed", e);
}
@@ -459,11 +460,11 @@ public class RocketmqClient {
props.getProperty(STORAGE_ROCKETMQ_NAMESRV,
STORAGE_ROCKETMQ_NAMESRV_DEFAULT)
);
- this.scheduleConsumer = new DefaultMQPushConsumer(
+ this.consumer = new DefaultMQPushConsumer(
props.getProperty(STORAGE_ROCKETMQ_CONSUMER_GROUP,
STORAGE_ROCKETMQ_CONSUMER_GROUP_DEFAULT)
);
- this.scheduleConsumer.setNamesrvAddr(
+ this.consumer.setNamesrvAddr(
props.getProperty(STORAGE_ROCKETMQ_NAMESRV,
STORAGE_ROCKETMQ_NAMESRV_DEFAULT)
);
diff --git a/war/pom.xml b/war/pom.xml
index d49b5c3..251743d 100644
--- a/war/pom.xml
+++ b/war/pom.xml
@@ -22,7 +22,7 @@
<parent>
<artifactId>rocketmq-schema-registry-all</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>0.0.5-SNAPSHOT</version>
+ <version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
