rocketmq-spring optimise

pom.xml

@@ -60,7 +60,6 @@
         <netty.version>3.2.5.Final</netty.version>
         <netty4.version>4.1.30.Final</netty4.version>
         <mina.version>1.1.7</mina.version>
-        <netty-tcnative.version>2.0.7.Final</netty-tcnative.version>
 
         <scala.version>2.8.2</scala.version>
         <metrics.version>2.2.0</metrics.version>
@@ -70,7 +69,6 @@
 
         <jedis.version>2.9.0</jedis.version>
 
-        <rocketmq.version>4.2.0</rocketmq.version>
         <activemq.version>5.15.0</activemq.version>
         <rabbitmq.version>4.2.0</rabbitmq.version>
         <kafka.version>0.8.0</kafka.version>
@@ -347,34 +345,6 @@
                 <version>${mina.version}</version>
             </dependency>
 
-            <!-- rocketmq -->
-            <dependency>
-                <groupId>org.apache.rocketmq</groupId>
-                <artifactId>rocketmq-namesrv</artifactId>
-                <version>${rocketmq.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>org.apache.rocketmq</groupId>
-                <artifactId>rocketmq-broker</artifactId>
-                <version>${rocketmq.version}</version>
-                <exclusions>
-                    <exclusion>
-                        <groupId>io.netty</groupId>
-                        <artifactId>netty-tcnative</artifactId>
-                    </exclusion>
-                </exclusions>
-            </dependency>
-            <dependency>
-                <groupId>io.netty</groupId>
-                <artifactId>netty-tcnative</artifactId>
-                <version>${netty-tcnative.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>org.apache.rocketmq</groupId>
-                <artifactId>rocketmq-client</artifactId>
-                <version>${rocketmq.version}</version>
-            </dependency>
-
             <!-- activemq -->
             <dependency>
                 <groupId>org.springframework</groupId>

whatsmars-mq/whatsmars-mq-rocketmq/pom.xml

@@ -11,18 +11,6 @@
 
     <artifactId>whatsmars-mq-rocketmq</artifactId>
 
-    <dependencyManagement>
-        <dependencies>
-            <dependency>
-                <groupId>org.springframework.boot</groupId>
-                <artifactId>spring-boot-dependencies</artifactId>
-                <version>${spring-boot.version}</version>
-                <type>pom</type>
-                <scope>import</scope>
-            </dependency>
-        </dependencies>
-    </dependencyManagement>
-
     <dependencies>
         <dependency>
             <groupId>org.hongxi</groupId>

whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ConsumerFactoryBean.java

@@ -11,7 +11,7 @@ public class ConsumerFactoryBean implements FactoryBean<DefaultMQPushConsumer>,I
 
     private DefaultMQPushConsumer consumer;
 
-    private String instanceName; // 不同集群不同值
+    private String instanceName = System.getProperty("rocketmq.client.name", "DEFAULT");
 
     private String consumerGroup;
 

whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ProducerFactoryBean.java

@@ -9,7 +9,7 @@ public class ProducerFactoryBean implements FactoryBean<DefaultMQProducer>,Initi
 
     private DefaultMQProducer producer;
 
-    private String instanceName; // 不同集群不同值
+    private String instanceName = System.getProperty("rocketmq.client.name", "DEFAULT");
 
     private String producerGroup;
 

whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-consumer.xml

@@ -6,7 +6,6 @@
        default-autowire="byName">
 
     <bean class="org.hongxi.whatsmars.mq.rocketmq.spring.ConsumerFactoryBean">
-        <property name="instanceName" value="DEFAULT" />
         <property name="consumerGroup" value="quick_start_consumer_group" />
         <property name="namesrvAddr" value="127.0.0.1:9876" />
         <property name="topic" value="TopicTest" />

whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-producer.xml

@@ -6,7 +6,6 @@
        default-autowire="byName">
 
     <bean id="defaultMQProducer" class="org.hongxi.whatsmars.mq.rocketmq.spring.ProducerFactoryBean">
-        <property name="instanceName" value="DEFAULT" />
         <property name="producerGroup" value="quick_start_producer_group" />
         <property name="namesrvAddr" value="127.0.0.1:9876" />
     </bean>