diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/BrokerStartup.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/BrokerStartup.java similarity index 93% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/BrokerStartup.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/BrokerStartup.java index a4a2e91944fde907748ef120bae90b4a30ea15b4..922c732be8da6916feb627975de3dc306ae1555c 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/BrokerStartup.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/BrokerStartup.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.activemq; +package org.hongxi.whatsmars.mq.activemq; import org.apache.activemq.broker.BrokerService; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/Consumer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/Consumer.java similarity index 95% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/Consumer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/Consumer.java index ff21a28277f28e3d8f778e4fcc555f2af020d180..717384e653e7d7c17037a01db870fa49b86af885 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/Consumer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/Consumer.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.activemq; +package org.hongxi.whatsmars.mq.activemq; import org.apache.activemq.ActiveMQConnectionFactory; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/Producer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/Producer.java similarity index 95% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/Producer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/Producer.java index debaea89f8d15e7a2ed5cd45c3652584e9bd41b9..ce466f1f36ba092ed88cfe4799b2e709476d6284 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/Producer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/Producer.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.activemq; +package org.hongxi.whatsmars.mq.activemq; import org.apache.activemq.ActiveMQConnectionFactory; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/kafka/KafkaConsumer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaConsumer.java similarity index 97% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/kafka/KafkaConsumer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaConsumer.java index 9e5b90b5376334d0cb2421708ce06e42f8bcfeca..6a5349bf2530006071b9acd913be45e92870036d 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/kafka/KafkaConsumer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaConsumer.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.kafka; +package org.hongxi.whatsmars.mq.kafka; import kafka.consumer.ConsumerConfig; import kafka.consumer.ConsumerIterator; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/kafka/KafkaProducer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaProducer.java similarity index 95% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/kafka/KafkaProducer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaProducer.java index ca3655cb8f6aa286e53e621169e9895461c7e961..d23432d0ea5f19c9882db974620a7b324223fa28 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/kafka/KafkaProducer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaProducer.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.kafka; +package org.hongxi.whatsmars.mq.kafka; import kafka.javaapi.producer.Producer; import kafka.producer.KeyedMessage; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rabbitmq/Consumer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rabbitmq/Consumer.java similarity index 96% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rabbitmq/Consumer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rabbitmq/Consumer.java index 4e84eff45bbf037b8734bd653371a2be57b530f3..7a998562eed519f7dbfa3b52980e92f0636cc8d9 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rabbitmq/Consumer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rabbitmq/Consumer.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rabbitmq; +package org.hongxi.whatsmars.mq.rabbitmq; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rabbitmq/Producer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rabbitmq/Producer.java similarity index 95% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rabbitmq/Producer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rabbitmq/Producer.java index 49f99af0f16666721069783256a7470420a3f630..23d15db61565b8304ef11f7203739b631407d7b1 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rabbitmq/Producer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rabbitmq/Producer.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rabbitmq; +package org.hongxi.whatsmars.mq.rabbitmq; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/BrokerStartup.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/BrokerStartup.java similarity index 91% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/BrokerStartup.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/BrokerStartup.java index f4c16bf0e9cdb126975d2260266fb77201f4a221..b9637b97402792b5742955a44557cc1b2a7dd1fa 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/BrokerStartup.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/BrokerStartup.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rocketmq; +package org.hongxi.whatsmars.mq.rocketmq; /** * Created by shenhongxi on 2017/6/21. diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/NamesrvStartup.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/NamesrvStartup.java similarity index 89% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/NamesrvStartup.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/NamesrvStartup.java index 8cb3d0f2771bc0ff220d8d5082eb6630889986fd..8d4c852f3eeda520179e5b8c3041bfb02f359803 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/NamesrvStartup.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/NamesrvStartup.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rocketmq; +package org.hongxi.whatsmars.mq.rocketmq; /** * Created by shenhongxi on 2017/6/21. diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/_BrokerStartup.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/_BrokerStartup.java similarity index 91% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/_BrokerStartup.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/_BrokerStartup.java index 58e8cf0a075536e11cadc651828499bc72f3bea6..af67e918cc8026f9b176cccb9df51972a6029529 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/_BrokerStartup.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/_BrokerStartup.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rocketmq; +package org.hongxi.whatsmars.mq.rocketmq; /** * Created by shenhongxi on 2017/6/21. diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ConsumerApplication.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ConsumerApplication.java similarity index 95% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ConsumerApplication.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ConsumerApplication.java index bda1ac50abddcaa0ee9fc25e2f980c3eaeeb108e..dbd4157a02d8990b3071c51ebea4c9f4bb44c1d4 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ConsumerApplication.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ConsumerApplication.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rocketmq.boot; +package org.hongxi.whatsmars.mq.rocketmq.boot; import com.qianmi.ms.starter.rocketmq.annotation.RocketMQMessageListener; import com.qianmi.ms.starter.rocketmq.core.RocketMQListener; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java similarity index 93% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java index 3ba8d585ffbc6be0c4d160882c998ba5abdef6e0..6e1b1e4196d60f71514612c8769d9f5809e0965c 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rocketmq.boot; +package org.hongxi.whatsmars.mq.rocketmq.boot; import java.io.Serializable; import java.math.BigDecimal; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ProducerApplication.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ProducerApplication.java similarity index 96% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ProducerApplication.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ProducerApplication.java index 9fa1e86057e50c8cf3f871282d02b2f71dd197ca..40b1cb0d8a2ed9bfab60d79113d363b5db7f0deb 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ProducerApplication.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ProducerApplication.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rocketmq.boot; +package org.hongxi.whatsmars.mq.rocketmq.boot; import com.qianmi.ms.starter.rocketmq.core.RocketMQTemplate; import org.springframework.beans.factory.annotation.Autowired; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/broadcast/PushConsumer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/broadcast/PushConsumer.java similarity index 97% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/broadcast/PushConsumer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/broadcast/PushConsumer.java index 58eb8f3abd0161b9fdaf0350fce96a8ec3eca777..a4a26fff51f11ad30dd829ddce26463260e92978 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/broadcast/PushConsumer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/broadcast/PushConsumer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.broadcast; +package org.hongxi.whatsmars.mq.rocketmq.broadcast; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/ordermessage/Consumer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/ordermessage/Consumer.java similarity index 96% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/ordermessage/Consumer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/ordermessage/Consumer.java index 15c8932249aaf3da13dc6048f392b66c99fbbbaf..5d38f01146599b8e6362c0767181943c025abf3d 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/ordermessage/Consumer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/ordermessage/Consumer.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rocketmq.ordermessage; +package org.hongxi.whatsmars.mq.rocketmq.ordermessage; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/ordermessage/Producer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/ordermessage/Producer.java similarity index 97% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/ordermessage/Producer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/ordermessage/Producer.java index 70a3d10199dbf772a03c74b9e4e4b3cf508bcb61..da1f669b5b3514661f6e1d2342e2f332b061b085 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/ordermessage/Producer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/ordermessage/Producer.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.rocketmq.ordermessage; +package org.hongxi.whatsmars.mq.rocketmq.ordermessage; import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.MessageQueueSelector; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/quickstart/Consumer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/quickstart/Consumer.java similarity index 98% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/quickstart/Consumer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/quickstart/Consumer.java index 23ec4b30af626a1296613269a247d83241823df4..581c0104b0b372f88664ae98c850f0748a0ad849 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/quickstart/Consumer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/quickstart/Consumer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.quickstart; +package org.hongxi.whatsmars.mq.rocketmq.quickstart; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/quickstart/Producer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/quickstart/Producer.java similarity index 98% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/quickstart/Producer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/quickstart/Producer.java index c9103d9c7a5388583759086745d684b48c48b5f4..5e1fcdce33927440de04247b63cdd528498ec3e1 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/quickstart/Producer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/quickstart/Producer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.quickstart; +package org.hongxi.whatsmars.mq.rocketmq.quickstart; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.producer.DefaultMQProducer; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/AsyncProducer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/AsyncProducer.java similarity index 98% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/AsyncProducer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/AsyncProducer.java index 25fb26a4e31869a218fffb99836d7d5760489e77..d3e1b227f2c70d10a4653981f2a3daa71fd70366 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/AsyncProducer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/AsyncProducer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.simple; +package org.hongxi.whatsmars.mq.rocketmq.simple; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.producer.DefaultMQProducer; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/CachedQueue.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/CachedQueue.java similarity index 95% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/CachedQueue.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/CachedQueue.java index 8348b523aca751b8d8363e54f82fa4c94a75e680..8bfe3830b5f481771c3e1214d7e8f5a180227efb 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/CachedQueue.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/CachedQueue.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.whatsmars.mq.rocketmq.simple; +package org.hongxi.whatsmars.mq.rocketmq.simple; import org.apache.rocketmq.common.message.MessageExt; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/Producer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/Producer.java similarity index 97% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/Producer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/Producer.java index 0e6077e270eb2e57484b91141f0d45dbbe8da6ef..df42b472e4e1c8f21470c692af171f7b9c01fa42 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/Producer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/Producer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.simple; +package org.hongxi.whatsmars.mq.rocketmq.simple; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.producer.DefaultMQProducer; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullConsumer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PullConsumer.java similarity index 98% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullConsumer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PullConsumer.java index 2721b7c1b5134365186724f7a3ba6a2673c97723..8d1b77b682d24d1c5de08daab0e2b1c69a7cef4b 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullConsumer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PullConsumer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.simple; +package org.hongxi.whatsmars.mq.rocketmq.simple; import org.apache.rocketmq.client.consumer.DefaultMQPullConsumer; import org.apache.rocketmq.client.consumer.PullResult; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullConsumerTest.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PullConsumerTest.java similarity index 97% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullConsumerTest.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PullConsumerTest.java index 1c9feb269a86e9dfd4a08b6dd0968cc545d1dce0..6a38db2ef36607a8ebe5cd37661823d557f1a16a 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullConsumerTest.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PullConsumerTest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.simple; +package org.hongxi.whatsmars.mq.rocketmq.simple; import org.apache.rocketmq.client.consumer.DefaultMQPullConsumer; import org.apache.rocketmq.client.consumer.PullResult; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullScheduleService.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PullScheduleService.java similarity index 98% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullScheduleService.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PullScheduleService.java index cdb982eeff8ff79d17e8e5e8ed7e9cf07375c05d..7ef9f75e6ac7b880a79accaffda7dcc070b8bf92 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullScheduleService.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PullScheduleService.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.whatsmars.mq.rocketmq.simple; +package org.hongxi.whatsmars.mq.rocketmq.simple; import org.apache.rocketmq.client.consumer.*; import org.apache.rocketmq.client.exception.MQClientException; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PushConsumer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PushConsumer.java similarity index 97% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PushConsumer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PushConsumer.java index 4992864a549a5f11eb20127cef65aef6d6bf82b0..215159b56903b4343bb8f44db085a1b4fb02e18a 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PushConsumer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/PushConsumer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.simple; +package org.hongxi.whatsmars.mq.rocketmq.simple; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/RandomAsyncCommit.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/RandomAsyncCommit.java similarity index 97% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/RandomAsyncCommit.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/RandomAsyncCommit.java index b3f3734e34c03890b36939334220358984e28722..5d84b32b2e2d8ef20f9f6b8c70bee858b63bc2c9 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/RandomAsyncCommit.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/RandomAsyncCommit.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.whatsmars.mq.rocketmq.simple; +package org.hongxi.whatsmars.mq.rocketmq.simple; import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocketmq.common.message.MessageQueue; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/TestProducer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/TestProducer.java similarity index 97% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/TestProducer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/TestProducer.java index 44a9554ba7ff481aea54cc93c1b8b7220258d551..28ac4fd36ef1f38042ef3935379d43ebe8d8573d 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/TestProducer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/simple/TestProducer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.simple; +package org.hongxi.whatsmars.mq.rocketmq.simple; import org.apache.rocketmq.client.QueryResult; import org.apache.rocketmq.client.exception.MQClientException; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionCheckListenerImpl.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/transaction/TransactionCheckListenerImpl.java similarity index 97% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionCheckListenerImpl.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/transaction/TransactionCheckListenerImpl.java index 1a98f8f637576db549015144b858c1e8782b5697..782ed718d6518ca945c025c97865d713803bde47 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionCheckListenerImpl.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/transaction/TransactionCheckListenerImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.transaction; +package org.hongxi.whatsmars.mq.rocketmq.transaction; import org.apache.rocketmq.client.producer.LocalTransactionState; import org.apache.rocketmq.client.producer.TransactionCheckListener; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionExecuterImpl.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/transaction/TransactionExecuterImpl.java similarity index 96% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionExecuterImpl.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/transaction/TransactionExecuterImpl.java index 285d72b384ee5d396418a5e6301dc31ab4cd78b4..577708f9789f9c53ef6a8b362fb425d19e8520b6 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionExecuterImpl.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/transaction/TransactionExecuterImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.transaction; +package org.hongxi.whatsmars.mq.rocketmq.transaction; import org.apache.rocketmq.client.producer.LocalTransactionExecuter; import org.apache.rocketmq.client.producer.LocalTransactionState; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionProducer.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/transaction/TransactionProducer.java similarity index 98% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionProducer.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/transaction/TransactionProducer.java index a64391dbe4137ec8ad96d9fb22b54e853ce08501..dd379b84f8b70137def2dac637a93dfa1b9d027b 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionProducer.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/transaction/TransactionProducer.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.whatsmars.mq.rocketmq.transaction; +package org.hongxi.whatsmars.mq.rocketmq.transaction; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.producer.TransactionCheckListener; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/zeromq/Publisher.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/zeromq/Publisher.java similarity index 93% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/zeromq/Publisher.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/zeromq/Publisher.java index 2dfbb204624aac5b5ca63b2e88732a0f8290bf45..02a73f0004b487e225440857e51705d1d2aa3090 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/zeromq/Publisher.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/zeromq/Publisher.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.zeromq; +package org.hongxi.whatsmars.mq.zeromq; import org.zeromq.ZMQ; diff --git a/whatsmars-mq/src/main/java/com/whatsmars/mq/zeromq/Subscriber.java b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/zeromq/Subscriber.java similarity index 95% rename from whatsmars-mq/src/main/java/com/whatsmars/mq/zeromq/Subscriber.java rename to whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/zeromq/Subscriber.java index a9078127b3307088a19b22672ec1724a11531604..d87f1301ad60d3edb79f9f241401528f21191879 100644 --- a/whatsmars-mq/src/main/java/com/whatsmars/mq/zeromq/Subscriber.java +++ b/whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/zeromq/Subscriber.java @@ -1,4 +1,4 @@ -package com.whatsmars.mq.zeromq; +package org.hongxi.whatsmars.mq.zeromq; import org.zeromq.ZMQ;