From 1642db01f3e42150cc8026036685e62775fc18cf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=A7=A6=E8=8B=B1=E6=9D=B0?= <327782001@qq.com> Date: Fri, 26 May 2023 14:22:27 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../{OneWayProducer.java => Base_01_OneWayProducer.java} | 2 +- .../producer/{SyncProducer.java => Base_02_SyncProducer.java} | 2 +- .../producer/{AsyncProducer.java => Base_03_AsyncProducer.java} | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) rename rocketmq-demo/src/main/java/base/producer/{OneWayProducer.java => Base_01_OneWayProducer.java} (97%) rename rocketmq-demo/src/main/java/base/producer/{SyncProducer.java => Base_02_SyncProducer.java} (97%) rename rocketmq-demo/src/main/java/base/producer/{AsyncProducer.java => Base_03_AsyncProducer.java} (98%) diff --git a/rocketmq-demo/src/main/java/base/producer/OneWayProducer.java b/rocketmq-demo/src/main/java/base/producer/Base_01_OneWayProducer.java similarity index 97% rename from rocketmq-demo/src/main/java/base/producer/OneWayProducer.java rename to rocketmq-demo/src/main/java/base/producer/Base_01_OneWayProducer.java index a821da5..333a7f1 100644 --- a/rocketmq-demo/src/main/java/base/producer/OneWayProducer.java +++ b/rocketmq-demo/src/main/java/base/producer/Base_01_OneWayProducer.java @@ -14,7 +14,7 @@ import java.util.concurrent.TimeUnit; * @version : 2.2.0 * @date : 2023/5/26 14:18 */ -public class OneWayProducer { +public class Base_01_OneWayProducer { public static void main(String[] args) throws Exception, MQBrokerException { //1.创建消息生产者producer,并制定生产者组名 DefaultMQProducer producer = new DefaultMQProducer("group1"); diff --git a/rocketmq-demo/src/main/java/base/producer/SyncProducer.java b/rocketmq-demo/src/main/java/base/producer/Base_02_SyncProducer.java similarity index 97% rename from rocketmq-demo/src/main/java/base/producer/SyncProducer.java rename to rocketmq-demo/src/main/java/base/producer/Base_02_SyncProducer.java index 395696c..207c57a 100644 --- a/rocketmq-demo/src/main/java/base/producer/SyncProducer.java +++ b/rocketmq-demo/src/main/java/base/producer/Base_02_SyncProducer.java @@ -14,7 +14,7 @@ import java.util.concurrent.TimeUnit; * @version : 2.2.0 * @date : 2023/5/26 14:18 */ -public class SyncProducer { +public class Base_02_SyncProducer { public static void main(String[] args) throws Exception { //1.创建消息生产者producer,并制定生产者组名 DefaultMQProducer producer = new DefaultMQProducer("group1"); diff --git a/rocketmq-demo/src/main/java/base/producer/AsyncProducer.java b/rocketmq-demo/src/main/java/base/producer/Base_03_AsyncProducer.java similarity index 98% rename from rocketmq-demo/src/main/java/base/producer/AsyncProducer.java rename to rocketmq-demo/src/main/java/base/producer/Base_03_AsyncProducer.java index 2c54e77..c388d25 100644 --- a/rocketmq-demo/src/main/java/base/producer/AsyncProducer.java +++ b/rocketmq-demo/src/main/java/base/producer/Base_03_AsyncProducer.java @@ -15,7 +15,7 @@ import java.util.concurrent.TimeUnit; * @version : 2.2.0 * @date : 2023/5/26 14:17 */ -public class AsyncProducer { +public class Base_03_AsyncProducer { public static void main(String[] args) throws Exception { //1.创建消息生产者producer,并制定生产者组名 DefaultMQProducer producer = new DefaultMQProducer("group1"); -- GitLab