package com.lcd.activemq;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
public class Sender {
@Autowired
@Qualifier(value = "jmsTemplate")
private JmsTemplate jmsTemplate;
public void sender(final String message) {
jmsTemplate.send(new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
StringBuilder sb = new StringBuilder();
sb.append("Hello activeMQ ====>message:" + message);
return session.createObjectMessage(sb.toString());
}
});
}
}
没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
收起资源包目录
activeamq.zip (33个子文件)
activeamq
.project 1KB
src
main
webapp
WEB-INF
web.xml 222B
resources
mq-env.xml 2KB
mq-config.properties 161B
applicationContext.xml 717B
mq-producer.xml 363B
mq-consumer.xml 939B
java
com
lcd
activemq
TestApp.java 529B
Sender.java 804B
Receiver.java 181B
target
m2e-wtp
web-resources
META-INF
MANIFEST.MF 114B
maven
activemq
com.lcd.activeamq
pom.properties 230B
pom.xml 3KB
classes
mq-env.xml 2KB
mq-config.properties 161B
applicationContext.xml 717B
mq-producer.xml 363B
com
lcd
activemq
Sender.class 915B
TestApp.class 1KB
Receiver.class 581B
Sender$1.class 1KB
mq-consumer.xml 939B
test-classes
.settings
org.eclipse.wst.jsdt.ui.superType.container 49B
org.eclipse.wst.common.project.facet.core.xml 252B
org.eclipse.m2e.core.prefs 90B
org.eclipse.jdt.core.prefs 430B
org.eclipse.wst.validation.prefs 50B
org.eclipse.wst.jsdt.ui.superType.name 6B
org.eclipse.core.resources.prefs 57B
org.eclipse.wst.common.component 668B
.jsdtscope 639B
pom.xml 3KB
.classpath 1KB
共 33 条
- 1
资源评论
- 年轻人20002020-08-01demo不能用
Chengdu_Li
- 粉丝: 11
- 资源: 13
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功