whatsmars-mq-rocketmq-spring

whatsmars-mq/pom.xml

@@ -21,6 +21,7 @@
         <module>whatsmars-mq-rocketmq-namesrv</module>
         <module>whatsmars-mq-rocketmq-broker</module>
         <module>whatsmars-mq-rocketmq-tools</module>
+        <module>whatsmars-mq-rocketmq-spring</module>
     </modules>
 
     <properties>

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

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>whatsmars-mq</artifactId>
+        <groupId>org.hongxi</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>whatsmars-mq-rocketmq-spring</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-client</artifactId>
+            <version>${rocketmq.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-logging</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file

whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ClientConfig.java → whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/mq/rocketmq/config/spring/ClientConfig.java

-package org.hongxi.whatsmars.mq.rocketmq.spring;
+package org.hongxi.whatsmars.mq.rocketmq.config.spring;
 
 import org.apache.rocketmq.common.MixAll;
 

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

-package org.hongxi.whatsmars.mq.rocketmq.spring;
+package org.hongxi.whatsmars.mq.rocketmq.config.spring;
 
+import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
 import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
 import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
 import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.FactoryBean;
 import org.springframework.beans.factory.InitializingBean;
 
-public class ConsumerFactoryBean extends ClientConfig implements FactoryBean<DefaultMQPushConsumer>,InitializingBean,DisposableBean {
-
-    private static final Logger logger = LoggerFactory.getLogger(ConsumerFactoryBean.class);
+@Slf4j
+public class Consumer extends ClientConfig implements FactoryBean<DefaultMQPushConsumer>,InitializingBean,DisposableBean {
 
     private DefaultMQPushConsumer consumer;
 
@@ -127,7 +125,7 @@ public class ConsumerFactoryBean extends ClientConfig implements FactoryBean<Def
         consumer.subscribe(topic, tags);
         consumer.registerMessageListener(messageListener);
         consumer.start();
-        logger.info("Consumer Group {} started!", consumerGroup);
+        log.info("Consumer Group {} started!", consumerGroup);
     }
 
     @Override

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

-package org.hongxi.whatsmars.mq.rocketmq.spring;
+package org.hongxi.whatsmars.mq.rocketmq.config.spring;
 
+import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.producer.DefaultMQProducer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -7,9 +8,8 @@ import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.FactoryBean;
 import org.springframework.beans.factory.InitializingBean;
 
-public class ProducerFactoryBean extends ClientConfig implements FactoryBean<DefaultMQProducer>,InitializingBean,DisposableBean {
-
-    private static final Logger logger = LoggerFactory.getLogger(ProducerFactoryBean.class);
+@Slf4j
+public class Producer extends ClientConfig implements FactoryBean<DefaultMQProducer>,InitializingBean,DisposableBean {
 
     private DefaultMQProducer producer;
 
@@ -61,7 +61,7 @@ public class ProducerFactoryBean extends ClientConfig implements FactoryBean<Def
         producer.setSendMsgTimeout(sendMsgTimeout);
         producer.setRetryTimesWhenSendFailed(retryTimesWhenSendFailed);
         producer.start();
-        logger.info("Producer Group {} started!", producerGroup);
+        log.info("Producer Group {} started!", producerGroup);
     }
 
     @Override

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

@@ -17,6 +17,11 @@
             <artifactId>rocketmq-spring-boot-starter</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>org.hongxi</groupId>
+            <artifactId>whatsmars-mq-rocketmq-spring</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
     </dependencies>
 
 

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

@@ -5,7 +5,7 @@
                            http://www.springframework.org/schema/beans/spring-beans-3.2.xsd"
        default-autowire="byName">
 
-    <bean class="org.hongxi.whatsmars.mq.rocketmq.spring.ConsumerFactoryBean">
+    <bean class="org.hongxi.whatsmars.mq.rocketmq.config.spring.Consumer">
         <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

@@ -5,7 +5,7 @@
                            http://www.springframework.org/schema/beans/spring-beans-3.2.xsd"
        default-autowire="byName">
 
-    <bean id="defaultMQProducer" class="org.hongxi.whatsmars.mq.rocketmq.spring.ProducerFactoryBean">
+    <bean id="defaultMQProducer" class="org.hongxi.whatsmars.mq.rocketmq.config.spring.Producer">
         <property name="producerGroup" value="quick_start_producer_group" />
         <property name="namesrvAddr" value="127.0.0.1:9876" />
     </bean>