Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
武汉红喜
whatsmars
提交
cfa0f6fa
W
whatsmars
项目概览
武汉红喜
/
whatsmars
通知
3
Star
0
Fork
1
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
W
whatsmars
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
cfa0f6fa
编写于
11月 28, 2018
作者:
武汉红喜
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
rename package
上级
2d777683
变更
49
隐藏空白更改
内联
并排
Showing
49 changed file
with
52 addition
and
54 deletion
+52
-54
whatsmars-mq/whatsmars-mq-activemq-broker/src/main/java/org/hongxi/whatsmars/activemq/broker/BrokerStartup.java
...a/org/hongxi/whatsmars/activemq/broker/BrokerStartup.java
+1
-1
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/Consumer.java
...src/main/java/org/hongxi/whatsmars/activemq/Consumer.java
+1
-1
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/Producer.java
...src/main/java/org/hongxi/whatsmars/activemq/Producer.java
+1
-1
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/boot/ActiveMQApplication.java
...g/hongxi/whatsmars/activemq/boot/ActiveMQApplication.java
+1
-1
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/boot/Consumer.java
...ain/java/org/hongxi/whatsmars/activemq/boot/Consumer.java
+1
-1
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/boot/Producer.java
...ain/java/org/hongxi/whatsmars/activemq/boot/Producer.java
+1
-1
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/spring/Consumer.java
...n/java/org/hongxi/whatsmars/activemq/spring/Consumer.java
+1
-1
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/spring/DemoMessageListener.java
...hongxi/whatsmars/activemq/spring/DemoMessageListener.java
+1
-1
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/spring/Producer.java
...n/java/org/hongxi/whatsmars/activemq/spring/Producer.java
+1
-1
whatsmars-mq/whatsmars-mq-activemq/src/main/resources/spring/activemq-consumer.xml
...-activemq/src/main/resources/spring/activemq-consumer.xml
+1
-1
whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/kafka/KafkaConsumer.java
...c/main/java/org/hongxi/whatsmars/kafka/KafkaConsumer.java
+1
-1
whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/kafka/KafkaProducer.java
...c/main/java/org/hongxi/whatsmars/kafka/KafkaProducer.java
+1
-1
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/Consumer.java
...src/main/java/org/hongxi/whatsmars/rabbitmq/Consumer.java
+1
-1
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/Producer.java
...src/main/java/org/hongxi/whatsmars/rabbitmq/Producer.java
+1
-1
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/boot/SampleAmqpSimpleApplication.java
.../whatsmars/rabbitmq/boot/SampleAmqpSimpleApplication.java
+1
-1
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/boot/Sender.java
.../main/java/org/hongxi/whatsmars/rabbitmq/boot/Sender.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq-broker/src/main/java/org/hongxi/whatsmars/rocketmq/BrokerStartup.java
...ain/java/org/hongxi/whatsmars/rocketmq/BrokerStartup.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq-broker/src/main/java/org/hongxi/whatsmars/rocketmq/BrokerStartup2.java
...in/java/org/hongxi/whatsmars/rocketmq/BrokerStartup2.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq-namesrv/src/main/java/org/hongxi/whatsmars/rocketmq/NamesrvStartup.java
...in/java/org/hongxi/whatsmars/rocketmq/NamesrvStartup.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/rocketmq/config/spring/ClientConfig.java
...hongxi/whatsmars/rocketmq/config/spring/ClientConfig.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/rocketmq/config/spring/Consumer.java
...org/hongxi/whatsmars/rocketmq/config/spring/Consumer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/rocketmq/config/spring/Producer.java
...org/hongxi/whatsmars/rocketmq/config/spring/Producer.java
+1
-3
whatsmars-mq/whatsmars-mq-rocketmq-tools/src/main/java/org/hongxi/whatsmars/rocketmq/MQAdminStartup.java
...in/java/org/hongxi/whatsmars/rocketmq/MQAdminStartup.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/OrderPaidEvent.java
...va/org/hongxi/whatsmars/rocketmq/boot/OrderPaidEvent.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/ConsumerApplication.java
...whatsmars/rocketmq/boot/consumer/ConsumerApplication.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer.java
...g/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer2.java
.../hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer2.java
+2
-2
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/producer/ProducerApplication.java
...whatsmars/rocketmq/boot/producer/ProducerApplication.java
+2
-2
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/broadcast/PushConsumer.java
...org/hongxi/whatsmars/rocketmq/broadcast/PushConsumer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/ordermessage/Consumer.java
.../org/hongxi/whatsmars/rocketmq/ordermessage/Consumer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/ordermessage/Producer.java
.../org/hongxi/whatsmars/rocketmq/ordermessage/Producer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/quickstart/Consumer.java
...va/org/hongxi/whatsmars/rocketmq/quickstart/Consumer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/quickstart/Producer.java
...va/org/hongxi/whatsmars/rocketmq/quickstart/Producer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/AsyncProducer.java
...a/org/hongxi/whatsmars/rocketmq/simple/AsyncProducer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/CachedQueue.java
...ava/org/hongxi/whatsmars/rocketmq/simple/CachedQueue.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/Producer.java
...n/java/org/hongxi/whatsmars/rocketmq/simple/Producer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/PullConsumer.java
...va/org/hongxi/whatsmars/rocketmq/simple/PullConsumer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/PullConsumerTest.java
...rg/hongxi/whatsmars/rocketmq/simple/PullConsumerTest.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/PullScheduleService.java
...hongxi/whatsmars/rocketmq/simple/PullScheduleService.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/PushConsumer.java
...va/org/hongxi/whatsmars/rocketmq/simple/PushConsumer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/RandomAsyncCommit.java
...g/hongxi/whatsmars/rocketmq/simple/RandomAsyncCommit.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/TestProducer.java
...va/org/hongxi/whatsmars/rocketmq/simple/TestProducer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/spring/demo/Consumer.java
...a/org/hongxi/whatsmars/rocketmq/spring/demo/Consumer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/spring/demo/DemoMessageListener.java
...i/whatsmars/rocketmq/spring/demo/DemoMessageListener.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/spring/demo/Producer.java
...a/org/hongxi/whatsmars/rocketmq/spring/demo/Producer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/transaction/TransactionListenerImpl.java
...atsmars/rocketmq/transaction/TransactionListenerImpl.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/transaction/TransactionProducer.java
...i/whatsmars/rocketmq/transaction/TransactionProducer.java
+1
-1
whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-consumer.xml
...-rocketmq/src/main/resources/spring/rocketmq-consumer.xml
+2
-2
whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-producer.xml
...-rocketmq/src/main/resources/spring/rocketmq-producer.xml
+1
-1
未找到文件。
whatsmars-mq/whatsmars-mq-activemq-broker/src/main/java/org/hongxi/whatsmars/
mq/
activemq/broker/BrokerStartup.java
→
whatsmars-mq/whatsmars-mq-activemq-broker/src/main/java/org/hongxi/whatsmars/activemq/broker/BrokerStartup.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
activemq.broker
;
package
org.hongxi.whatsmars.activemq.broker
;
import
org.apache.activemq.broker.BrokerService
;
...
...
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/
mq/
activemq/Consumer.java
→
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/Consumer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
activemq
;
package
org.hongxi.whatsmars.activemq
;
import
org.apache.activemq.ActiveMQConnectionFactory
;
...
...
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/
mq/
activemq/Producer.java
→
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/Producer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
activemq
;
package
org.hongxi.whatsmars.activemq
;
import
org.apache.activemq.ActiveMQConnectionFactory
;
...
...
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/
mq/
activemq/boot/ActiveMQApplication.java
→
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/boot/ActiveMQApplication.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
activemq.boot
;
package
org.hongxi.whatsmars.activemq.boot
;
import
org.apache.activemq.command.ActiveMQQueue
;
import
org.springframework.boot.SpringApplication
;
...
...
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/
mq/
activemq/boot/Consumer.java
→
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/boot/Consumer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
activemq.boot
;
package
org.hongxi.whatsmars.activemq.boot
;
import
org.springframework.jms.annotation.JmsListener
;
import
org.springframework.stereotype.Component
;
...
...
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/
mq/
activemq/boot/Producer.java
→
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/boot/Producer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
activemq.boot
;
package
org.hongxi.whatsmars.activemq.boot
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.boot.CommandLineRunner
;
...
...
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/
mq/
activemq/spring/Consumer.java
→
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/spring/Consumer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
activemq.spring
;
package
org.hongxi.whatsmars.activemq.spring
;
import
org.springframework.context.support.ClassPathXmlApplicationContext
;
...
...
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/
mq/
activemq/spring/DemoMessageListener.java
→
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/spring/DemoMessageListener.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
activemq.spring
;
package
org.hongxi.whatsmars.activemq.spring
;
import
org.springframework.stereotype.Service
;
...
...
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/
mq/
activemq/spring/Producer.java
→
whatsmars-mq/whatsmars-mq-activemq/src/main/java/org/hongxi/whatsmars/activemq/spring/Producer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
activemq.spring
;
package
org.hongxi.whatsmars.activemq.spring
;
import
org.springframework.context.support.ClassPathXmlApplicationContext
;
import
org.springframework.jms.core.JmsTemplate
;
...
...
whatsmars-mq/whatsmars-mq-activemq/src/main/resources/spring/activemq-consumer.xml
浏览文件 @
cfa0f6fa
...
...
@@ -22,6 +22,6 @@
<property
name=
"sessionAcknowledgeMode"
value=
"2"
/>
</bean>
<bean
id=
"demoMessageListener"
class=
"org.hongxi.whatsmars.
mq.
activemq.spring.DemoMessageListener"
/>
<bean
id=
"demoMessageListener"
class=
"org.hongxi.whatsmars.activemq.spring.DemoMessageListener"
/>
</beans>
\ No newline at end of file
whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/
mq/
kafka/KafkaConsumer.java
→
whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/kafka/KafkaConsumer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
kafka
;
package
org.hongxi.whatsmars.kafka
;
import
kafka.consumer.ConsumerConfig
;
import
kafka.consumer.ConsumerIterator
;
...
...
whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/
mq/
kafka/KafkaProducer.java
→
whatsmars-mq/whatsmars-mq-kafka/src/main/java/org/hongxi/whatsmars/kafka/KafkaProducer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
kafka
;
package
org.hongxi.whatsmars.kafka
;
import
kafka.javaapi.producer.Producer
;
import
kafka.producer.KeyedMessage
;
...
...
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/
mq/
rabbitmq/Consumer.java
→
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/Consumer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rabbitmq
;
package
org.hongxi.whatsmars.rabbitmq
;
import
com.rabbitmq.client.Channel
;
import
com.rabbitmq.client.Connection
;
...
...
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/
mq/
rabbitmq/Producer.java
→
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/Producer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rabbitmq
;
package
org.hongxi.whatsmars.rabbitmq
;
import
com.rabbitmq.client.Channel
;
import
com.rabbitmq.client.Connection
;
...
...
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/
mq/
rabbitmq/boot/SampleAmqpSimpleApplication.java
→
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/boot/SampleAmqpSimpleApplication.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rabbitmq.boot
;
package
org.hongxi.whatsmars.rabbitmq.boot
;
import
org.springframework.amqp.core.Queue
;
import
org.springframework.amqp.rabbit.annotation.RabbitHandler
;
...
...
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/
mq/
rabbitmq/boot/Sender.java
→
whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/boot/Sender.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rabbitmq.boot
;
package
org.hongxi.whatsmars.rabbitmq.boot
;
import
org.springframework.amqp.rabbit.core.RabbitTemplate
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq-broker/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/BrokerStartup.java
→
whatsmars-mq/whatsmars-mq-rocketmq-broker/src/main/java/org/hongxi/whatsmars/rocketmq/BrokerStartup.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq
;
package
org.hongxi.whatsmars.rocketmq
;
/**
* Created by shenhongxi on 2017/6/21.
...
...
whatsmars-mq/whatsmars-mq-rocketmq-broker/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/BrokerStartup2.java
→
whatsmars-mq/whatsmars-mq-rocketmq-broker/src/main/java/org/hongxi/whatsmars/rocketmq/BrokerStartup2.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq
;
package
org.hongxi.whatsmars.rocketmq
;
/**
* Created by shenhongxi on 2017/6/21.
...
...
whatsmars-mq/whatsmars-mq-rocketmq-namesrv/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/NamesrvStartup.java
→
whatsmars-mq/whatsmars-mq-rocketmq-namesrv/src/main/java/org/hongxi/whatsmars/rocketmq/NamesrvStartup.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq
;
package
org.hongxi.whatsmars.rocketmq
;
/**
* Created by shenhongxi on 2017/6/21.
...
...
whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/config/spring/ClientConfig.java
→
whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/rocketmq/config/spring/ClientConfig.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.config.spring
;
package
org.hongxi.whatsmars.rocketmq.config.spring
;
import
org.apache.rocketmq.common.MixAll
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/config/spring/Consumer.java
→
whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/rocketmq/config/spring/Consumer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.config.spring
;
package
org.hongxi.whatsmars.rocketmq.config.spring
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/config/spring/Producer.java
→
whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/rocketmq/config/spring/Producer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.config.spring
;
package
org.hongxi.whatsmars.rocketmq.config.spring
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.rocketmq.client.producer.DefaultMQProducer
;
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
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq-tools/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/MQAdminStartup.java
→
whatsmars-mq/whatsmars-mq-rocketmq-tools/src/main/java/org/hongxi/whatsmars/rocketmq/MQAdminStartup.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq
;
package
org.hongxi.whatsmars.rocketmq
;
import
org.apache.rocketmq.common.MixAll
;
import
org.springframework.boot.SpringApplication
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/boot/OrderPaidEvent.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/OrderPaidEvent.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.boot
;
package
org.hongxi.whatsmars.rocketmq.boot
;
import
lombok.AllArgsConstructor
;
import
lombok.Data
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/boot/consumer/ConsumerApplication.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/ConsumerApplication.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.boot.consumer
;
package
org.hongxi.whatsmars.rocketmq.boot.consumer
;
import
org.springframework.boot.SpringApplication
;
import
org.springframework.boot.autoconfigure.SpringBootApplication
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/boot/consumer/MyConsumer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.boot.consumer
;
package
org.hongxi.whatsmars.rocketmq.boot.consumer
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.rocketmq.spring.starter.annotation.RocketMQMessageListener
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/boot/consumer/MyConsumer2.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer2.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.boot.consumer
;
package
org.hongxi.whatsmars.rocketmq.boot.consumer
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.rocketmq.spring.starter.annotation.RocketMQMessageListener
;
import
org.apache.rocketmq.spring.starter.core.RocketMQListener
;
import
org.hongxi.whatsmars.
mq.
rocketmq.boot.OrderPaidEvent
;
import
org.hongxi.whatsmars.rocketmq.boot.OrderPaidEvent
;
import
org.springframework.stereotype.Service
;
@Slf4j
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/boot/producer/ProducerApplication.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/producer/ProducerApplication.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.boot.producer
;
package
org.hongxi.whatsmars.rocketmq.boot.producer
;
import
org.apache.rocketmq.spring.starter.core.RocketMQTemplate
;
import
org.hongxi.whatsmars.
mq.
rocketmq.boot.OrderPaidEvent
;
import
org.hongxi.whatsmars.rocketmq.boot.OrderPaidEvent
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.boot.CommandLineRunner
;
import
org.springframework.boot.SpringApplication
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/broadcast/PushConsumer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/broadcast/PushConsumer.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.broadcast
;
package
org.hongxi.whatsmars.rocketmq.broadcast
;
import
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer
;
import
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/ordermessage/Consumer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/ordermessage/Consumer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.ordermessage
;
package
org.hongxi.whatsmars.rocketmq.ordermessage
;
import
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer
;
import
org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/ordermessage/Producer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/ordermessage/Producer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.ordermessage
;
package
org.hongxi.whatsmars.rocketmq.ordermessage
;
import
org.apache.rocketmq.client.producer.DefaultMQProducer
;
import
org.apache.rocketmq.client.producer.MessageQueueSelector
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/quickstart/Consumer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/quickstart/Consumer.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.quickstart
;
package
org.hongxi.whatsmars.rocketmq.quickstart
;
import
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer
;
import
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/quickstart/Producer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/quickstart/Producer.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.quickstart
;
package
org.hongxi.whatsmars.rocketmq.quickstart
;
import
org.apache.rocketmq.client.exception.MQClientException
;
import
org.apache.rocketmq.client.producer.DefaultMQProducer
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/simple/AsyncProducer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/AsyncProducer.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.simple
;
package
org.hongxi.whatsmars.rocketmq.simple
;
import
org.apache.rocketmq.client.exception.MQClientException
;
import
org.apache.rocketmq.client.producer.DefaultMQProducer
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/simple/CachedQueue.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/CachedQueue.java
浏览文件 @
cfa0f6fa
...
...
@@ -15,7 +15,7 @@
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.simple
;
package
org.hongxi.whatsmars.rocketmq.simple
;
import
org.apache.rocketmq.common.message.MessageExt
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/simple/Producer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/Producer.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.simple
;
package
org.hongxi.whatsmars.rocketmq.simple
;
import
org.apache.rocketmq.client.exception.MQClientException
;
import
org.apache.rocketmq.client.producer.DefaultMQProducer
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/simple/PullConsumer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/PullConsumer.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.simple
;
package
org.hongxi.whatsmars.rocketmq.simple
;
import
org.apache.rocketmq.client.consumer.DefaultMQPullConsumer
;
import
org.apache.rocketmq.client.consumer.PullResult
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/simple/PullConsumerTest.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/PullConsumerTest.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.simple
;
package
org.hongxi.whatsmars.rocketmq.simple
;
import
org.apache.rocketmq.client.consumer.DefaultMQPullConsumer
;
import
org.apache.rocketmq.client.consumer.PullResult
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/simple/PullScheduleService.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/PullScheduleService.java
浏览文件 @
cfa0f6fa
...
...
@@ -15,7 +15,7 @@
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.simple
;
package
org.hongxi.whatsmars.rocketmq.simple
;
import
org.apache.rocketmq.client.consumer.*
;
import
org.apache.rocketmq.client.exception.MQClientException
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/simple/PushConsumer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/PushConsumer.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.simple
;
package
org.hongxi.whatsmars.rocketmq.simple
;
import
org.apache.rocketmq.client.consumer.DefaultMQPushConsumer
;
import
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/simple/RandomAsyncCommit.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/RandomAsyncCommit.java
浏览文件 @
cfa0f6fa
...
...
@@ -15,7 +15,7 @@
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.simple
;
package
org.hongxi.whatsmars.rocketmq.simple
;
import
org.apache.rocketmq.common.message.MessageExt
;
import
org.apache.rocketmq.common.message.MessageQueue
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/simple/TestProducer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/simple/TestProducer.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.simple
;
package
org.hongxi.whatsmars.rocketmq.simple
;
import
org.apache.rocketmq.client.QueryResult
;
import
org.apache.rocketmq.client.exception.MQClientException
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/spring/demo/Consumer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/spring/demo/Consumer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.spring.demo
;
package
org.hongxi.whatsmars.rocketmq.spring.demo
;
import
org.springframework.context.support.ClassPathXmlApplicationContext
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/spring/demo/DemoMessageListener.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/spring/demo/DemoMessageListener.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.spring.demo
;
package
org.hongxi.whatsmars.rocketmq.spring.demo
;
import
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext
;
import
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/spring/demo/Producer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/spring/demo/Producer.java
浏览文件 @
cfa0f6fa
package
org.hongxi.whatsmars.
mq.
rocketmq.spring.demo
;
package
org.hongxi.whatsmars.rocketmq.spring.demo
;
import
org.apache.rocketmq.client.producer.DefaultMQProducer
;
import
org.apache.rocketmq.client.producer.SendResult
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/transaction/TransactionListenerImpl.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/transaction/TransactionListenerImpl.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.transaction
;
package
org.hongxi.whatsmars.rocketmq.transaction
;
import
org.apache.rocketmq.client.producer.LocalTransactionState
;
import
org.apache.rocketmq.client.producer.TransactionListener
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/
mq/
rocketmq/transaction/TransactionProducer.java
→
whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/transaction/TransactionProducer.java
浏览文件 @
cfa0f6fa
...
...
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
org.hongxi.whatsmars.
mq.
rocketmq.transaction
;
package
org.hongxi.whatsmars.rocketmq.transaction
;
import
org.apache.rocketmq.client.exception.MQClientException
;
import
org.apache.rocketmq.client.producer.SendResult
;
...
...
whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-consumer.xml
浏览文件 @
cfa0f6fa
...
...
@@ -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.config.spring.Consumer"
>
<bean
class=
"org.hongxi.whatsmars.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"
/>
...
...
@@ -13,5 +13,5 @@
<property
name=
"messageListener"
ref=
"demoMessageListener"
/>
</bean>
<bean
id=
"demoMessageListener"
class=
"org.hongxi.whatsmars.
mq.
rocketmq.spring.demo.DemoMessageListener"
/>
<bean
id=
"demoMessageListener"
class=
"org.hongxi.whatsmars.rocketmq.spring.demo.DemoMessageListener"
/>
</beans>
\ No newline at end of file
whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-producer.xml
浏览文件 @
cfa0f6fa
...
...
@@ -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.config.spring.Producer"
>
<bean
id=
"defaultMQProducer"
class=
"org.hongxi.whatsmars.rocketmq.config.spring.Producer"
>
<property
name=
"producerGroup"
value=
"quick_start_producer_group"
/>
<property
name=
"namesrvAddr"
value=
"127.0.0.1:9876"
/>
</bean>
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录