From 9a46ec4d65317a31924069fb2ac1a2f71a943cb2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kevin=C2=B7King?= <841156602@qq.com> Date: Mon, 30 Jan 2023 00:00:39 +0800 Subject: [PATCH 01/16] =?UTF-8?q?=E7=88=B6=E9=A1=B9=E7=9B=AE=E5=8D=87?= =?UTF-8?q?=E7=BA=A7=E4=B8=BA1.1.0=E7=89=88=E6=9C=AC=EF=BC=8C=E5=8D=87?= =?UTF-8?q?=E7=BA=A7spring=20boot=20=20&=20spring=20cloud=20=E6=9C=80?= =?UTF-8?q?=E6=96=B0=E7=89=88=E6=9C=AC=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/workflow/SecurityConfiguration.java | 38 +-- .../com/workflow/model/dto/TaskParamDto.java | 3 +- .../main/java/com/chat/vo/InviteInfoVo.java | 3 +- .../java/com/chat/vo/LoginUserInfoVo.java | 3 +- .../java/com/chat/vo/RegisterUserInfoVo.java | 3 +- .../file/controller/DownloadController.java | 6 +- .../example/web/OrderRocketController.java | 2 +- .../springdemo/mybatis/CodeGenerator.java | 236 +++++++++--------- pom.xml | 8 +- .../com/gateway/GatewayServerApplication.java | 4 +- .../HystrixDashboardServerApplication.java | 4 +- .../main/java/com/order/OrderApplication.java | 5 +- .../system-server/system-server-web/pom.xml | 8 +- .../java/com/system/SystemApplication.java | 2 - .../TurbineStreamServerApplication.java | 4 +- spring-cloud-learn/user-server/pom.xml | 20 +- .../main/java/com/user/UserApplication.java | 3 +- .../com/user/controller/TestController.java | 18 ++ .../account/test/service/UserServiceTest.java | 12 +- .../java/com/gateway/GatewayApplication.java | 107 ++++---- .../java/com/account/AccountApplication.java | 2 - .../business/app/BusinessAppApplication.java | 4 +- .../config/DataSourceProxyConfiguration.java | 8 +- .../main/java/com/order/OrderApplication.java | 2 - .../java/com/storage/StorageApplication.java | 2 - .../com/elastic/config/RestClientConfig.java | 4 +- .../elastic/controller/DataController.java | 2 + .../multidb/config/OrderDbConfiguration.java | 3 +- .../multidb/config/UserDbConfiguration.java | 3 +- 29 files changed, 272 insertions(+), 247 deletions(-) diff --git a/activiti-sample/src/main/java/com/workflow/SecurityConfiguration.java b/activiti-sample/src/main/java/com/workflow/SecurityConfiguration.java index 27c1866..61a4dc1 100644 --- a/activiti-sample/src/main/java/com/workflow/SecurityConfiguration.java +++ b/activiti-sample/src/main/java/com/workflow/SecurityConfiguration.java @@ -1,19 +1,19 @@ -package com.workflow; - -import org.springframework.context.annotation.Configuration; -import org.springframework.security.config.annotation.web.builders.WebSecurity; -import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity; -import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter; -import org.springframework.stereotype.Component; - -@Configuration -@Component -@EnableWebSecurity -public class SecurityConfiguration extends WebSecurityConfigurerAdapter { - - @Override - public void configure(WebSecurity web) throws Exception { - web.ignoring().antMatchers("/**"); - } - -} +//package com.workflow; +// +//import org.springframework.context.annotation.Configuration; +//import org.springframework.security.config.annotation.web.builders.WebSecurity; +//import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity; +//import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter; +//import org.springframework.stereotype.Component; +// +//@Configuration +//@Component +//@EnableWebSecurity +//public class SecurityConfiguration extends WebSecurityConfigurerAdapter { +// +// @Override +// public void configure(WebSecurity web) throws Exception { +// web.ignoring().antMatchers("/**"); +// } +// +//} diff --git a/activiti-sample/src/main/java/com/workflow/model/dto/TaskParamDto.java b/activiti-sample/src/main/java/com/workflow/model/dto/TaskParamDto.java index c8d5bb0..f91e9bf 100644 --- a/activiti-sample/src/main/java/com/workflow/model/dto/TaskParamDto.java +++ b/activiti-sample/src/main/java/com/workflow/model/dto/TaskParamDto.java @@ -1,8 +1,9 @@ package com.workflow.model.dto; +import jakarta.validation.constraints.NotEmpty; import lombok.Data; -import javax.validation.constraints.NotEmpty; +//import javax.validation.constraints.NotEmpty; /** * 待办、已办列表入参 diff --git a/chat/src/main/java/com/chat/vo/InviteInfoVo.java b/chat/src/main/java/com/chat/vo/InviteInfoVo.java index 1e18079..b12edd3 100644 --- a/chat/src/main/java/com/chat/vo/InviteInfoVo.java +++ b/chat/src/main/java/com/chat/vo/InviteInfoVo.java @@ -1,8 +1,9 @@ package com.chat.vo; +import jakarta.validation.constraints.NotEmpty; import lombok.Data; -import javax.validation.constraints.NotEmpty; +//import javax.validation.constraints.NotEmpty; /** * 发送邀请用户信息实体 diff --git a/chat/src/main/java/com/chat/vo/LoginUserInfoVo.java b/chat/src/main/java/com/chat/vo/LoginUserInfoVo.java index 3b9d31d..0217ada 100644 --- a/chat/src/main/java/com/chat/vo/LoginUserInfoVo.java +++ b/chat/src/main/java/com/chat/vo/LoginUserInfoVo.java @@ -1,8 +1,9 @@ package com.chat.vo; +import jakarta.validation.constraints.NotEmpty; import lombok.Data; -import javax.validation.constraints.NotEmpty; +//import javax.validation.constraints.NotEmpty; /** * 登录信息实体 diff --git a/chat/src/main/java/com/chat/vo/RegisterUserInfoVo.java b/chat/src/main/java/com/chat/vo/RegisterUserInfoVo.java index eacb0be..b2b2e88 100644 --- a/chat/src/main/java/com/chat/vo/RegisterUserInfoVo.java +++ b/chat/src/main/java/com/chat/vo/RegisterUserInfoVo.java @@ -1,8 +1,9 @@ package com.chat.vo; +import jakarta.validation.constraints.NotEmpty; import lombok.Data; -import javax.validation.constraints.NotEmpty; +//import javax.validation.constraints.NotEmpty; /** * 注册信息实体 diff --git a/file-server/src/main/java/com/file/controller/DownloadController.java b/file-server/src/main/java/com/file/controller/DownloadController.java index 290d738..03bc036 100644 --- a/file-server/src/main/java/com/file/controller/DownloadController.java +++ b/file-server/src/main/java/com/file/controller/DownloadController.java @@ -1,11 +1,13 @@ package com.file.controller; +import jakarta.servlet.http.HttpServletRequest; +import jakarta.servlet.http.HttpServletResponse; import org.apache.commons.io.IOUtils; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; +//import javax.servlet.http.HttpServletRequest; +//import javax.servlet.http.HttpServletResponse; import java.io.*; import java.net.URLEncoder; diff --git a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java b/message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java index 2919686..a95fa33 100644 --- a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java +++ b/message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java @@ -6,6 +6,7 @@ import com.rocketmq.example.vo.AccountVo; import com.saturday.common.exception.BusinessException; import com.saturday.common.model.vo.ResponseVO; import com.saturday.common.util.ResultUtils; +import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.producer.*; @@ -16,7 +17,6 @@ import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RestController; -import javax.annotation.Resource; @RestController @Slf4j diff --git a/mybatis-generator-demo/src/main/java/com/example/springdemo/mybatis/CodeGenerator.java b/mybatis-generator-demo/src/main/java/com/example/springdemo/mybatis/CodeGenerator.java index af1951b..9ae29d3 100644 --- a/mybatis-generator-demo/src/main/java/com/example/springdemo/mybatis/CodeGenerator.java +++ b/mybatis-generator-demo/src/main/java/com/example/springdemo/mybatis/CodeGenerator.java @@ -1,118 +1,118 @@ -package com.example.springdemo.mybatis; - -import com.baomidou.mybatisplus.core.exceptions.MybatisPlusException; -import com.baomidou.mybatisplus.core.toolkit.StringPool; -import com.baomidou.mybatisplus.core.toolkit.StringUtils; -import com.baomidou.mybatisplus.generator.AutoGenerator; -import com.baomidou.mybatisplus.generator.InjectionConfig; -import com.baomidou.mybatisplus.generator.config.*; -import com.baomidou.mybatisplus.generator.config.po.TableInfo; -import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy; -import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine; - -import java.util.ArrayList; -import java.util.List; -import java.util.Scanner; - -public class CodeGenerator { - - /** - *
- * 读取控制台内容 - *
- */ - public static String scanner(String tip) { - Scanner scanner = new Scanner(System.in); - StringBuilder help = new StringBuilder(); - help.append("请输入" + tip + ":"); - System.out.println(help.toString()); - if (scanner.hasNext()) { - String ipt = scanner.next(); - if (StringUtils.isNotEmpty(ipt)) { - return ipt; - } - } - throw new MybatisPlusException("请输入正确的" + tip + "!"); - } - - public static void main(String[] args) { - // 代码生成器 - AutoGenerator mpg = new AutoGenerator(); - - // 全局配置 - GlobalConfig gc = new GlobalConfig(); - String projectPath = System.getProperty("user.dir"); - gc.setOutputDir(projectPath + "/src/main/java"); - gc.setAuthor("wanggd"); - gc.setOpen(false); - // gc.setSwagger2(true); 实体属性 Swagger2 注解 - mpg.setGlobalConfig(gc); - - // 数据源配置 - DataSourceConfig dsc = new DataSourceConfig(); - dsc.setUrl("jdbc:mysql://localhost:3306/chat-app?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=UTC"); - // dsc.setSchemaName("public"); - dsc.setDriverName("com.mysql.cj.jdbc.Driver"); - dsc.setUsername("root"); - dsc.setPassword("123456"); - mpg.setDataSource(dsc); - - // 包配置 - PackageConfig pc = new PackageConfig(); - pc.setModuleName(scanner("模块名")); - pc.setParent("com"); - mpg.setPackageInfo(pc); - - // 自定义配置 - InjectionConfig cfg = new InjectionConfig() { - @Override - public void initMap() { - // to do nothing - } - }; - - // 如果模板引擎是 freemarker - String templatePath = "/templates/mapper.xml.ftl"; - // 如果模板引擎是 velocity - // String templatePath = "/templates/mapper.xml.vm"; - - // 自定义输出配置 - List+// * 读取控制台内容 +// *
+// */ +// public static String scanner(String tip) { +// Scanner scanner = new Scanner(System.in); +// StringBuilder help = new StringBuilder(); +// help.append("请输入" + tip + ":"); +// System.out.println(help.toString()); +// if (scanner.hasNext()) { +// String ipt = scanner.next(); +// if (StringUtils.isNotEmpty(ipt)) { +// return ipt; +// } +// } +// throw new MybatisPlusException("请输入正确的" + tip + "!"); +// } +// +// public static void main(String[] args) { +// // 代码生成器 +// AutoGenerator mpg = new AutoGenerator(); +// +// // 全局配置 +// GlobalConfig gc = new GlobalConfig(); +// String projectPath = System.getProperty("user.dir"); +// gc.setOutputDir(projectPath + "/src/main/java"); +// gc.setAuthor("wanggd"); +// gc.setOpen(false); +// // gc.setSwagger2(true); 实体属性 Swagger2 注解 +// mpg.setGlobalConfig(gc); +// +// // 数据源配置 +// DataSourceConfig dsc = new DataSourceConfig(); +// dsc.setUrl("jdbc:mysql://localhost:3306/chat-app?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=UTC"); +// // dsc.setSchemaName("public"); +// dsc.setDriverName("com.mysql.cj.jdbc.Driver"); +// dsc.setUsername("root"); +// dsc.setPassword("123456"); +// mpg.setDataSource(dsc); +// +// // 包配置 +// PackageConfig pc = new PackageConfig(); +// pc.setModuleName(scanner("模块名")); +// pc.setParent("com"); +// mpg.setPackageInfo(pc); +// +// // 自定义配置 +// InjectionConfig cfg = new InjectionConfig() { +// @Override +// public void initMap() { +// // to do nothing +// } +// }; +// +// // 如果模板引擎是 freemarker +// String templatePath = "/templates/mapper.xml.ftl"; +// // 如果模板引擎是 velocity +// // String templatePath = "/templates/mapper.xml.vm"; +// +// // 自定义输出配置 +// ListHello, SpringMVC
+ + + \ No newline at end of file -- Gitee From 9f8ddf092fc95b731daa87cd8a42267588e7bad4 Mon Sep 17 00:00:00 2001 From: Kevin <841156602@qq.com> Date: Sat, 6 May 2023 18:41:21 +0800 Subject: [PATCH 04/16] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E8=A1=A8?= =?UTF-8?q?=E7=BB=93=E6=9E=84=E5=86=99=E5=85=A5excel?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- common-support/pom.xml | 136 +++++++++++++++++- .../business/DatabaseExcelOperate.java | 4 + .../common/convert/entity/ColumnMetaData.java | 39 +++++ .../common/convert/entity/TableMetaData.java | 22 +++ .../com/common/convert/util/DatabaseUtil.java | 108 ++++++++++++++ .../com/common/convert/util/ExcelUtils.java | 43 ++++++ 6 files changed, 348 insertions(+), 4 deletions(-) create mode 100644 common-support/src/main/java/com/common/convert/business/DatabaseExcelOperate.java create mode 100644 common-support/src/main/java/com/common/convert/entity/ColumnMetaData.java create mode 100644 common-support/src/main/java/com/common/convert/entity/TableMetaData.java create mode 100644 common-support/src/main/java/com/common/convert/util/DatabaseUtil.java create mode 100644 common-support/src/main/java/com/common/convert/util/ExcelUtils.java diff --git a/common-support/pom.xml b/common-support/pom.xml index bb7a0fe..47b15ce 100644 --- a/common-support/pom.xml +++ b/common-support/pom.xml @@ -12,10 +12,138 @@diff --git a/message-queue-example/src/main/java/com/common/service/IOrderService.java b/message-queue-example/src/main/java/com/queue/common/service/IOrderService.java similarity index 72% rename from message-queue-example/src/main/java/com/common/service/IOrderService.java rename to message-queue-example/src/main/java/com/queue/common/service/IOrderService.java index f86b8ae..f16bf5a 100644 --- a/message-queue-example/src/main/java/com/common/service/IOrderService.java +++ b/message-queue-example/src/main/java/com/queue/common/service/IOrderService.java @@ -1,8 +1,8 @@ -package com.common.service; +package com.queue.common.service; import com.baomidou.mybatisplus.extension.service.IService; -import com.common.entity.OrderTbl; -import com.rocketmq.example.vo.OrderVo; +import com.queue.common.entity.OrderTbl; +import com.queue.rocketmq.example.vo.OrderVo; /** *
diff --git a/message-queue-example/src/main/java/com/common/service/impl/AccountServiceImpl.java b/message-queue-example/src/main/java/com/queue/common/service/impl/AccountServiceImpl.java
similarity index 87%
rename from message-queue-example/src/main/java/com/common/service/impl/AccountServiceImpl.java
rename to message-queue-example/src/main/java/com/queue/common/service/impl/AccountServiceImpl.java
index 12edfae..301613f 100644
--- a/message-queue-example/src/main/java/com/common/service/impl/AccountServiceImpl.java
+++ b/message-queue-example/src/main/java/com/queue/common/service/impl/AccountServiceImpl.java
@@ -1,10 +1,10 @@
-package com.common.service.impl;
+package com.queue.common.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.common.entity.AccountTbl;
-import com.common.mapper.AccountTblMapper;
-import com.common.service.IAccountService;
+import com.queue.common.entity.AccountTbl;
+import com.queue.common.mapper.AccountTblMapper;
+import com.queue.common.service.IAccountService;
import com.saturday.common.exception.BusinessException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
diff --git a/message-queue-example/src/main/java/com/common/service/impl/OrderServiceImpl.java b/message-queue-example/src/main/java/com/queue/common/service/impl/OrderServiceImpl.java
similarity index 84%
rename from message-queue-example/src/main/java/com/common/service/impl/OrderServiceImpl.java
rename to message-queue-example/src/main/java/com/queue/common/service/impl/OrderServiceImpl.java
index 8fb309b..6f76863 100644
--- a/message-queue-example/src/main/java/com/common/service/impl/OrderServiceImpl.java
+++ b/message-queue-example/src/main/java/com/queue/common/service/impl/OrderServiceImpl.java
@@ -1,11 +1,11 @@
-package com.common.service.impl;
+package com.queue.common.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.common.entity.OrderTbl;
-import com.common.mapper.OrderTblMapper;
-import com.common.service.IOrderService;
-import com.rocketmq.example.vo.OrderVo;
+import com.queue.common.entity.OrderTbl;
+import com.queue.common.mapper.OrderTblMapper;
+import com.queue.common.service.IOrderService;
+import com.queue.rocketmq.example.vo.OrderVo;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/Consumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/Consumer.java
similarity index 95%
rename from message-queue-example/src/main/java/com/rabbitmq/example/Consumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/Consumer.java
index 75734c1..53a4770 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/Consumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/Consumer.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example;
+package com.queue.rabbitmq.example;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/Producer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/Producer.java
similarity index 92%
rename from message-queue-example/src/main/java/com/rabbitmq/example/Producer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/Producer.java
index 293ae85..8ed8f98 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/Producer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/Producer.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example;
+package com.queue.rabbitmq.example;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/RabbitmqConfig.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/RabbitmqConfig.java
similarity index 89%
rename from message-queue-example/src/main/java/com/rabbitmq/example/RabbitmqConfig.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/RabbitmqConfig.java
index f92e355..ef9fd73 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/RabbitmqConfig.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/RabbitmqConfig.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example;
+package com.queue.rabbitmq.example;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/TestController.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/TestController.java
similarity index 93%
rename from message-queue-example/src/main/java/com/rabbitmq/example/TestController.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/TestController.java
index d838f3f..c7d62b2 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/TestController.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/TestController.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example;
+package com.queue.rabbitmq.example;
import com.saturday.common.util.ResultUtils;
import org.springframework.beans.factory.annotation.Autowired;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/ack/RabbitConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/RabbitConsumer.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rabbitmq/example/ack/RabbitConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/RabbitConsumer.java
index c18ea9a..ddf9b3a 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/ack/RabbitConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/RabbitConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.ack;
+package com.queue.rabbitmq.example.ack;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/ack/readme.txt b/message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/ack/readme.txt
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeConsumer.java
index 227048e..f1e9b25 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.backupexchange;
+package com.queue.rabbitmq.example.backupexchange;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeProducer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeProducer.java
similarity index 86%
rename from message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeProducer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeProducer.java
index 0a27719..3ffaef8 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/BackupExchangeProducer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeProducer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.backupexchange;
+package com.queue.rabbitmq.example.backupexchange;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.HashMap;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/MainExchangeConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/MainExchangeConsumer.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/MainExchangeConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/MainExchangeConsumer.java
index acce7bc..737be4b 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/MainExchangeConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/MainExchangeConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.backupexchange;
+package com.queue.rabbitmq.example.backupexchange;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/note.txt b/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/note.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/backupexchange/note.txt
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/note.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/common/Constants.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/common/Constants.java
similarity index 94%
rename from message-queue-example/src/main/java/com/rabbitmq/example/common/Constants.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/common/Constants.java
index 75ba0db..62223ad 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/common/Constants.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/common/Constants.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example.common;
+package com.queue.rabbitmq.example.common;
public class Constants {
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/common/RabbitMqUtil.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/common/RabbitMqUtil.java
similarity index 97%
rename from message-queue-example/src/main/java/com/rabbitmq/example/common/RabbitMqUtil.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/common/RabbitMqUtil.java
index f3cca88..a4e15c9 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/common/RabbitMqUtil.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/common/RabbitMqUtil.java
@@ -1,4 +1,4 @@
-package com.rabbitmq.example.common;
+package com.queue.rabbitmq.example.common;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java
index 209b99f..073e1be 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.fanout;
+package com.queue.rabbitmq.example.exchange.fanout;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java
index c6f3576..3fbffe1 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.fanout;
+package com.queue.rabbitmq.example.exchange.fanout;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java
index 3a159a9..3e57817 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.fanout;
+package com.queue.rabbitmq.example.exchange.fanout;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java
similarity index 84%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java
index b117d09..4077cd1 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.exchange.fanout;
+package com.queue.rabbitmq.example.exchange.fanout;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/readme.txt b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/readme.txt
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java
index 4e7b844..fa8c49e 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.topic;
+package com.queue.rabbitmq.example.exchange.topic;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java
index eecff5f..02f7830 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.topic;
+package com.queue.rabbitmq.example.exchange.topic;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java
index 39004cb..6687781 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.exchange.topic;
+package com.queue.rabbitmq.example.exchange.topic;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeProducer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeProducer.java
similarity index 85%
rename from message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeProducer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeProducer.java
index 1660f83..725d2d7 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/exchange/topic/TopicExchangeProducer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeProducer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.exchange.topic;
+package com.queue.rabbitmq.example.exchange.topic;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/message/Producer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/Producer.java
similarity index 86%
rename from message-queue-example/src/main/java/com/rabbitmq/example/message/Producer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/message/Producer.java
index 738897c..103358b 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/message/Producer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/Producer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.message;
+package com.queue.rabbitmq.example.message;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/message/PullConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PullConsumer.java
similarity index 89%
rename from message-queue-example/src/main/java/com/rabbitmq/example/message/PullConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PullConsumer.java
index 1bb42b2..df42da9 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/message/PullConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PullConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.message;
+package com.queue.rabbitmq.example.message;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/message/PushConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PushConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/message/PushConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PushConsumer.java
index 86a2818..a499735 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/message/PushConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PushConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.message;
+package com.queue.rabbitmq.example.message;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/message/readme.txt b/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/message/readme.txt
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/message/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitConsumer.java
index 722bee6..e16db20 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.quickstart;
+package com.queue.rabbitmq.example.quickstart;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitProducer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitProducer.java
similarity index 85%
rename from message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitProducer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitProducer.java
index 14841cc..c44ef4c 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/RabbitProducer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitProducer.java
@@ -1,11 +1,11 @@
-package com.rabbitmq.example.quickstart;
+package com.queue.rabbitmq.example.quickstart;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.MessageProperties;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/quickstart/readme.txt b/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/quickstart/readme.txt
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/reject/RabbitRejectConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/RabbitRejectConsumer.java
similarity index 92%
rename from message-queue-example/src/main/java/com/rabbitmq/example/reject/RabbitRejectConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/RabbitRejectConsumer.java
index f87d464..e9a65d1 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/reject/RabbitRejectConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/RabbitRejectConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.reject;
+package com.queue.rabbitmq.example.reject;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/reject/readme.txt b/message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/reject/readme.txt
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/readme.txt
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitConsumer.java
index 92c33f4..6af12dd 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitConsumer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.transaction;
+package com.queue.rabbitmq.example.transaction;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitProducer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitProducer.java
similarity index 88%
rename from message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitProducer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitProducer.java
index 13c47ec..b983fe4 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/transaction/RabbitProducer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitProducer.java
@@ -1,10 +1,10 @@
-package com.rabbitmq.example.transaction;
+package com.queue.rabbitmq.example.transaction;
+import com.queue.rabbitmq.example.common.Constants;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.Constants;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer.java
index d17655e..cd3a8db 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer.java
@@ -1,7 +1,7 @@
-package com.rabbitmq.example.workqueue;
+package com.queue.rabbitmq.example.workqueue;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.SneakyThrows;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer2.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer2.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer2.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer2.java
index f297baf..10e8341 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitConsumer2.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer2.java
@@ -1,7 +1,7 @@
-package com.rabbitmq.example.workqueue;
+package com.queue.rabbitmq.example.workqueue;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.rabbitmq.example.common.RabbitMqUtil;
import lombok.SneakyThrows;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitProducer.java b/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitProducer.java
similarity index 86%
rename from message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitProducer.java
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitProducer.java
index 1a04c4e..0794c66 100644
--- a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/RabbitProducer.java
+++ b/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitProducer.java
@@ -1,8 +1,8 @@
-package com.rabbitmq.example.workqueue;
+package com.queue.rabbitmq.example.workqueue;
+import com.queue.rabbitmq.example.common.RabbitMqUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/rabbitmq/example/workqueue/readme.txt b/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/rabbitmq/example/workqueue/readme.txt
rename to message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/readme.txt
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/ConsumerConfig.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/ConsumerConfig.java
similarity index 97%
rename from message-queue-example/src/main/java/com/rocketmq/example/ConsumerConfig.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/ConsumerConfig.java
index 063850d..66f0914 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/ConsumerConfig.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/ConsumerConfig.java
@@ -1,6 +1,6 @@
-package com.rocketmq.example;
+package com.queue.rocketmq.example;
-import com.rocketmq.example.consumer.RocketAccountConsumerService;
+import com.queue.rocketmq.example.consumer.RocketAccountConsumerService;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.consumer.DefaultLitePullConsumer;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/ExtRocketMqTemplate.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/ExtRocketMqTemplate.java
similarity index 100%
rename from message-queue-example/src/main/java/com/rocketmq/example/ExtRocketMqTemplate.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/ExtRocketMqTemplate.java
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/ProduceConfig.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/ProduceConfig.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rocketmq/example/ProduceConfig.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/ProduceConfig.java
index 3c6e82a..d6678e2 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/ProduceConfig.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/ProduceConfig.java
@@ -1,7 +1,7 @@
-package com.rocketmq.example;
+package com.queue.rocketmq.example;
-import com.common.service.IAccountService;
-import com.rocketmq.example.listener.AccountRocketMQTransactionLister;
+import com.queue.common.service.IAccountService;
+import com.queue.rocketmq.example.listener.AccountRocketMQTransactionLister;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/AccountConsumerService.java
similarity index 100%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/AccountConsumerService.java
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService1.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/AccountConsumerService1.java
similarity index 100%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/AccountConsumerService1.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/AccountConsumerService1.java
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/OrderConsumerService.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/OrderConsumerService.java
similarity index 100%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/OrderConsumerService.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/OrderConsumerService.java
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/RocketAccountConsumerService.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/RocketAccountConsumerService.java
similarity index 89%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/RocketAccountConsumerService.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/RocketAccountConsumerService.java
index 9506cc6..464c369 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/consumer/RocketAccountConsumerService.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/RocketAccountConsumerService.java
@@ -1,9 +1,8 @@
-package com.rocketmq.example.consumer;
+package com.queue.rocketmq.example.consumer;
-import com.common.service.IAccountService;
-import com.rocketmq.example.vo.AccountVo;
+import com.queue.common.service.IAccountService;
+import com.queue.rocketmq.example.vo.AccountVo;
import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/Storage2Service.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/Storage2Service.java
similarity index 100%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/Storage2Service.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/Storage2Service.java
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageReplyService.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/StorageReplyService.java
similarity index 100%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageReplyService.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/StorageReplyService.java
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageService.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/StorageService.java
similarity index 100%
rename from message-queue-example/src/main/java/com/rocketmq/example/consumer/StorageService.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/consumer/StorageService.java
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/listener/AccountRocketMQTransactionLister.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/listener/AccountRocketMQTransactionLister.java
similarity index 94%
rename from message-queue-example/src/main/java/com/rocketmq/example/listener/AccountRocketMQTransactionLister.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/listener/AccountRocketMQTransactionLister.java
index 4042fa5..11d9cc1 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/listener/AccountRocketMQTransactionLister.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/listener/AccountRocketMQTransactionLister.java
@@ -1,7 +1,7 @@
-package com.rocketmq.example.listener;
+package com.queue.rocketmq.example.listener;
-import com.common.entity.AccountTbl;
-import com.common.service.IAccountService;
+import com.queue.common.entity.AccountTbl;
+import com.queue.common.service.IAccountService;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.LocalTransactionState;
import org.apache.rocketmq.client.producer.TransactionListener;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/listener/AccountTransactionLister.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/listener/AccountTransactionLister.java
similarity index 100%
rename from message-queue-example/src/main/java/com/rocketmq/example/listener/AccountTransactionLister.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/listener/AccountTransactionLister.java
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/listener/OrderTransactionLister.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/listener/OrderTransactionLister.java
similarity index 100%
rename from message-queue-example/src/main/java/com/rocketmq/example/listener/OrderTransactionLister.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/listener/OrderTransactionLister.java
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/vo/AccountVo.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/vo/AccountVo.java
similarity index 91%
rename from message-queue-example/src/main/java/com/rocketmq/example/vo/AccountVo.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/vo/AccountVo.java
index 496f16b..00c162a 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/vo/AccountVo.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/vo/AccountVo.java
@@ -1,4 +1,4 @@
-package com.rocketmq.example.vo;
+package com.queue.rocketmq.example.vo;
import lombok.Data;
import lombok.EqualsAndHashCode;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/vo/OrderVo.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/vo/OrderVo.java
similarity index 85%
rename from message-queue-example/src/main/java/com/rocketmq/example/vo/OrderVo.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/vo/OrderVo.java
index 1161590..b6ca189 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/vo/OrderVo.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/vo/OrderVo.java
@@ -1,4 +1,4 @@
-package com.rocketmq.example.vo;
+package com.queue.rocketmq.example.vo;
import lombok.Data;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/vo/ProductVo.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/vo/ProductVo.java
similarity index 83%
rename from message-queue-example/src/main/java/com/rocketmq/example/vo/ProductVo.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/vo/ProductVo.java
index f0e2ac6..3b31b2a 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/vo/ProductVo.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/vo/ProductVo.java
@@ -1,4 +1,4 @@
-package com.rocketmq.example.vo;
+package com.queue.rocketmq.example.vo;
import lombok.Data;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/web/JsonController.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/web/JsonController.java
similarity index 88%
rename from message-queue-example/src/main/java/com/rocketmq/example/web/JsonController.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/web/JsonController.java
index 80521ba..d328062 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/web/JsonController.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/web/JsonController.java
@@ -1,7 +1,7 @@
-package com.rocketmq.example.web;
+package com.queue.rocketmq.example.web;
import cn.hutool.json.JSONUtil;
-import com.rocketmq.example.vo.ProductVo;
+import com.queue.rocketmq.example.vo.ProductVo;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/web/OrderRocketController.java
similarity index 95%
rename from message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/web/OrderRocketController.java
index a95fa33..3501752 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderRocketController.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/web/OrderRocketController.java
@@ -1,8 +1,8 @@
-package com.rocketmq.example.web;
+package com.queue.rocketmq.example.web;
-import com.common.service.IOrderService;
-import com.rocketmq.example.vo.AccountVo;
+import com.queue.common.service.IOrderService;
+import com.queue.rocketmq.example.vo.AccountVo;
import com.saturday.common.exception.BusinessException;
import com.saturday.common.model.vo.ResponseVO;
import com.saturday.common.util.ResultUtils;
diff --git a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderSpringRocketController.java b/message-queue-example/src/main/java/com/queue/rocketmq/example/web/OrderSpringRocketController.java
similarity index 97%
rename from message-queue-example/src/main/java/com/rocketmq/example/web/OrderSpringRocketController.java
rename to message-queue-example/src/main/java/com/queue/rocketmq/example/web/OrderSpringRocketController.java
index 3853eff..13f3285 100644
--- a/message-queue-example/src/main/java/com/rocketmq/example/web/OrderSpringRocketController.java
+++ b/message-queue-example/src/main/java/com/queue/rocketmq/example/web/OrderSpringRocketController.java
@@ -1,7 +1,7 @@
-package com.rocketmq.example.web;
+package com.queue.rocketmq.example.web;
-import com.common.service.IOrderService;
+import com.queue.common.service.IOrderService;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.*;
import org.springframework.beans.factory.annotation.Autowired;
diff --git a/message-queue-example/src/main/resources/mapper/AccountTblMapper.xml b/message-queue-example/src/main/resources/mapper/AccountTblMapper.xml
index 9d72ca7..5f5a10c 100644
--- a/message-queue-example/src/main/resources/mapper/AccountTblMapper.xml
+++ b/message-queue-example/src/main/resources/mapper/AccountTblMapper.xml
@@ -1,5 +1,5 @@
-
diff --git a/message-queue-example/src/main/java/com/queue/common/service/IOrderService.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/IOrderService.java
similarity index 72%
rename from message-queue-example/src/main/java/com/queue/common/service/IOrderService.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/IOrderService.java
index f16bf5a..ece6923 100644
--- a/message-queue-example/src/main/java/com/queue/common/service/IOrderService.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/IOrderService.java
@@ -1,8 +1,8 @@
-package com.queue.common.service;
+package com.opensource.common.service;
import com.baomidou.mybatisplus.extension.service.IService;
-import com.queue.common.entity.OrderTbl;
-import com.queue.rocketmq.example.vo.OrderVo;
+import com.opensource.common.entity.OrderTbl;
+import com.opensource.vo.OrderVo;
/**
*
diff --git a/message-queue-example/src/main/java/com/queue/common/service/impl/AccountServiceImpl.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/AccountServiceImpl.java
similarity index 86%
rename from message-queue-example/src/main/java/com/queue/common/service/impl/AccountServiceImpl.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/AccountServiceImpl.java
index 301613f..66f4964 100644
--- a/message-queue-example/src/main/java/com/queue/common/service/impl/AccountServiceImpl.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/AccountServiceImpl.java
@@ -1,10 +1,10 @@
-package com.queue.common.service.impl;
+package com.opensource.common.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.queue.common.entity.AccountTbl;
-import com.queue.common.mapper.AccountTblMapper;
-import com.queue.common.service.IAccountService;
+import com.opensource.common.entity.AccountTbl;
+import com.opensource.common.mapper.AccountTblMapper;
+import com.opensource.common.service.IAccountService;
import com.saturday.common.exception.BusinessException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
diff --git a/message-queue-example/src/main/java/com/queue/common/service/impl/OrderServiceImpl.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/OrderServiceImpl.java
similarity index 83%
rename from message-queue-example/src/main/java/com/queue/common/service/impl/OrderServiceImpl.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/OrderServiceImpl.java
index 6f76863..436ef75 100644
--- a/message-queue-example/src/main/java/com/queue/common/service/impl/OrderServiceImpl.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/common/service/impl/OrderServiceImpl.java
@@ -1,11 +1,11 @@
-package com.queue.common.service.impl;
+package com.opensource.common.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.queue.common.entity.OrderTbl;
-import com.queue.common.mapper.OrderTblMapper;
-import com.queue.common.service.IOrderService;
-import com.queue.rocketmq.example.vo.OrderVo;
+import com.opensource.common.entity.OrderTbl;
+import com.opensource.common.mapper.OrderTblMapper;
+import com.opensource.common.service.IOrderService;
+import com.opensource.vo.OrderVo;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/Consumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Consumer.java
similarity index 95%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/Consumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Consumer.java
index 53a4770..d4306e6 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/Consumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Consumer.java
@@ -1,4 +1,4 @@
-package com.queue.rabbitmq.example;
+package com.opensource.example;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/Producer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Producer.java
similarity index 92%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/Producer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Producer.java
index 8ed8f98..74bd527 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/Producer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/Producer.java
@@ -1,4 +1,4 @@
-package com.queue.rabbitmq.example;
+package com.opensource.example;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/RabbitmqConfig.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/RabbitmqConfig.java
similarity index 89%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/RabbitmqConfig.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/RabbitmqConfig.java
index ef9fd73..0c75bbe 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/RabbitmqConfig.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/RabbitmqConfig.java
@@ -1,4 +1,4 @@
-package com.queue.rabbitmq.example;
+package com.opensource.example;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/TestController.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/TestController.java
similarity index 93%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/TestController.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/TestController.java
index c7d62b2..c705ae0 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/TestController.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/TestController.java
@@ -1,4 +1,4 @@
-package com.queue.rabbitmq.example;
+package com.opensource.example;
import com.saturday.common.util.ResultUtils;
import org.springframework.beans.factory.annotation.Autowired;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/RabbitConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/RabbitConsumer.java
similarity index 91%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/RabbitConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/RabbitConsumer.java
index ddf9b3a..c4a76cb 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/RabbitConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/RabbitConsumer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.ack;
+package com.opensource.example.ack;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/ack/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/ack/readme.txt
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeConsumer.java
index f1e9b25..679f86d 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeConsumer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.backupexchange;
+package com.opensource.example.backupexchange;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeProducer.java
similarity index 86%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeProducer.java
index 3ffaef8..cb9ea5e 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/BackupExchangeProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/BackupExchangeProducer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.backupexchange;
+package com.opensource.example.backupexchange;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/MainExchangeConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/MainExchangeConsumer.java
similarity index 91%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/MainExchangeConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/MainExchangeConsumer.java
index 737be4b..f1205c0 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/MainExchangeConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/MainExchangeConsumer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.backupexchange;
+package com.opensource.example.backupexchange;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/note.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/note.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/backupexchange/note.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/backupexchange/note.txt
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/common/Constants.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/Constants.java
similarity index 94%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/common/Constants.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/Constants.java
index 62223ad..3c8233c 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/common/Constants.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/Constants.java
@@ -1,4 +1,4 @@
-package com.queue.rabbitmq.example.common;
+package com.opensource.example.common;
public class Constants {
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/common/RabbitMqUtil.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/RabbitMqUtil.java
similarity index 97%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/common/RabbitMqUtil.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/RabbitMqUtil.java
index a4e15c9..16f30d5 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/common/RabbitMqUtil.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/common/RabbitMqUtil.java
@@ -1,4 +1,4 @@
-package com.queue.rabbitmq.example.common;
+package com.opensource.example.common;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer.java
index 073e1be..cf9a9e5 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.exchange.fanout;
+package com.opensource.example.exchange.fanout;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer2.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer2.java
index 3fbffe1..0a3f2d7 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer2.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer2.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.exchange.fanout;
+package com.opensource.example.exchange.fanout;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer3.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer3.java
index 3e57817..1623dc1 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeConsumer3.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeConsumer3.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.exchange.fanout;
+package com.opensource.example.exchange.fanout;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeProducer.java
similarity index 84%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeProducer.java
index 4077cd1..a47ae7c 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/fanout/FanoutExchangeProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/fanout/FanoutExchangeProducer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.exchange.fanout;
+package com.opensource.example.exchange.fanout;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/readme.txt
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer.java
index fa8c49e..105db3f 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.exchange.topic;
+package com.opensource.example.exchange.topic;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer2.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer2.java
index 02f7830..52e48e2 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer2.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer2.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.exchange.topic;
+package com.opensource.example.exchange.topic;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer3.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer3.java
index 6687781..071cfed 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeConsumer3.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeConsumer3.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.exchange.topic;
+package com.opensource.example.exchange.topic;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeProducer.java
similarity index 85%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeProducer.java
index 725d2d7..7b49558 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/exchange/topic/TopicExchangeProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/exchange/topic/TopicExchangeProducer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.exchange.topic;
+package com.opensource.example.exchange.topic;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/Producer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/Producer.java
similarity index 86%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/message/Producer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/Producer.java
index 103358b..7ba737f 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/Producer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/Producer.java
@@ -1,10 +1,10 @@
-package com.queue.rabbitmq.example.message;
+package com.opensource.example.message;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PullConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PullConsumer.java
similarity index 89%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PullConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PullConsumer.java
index df42da9..6411606 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PullConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PullConsumer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.message;
+package com.opensource.example.message;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PushConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PushConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PushConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PushConsumer.java
index a499735..2a4490b 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/PushConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/PushConsumer.java
@@ -1,8 +1,8 @@
-package com.queue.rabbitmq.example.message;
+package com.opensource.example.message;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/message/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/message/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/message/readme.txt
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitConsumer.java
index e16db20..75cb9cc 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitConsumer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.quickstart;
+package com.opensource.example.quickstart;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitProducer.java
similarity index 85%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitProducer.java
index c44ef4c..25a57ca 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/RabbitProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/RabbitProducer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.quickstart;
+package com.opensource.example.quickstart;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/quickstart/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/quickstart/readme.txt
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/RabbitRejectConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/RabbitRejectConsumer.java
similarity index 92%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/RabbitRejectConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/RabbitRejectConsumer.java
index e9a65d1..d4f4ff9 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/RabbitRejectConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/RabbitRejectConsumer.java
@@ -1,8 +1,8 @@
-package com.queue.rabbitmq.example.reject;
+package com.opensource.example.reject;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/reject/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/reject/readme.txt
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitConsumer.java
similarity index 90%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitConsumer.java
index 6af12dd..d4ad7de 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitConsumer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.transaction;
+package com.opensource.example.transaction;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitProducer.java
similarity index 88%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitProducer.java
index b983fe4..d03dc45 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/transaction/RabbitProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/transaction/RabbitProducer.java
@@ -1,7 +1,7 @@
-package com.queue.rabbitmq.example.transaction;
+package com.opensource.example.transaction;
-import com.queue.rabbitmq.example.common.Constants;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.Constants;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer.java
similarity index 91%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer.java
index cd3a8db..c937a89 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer.java
@@ -1,6 +1,6 @@
-package com.queue.rabbitmq.example.workqueue;
+package com.opensource.example.workqueue;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.SneakyThrows;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer2.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer2.java
similarity index 91%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer2.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer2.java
index 10e8341..98c48c8 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitConsumer2.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitConsumer2.java
@@ -1,6 +1,6 @@
-package com.queue.rabbitmq.example.workqueue;
+package com.opensource.example.workqueue;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.*;
import lombok.SneakyThrows;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitProducer.java b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitProducer.java
similarity index 86%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitProducer.java
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitProducer.java
index 0794c66..5805a57 100644
--- a/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/RabbitProducer.java
+++ b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/RabbitProducer.java
@@ -1,6 +1,6 @@
-package com.queue.rabbitmq.example.workqueue;
+package com.opensource.example.workqueue;
-import com.queue.rabbitmq.example.common.RabbitMqUtil;
+import com.opensource.example.common.RabbitMqUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
diff --git a/message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/readme.txt b/message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/readme.txt
similarity index 100%
rename from message-queue-example/src/main/java/com/queue/rabbitmq/example/workqueue/readme.txt
rename to message-queue-example/rabbitmq-example/src/main/java/com/opensource/example/workqueue/readme.txt
diff --git a/message-queue-example/src/main/resources/application.yml b/message-queue-example/rabbitmq-example/src/main/resources/application.yml
similarity index 100%
rename from message-queue-example/src/main/resources/application.yml
rename to message-queue-example/rabbitmq-example/src/main/resources/application.yml
diff --git a/message-queue-example/src/main/resources/mapper/AccountTblMapper.xml b/message-queue-example/rabbitmq-example/src/main/resources/mapper/AccountTblMapper.xml
similarity index 100%
rename from message-queue-example/src/main/resources/mapper/AccountTblMapper.xml
rename to message-queue-example/rabbitmq-example/src/main/resources/mapper/AccountTblMapper.xml
diff --git a/message-queue-example/src/main/resources/mapper/OrderTblMapper.xml b/message-queue-example/rabbitmq-example/src/main/resources/mapper/OrderTblMapper.xml
similarity index 100%
rename from message-queue-example/src/main/resources/mapper/OrderTblMapper.xml
rename to message-queue-example/rabbitmq-example/src/main/resources/mapper/OrderTblMapper.xml
diff --git a/message-queue-example/rocketmq-example/.gitignore b/message-queue-example/rocketmq-example/.gitignore
new file mode 100644
index 0000000..5ff6309
--- /dev/null
+++ b/message-queue-example/rocketmq-example/.gitignore
@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store
\ No newline at end of file
diff --git a/message-queue-example/rocketmq-example/pom.xml b/message-queue-example/rocketmq-example/pom.xml
new file mode 100644
index 0000000..b1f6470
--- /dev/null
+++ b/message-queue-example/rocketmq-example/pom.xml
@@ -0,0 +1,20 @@
+
+
+ *
+ *
+ *
+ *
+ * Mapper 接口
+ *
+ * Mapper 接口
+ *
+ * 服务类
+ *
+ * 服务类
+ *
+ * 服务实现类
+ *
+ * 服务实现类
+ *