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 a821da59aff098d923d30c8366c00e860301d20c..333a7f1e4c5ba220cbabf42de15947aa6b5df695 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 395696cc580cbb0659ed3990c3187edef3d077f0..207c57a5af7e4c02e846601877cf04e5df5d6cd4 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 2c54e77cf5dc735d4e143b68e914d9afd5ec2e4c..c388d25a29af199456827b0012466f4f9588c10e 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");