rename package name

whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/BrokerStartup.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/BrokerStartup.java

-package com.whatsmars.mq.activemq;
+package org.hongxi.whatsmars.mq.activemq;
 
 import org.apache.activemq.broker.BrokerService;
 

whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/Consumer.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/Consumer.java

-package com.whatsmars.mq.activemq;
+package org.hongxi.whatsmars.mq.activemq;
 
 import org.apache.activemq.ActiveMQConnectionFactory;
 

whatsmars-mq/src/main/java/com/whatsmars/mq/activemq/Producer.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/activemq/Producer.java

-package com.whatsmars.mq.activemq;
+package org.hongxi.whatsmars.mq.activemq;
 
 import org.apache.activemq.ActiveMQConnectionFactory;
 

whatsmars-mq/src/main/java/com/whatsmars/mq/kafka/KafkaConsumer.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaConsumer.java

-package com.whatsmars.mq.kafka;
+package org.hongxi.whatsmars.mq.kafka;
 
 import kafka.consumer.ConsumerConfig;
 import kafka.consumer.ConsumerIterator;

whatsmars-mq/src/main/java/com/whatsmars/mq/kafka/KafkaProducer.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/kafka/KafkaProducer.java

-package com.whatsmars.mq.kafka;
+package org.hongxi.whatsmars.mq.kafka;
 
 import kafka.javaapi.producer.Producer;
 import kafka.producer.KeyedMessage;

whatsmars-mq/src/main/java/com/whatsmars/mq/rabbitmq/Consumer.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rabbitmq/Consumer.java

-package com.whatsmars.mq.rabbitmq;
+package org.hongxi.whatsmars.mq.rabbitmq;
 
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;

whatsmars-mq/src/main/java/com/whatsmars/mq/rabbitmq/Producer.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rabbitmq/Producer.java

-package com.whatsmars.mq.rabbitmq;
+package org.hongxi.whatsmars.mq.rabbitmq;
 
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/BrokerStartup.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/BrokerStartup.java

-package com.whatsmars.mq.rocketmq;
+package org.hongxi.whatsmars.mq.rocketmq;
 
 /**
  * Created by shenhongxi on 2017/6/21.

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/NamesrvStartup.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/NamesrvStartup.java

-package com.whatsmars.mq.rocketmq;
+package org.hongxi.whatsmars.mq.rocketmq;
 
 /**
  * Created by shenhongxi on 2017/6/21.

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/_BrokerStartup.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/_BrokerStartup.java

-package com.whatsmars.mq.rocketmq;
+package org.hongxi.whatsmars.mq.rocketmq;
 
 /**
  * Created by shenhongxi on 2017/6/21.

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ConsumerApplication.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ConsumerApplication.java

-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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/OrderPaidEvent.java

-package com.whatsmars.mq.rocketmq.boot;
+package org.hongxi.whatsmars.mq.rocketmq.boot;
 
 import java.io.Serializable;
 import java.math.BigDecimal;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/boot/ProducerApplication.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/boot/ProducerApplication.java

-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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/broadcast/PushConsumer.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/ordermessage/Consumer.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/ordermessage/Consumer.java

-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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/ordermessage/Producer.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/ordermessage/Producer.java

-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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/quickstart/Consumer.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/quickstart/Producer.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/AsyncProducer.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/CachedQueue.java → 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;
 

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/Producer.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullConsumer.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullConsumerTest.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PullScheduleService.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/PushConsumer.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/RandomAsyncCommit.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/simple/TestProducer.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionCheckListenerImpl.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionExecuterImpl.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/rocketmq/transaction/TransactionProducer.java → 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;

whatsmars-mq/src/main/java/com/whatsmars/mq/zeromq/Publisher.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/zeromq/Publisher.java

-package com.whatsmars.mq.zeromq;
+package org.hongxi.whatsmars.mq.zeromq;
 
 import org.zeromq.ZMQ;
 

whatsmars-mq/src/main/java/com/whatsmars/mq/zeromq/Subscriber.java → whatsmars-mq/src/main/java/org/hongxi/whatsmars/mq/zeromq/Subscriber.java

-package com.whatsmars.mq.zeromq;
+package org.hongxi.whatsmars.mq.zeromq;
 
 import org.zeromq.ZMQ;