提交 4c332f5e 编写于 作者: 武汉红喜's avatar 武汉红喜

move rocketmq spring demo

上级 2ee02595
......@@ -4,7 +4,7 @@ import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Consumer {
public static void main(String[] args) {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/rocketmq-consumer.xml");
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("rocketmq-consumer.xml");
context.registerShutdownHook();
}
}
......@@ -7,7 +7,7 @@ import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Producer {
public static void main(String[] args) {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring/rocketmq-producer.xml");
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("rocketmq-producer.xml");
RocketMQTemplate rocketMQTemplate = (RocketMQTemplate) context.getBean("rocketMQTemplate");
for (int i = 0; i < 20; i++) {
try {
......
......@@ -7,7 +7,7 @@
<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="namesrvAddr" value="10.2.4.63:9876" />
<property name="topic" value="sdk-test" />
<property name="tags" value="*" />
<property name="messageListener" ref="demoMessageListener" />
......
......@@ -7,7 +7,7 @@
<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" />
<property name="namesrvAddr" value="10.2.4.63:9876" />
</bean>
<bean id="rocketMQTemplate" class="org.hongxi.whatsmars.rocketmq.config.spring.RocketMQTemplate">
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册