1.applicationContext-jms.xml 配制内容如果下
<!--jndi环境配制-->
<bean id="jndiTemplate"
class="org.springframework.jndi.JndiTemplate">
<property name="environment">
<props>
<prop key="java.naming.factory.initial">
weblogic.jndi.WLInitialContextFactory
</prop>
<prop key="java.naming.provider.url">
t3://127.0.0.1:7001
</prop>
<prop key="java.naming.factory.url.pkgs">
weblogic.jndi.factories
</prop>
<prop key="java.naming.security.principal">
weblogic
</prop>
<prop key="java.naming.security.credentials">
12345678
</prop>
</props>
</property>
</bean>
<!--连接工厂配制-->
<bean id="jmsConnectionFactory"
class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="myConnectionFactory-0" />
<property name="jndiTemplate" ref="jndiTemplate" />
</bean>
<bean id="singleConnectionFactory"
class="org.springframework.jms.connection.SingleConnectionFactory102">
<property name="targetConnectionFactory"
ref="jmsConnectionFactory" />
<property name="clientId" value="sp_receiver" /><!-- receiver client id -->
</bean>
<!--消息队列-->
<bean id="jmsQueue"
class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="myQueue" />
<property name="jndiTemplate" ref="jndiTemplate" />
</bean>
<bean id="jmsTopic"
class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="mYTopic" />
<property name="jndiTemplate" ref="jndiTemplate" />
</bean>
<bean id="jmsReceiver" class="com.vst.test.jms.MyMessageListener" />
<!--接收端配制-->
<bean id="listenerQueue"
class="org.springframework.jms.listener.DefaultMessageListenerContainer102">
<property name="connectionFactory" ref="singleConnectionFactory" />
<property name="destination" ref="jmsQueue" />
<property name="messageListener" ref="jmsReceiver" />
<property name="autoStartup" value="true" />
</bean>
<bean id="listenerTopic"
class="org.springframework.jms.listener.DefaultMessageListenerContainer102">
<property name="connectionFactory" ref="singleConnectionFactory" />
<property name="destination" ref="jmsTopic" />
<property name="messageListener" ref="jmsReceiver" />
<property name="pubSubDomain" value="true" />
<property name="autoStartup" value="true" />
</bean>
<!--发送端配制-->
<bean id="jmsTemplate"
class="org.springframework.jms.core.JmsTemplate102">
<property name="connectionFactory"
ref="jmsConnectionFactory" />
<property name="defaultDestination" ref="jmsTopic" />
<property name="pubSubDomain" value="true" />
<property name="explicitQosEnabled" value="true" />
</bean>
<bean id="jmsTopicProducter"
class="com.vst.test.jms.TestSend">
<property name="jmsTemplate" ref="jmsTemplate" />
</bean>
配制文件完成,接下来看程序
发送端:
public class TestSend {
private JmsTemplate102 jmsTemplate;
public void setJmsTemplate(JmsTemplate102 jmsTemplate) {
this.jmsTemplate = jmsTemplate;
}
public void sendTopicMsg(final String msg){
try {
this.jmsTemplate.send(new MessageCreator() {
public Message createMessage(Session session)
throws JMSException {
MessageObj mObj=new MessageObj();
mObj.setMsgText(msg);
Message message = session.createObjectMessage();
((ObjectMessage) message).setObject((Serializable) mObj);
return message;
}
});
} catch (Exception e) {
e.printStackTrace();
}
}
}
接收端:
public class TopicListener implements MessageListener {
public void onMessage(Message message) {
try {
if (message instanceof ObjectMessage) {
ObjectMessage objM=(ObjectMessage)message;
MessageObj mObj=(MessageObj)objM.getObject();
System.out.println(mObj.getMsgText());
}else if(message instanceof TextMessage){
TextMessage tm=(TextMessage)message;
System.out.println(tm.getText());
}
} catch (JMSException e) {
e.printStackTrace();
}
}
}
分享到:
相关推荐
NULL 博文链接:https://jackaney.iteye.com/blog/1276918
这是本人搭建的Spring框架,集成了Weblogic JMS,测试已经完成。现提供给大家下载学习。
webwork2.1.7+spring+hibernate3+oracle+weblogic8.1登录示例(详解): 通过输入用户名查询出数据库中的对应数据
NULL 博文链接:https://a3mao.iteye.com/blog/313531
\桌面\linux jboss\Linux+++JDK+++WebLogic+Server++Oracle+的安装配置过程.rar
myeclips+weblogic文档配置文档配置
Oracle+Weblogic+Server+Java反序列化漏洞 解决方案 Oracle+Weblogic+Server+Java反序列化漏洞 解决方案
图解eclipse+myelcipse+weblogic开发EJB .doc
Extjs3.2+struts2.0+spring2.5+hibernate3.5+weblogic10+oracle10g 第4部分
AIX+ORACLE9i+WEBLOGIC81安装实施.rar pdf文件 中文
Extjs3.2+struts2.0+spring2.5+hibernate3.5+weblogic10+oracle10g含全包 共5 部分 全部下载后解压缩
Extjs3.2+struts2.0+spring2.5+hibernate3.5+weblogic10+oracle10g含全包 第三部分
Extjs3.2+struts2.0+spring2.5+hibernate3.5+weblogic10+oracle10g含全包 共5 部分 全部下载后解压缩
AIX+HACMP+ORACLE9i+WEBLOGIC81安装实施AIX+HACMP+ORACLE9i+WEBLOGIC81安装实施
5.单数据源配置(兼容Tomcat和Weblogic)。 6.Hibernate继承 HibernateDaoSupport。 7.Spring+Junit4单元测试,优点:不会破坏数据库现场,等等。 2)Demo 导入说明: 1.Eclipse Encoding:GBK 2.Eclipse 导入后可能...
Linux更换JDK+weblogic更换JDK 全局更换JDK Linux更换JDK+weblogic更换JDK 全局更换JDK
搭建Eclipse3.2.2+MyEclipse5.5+Tomcat+Weblogic
weblogic中使用JMS发送和接受消息(Queue and TOPIC)
我在建站过程中手机的一些资料,分享给大家。Linux+WebLogic+Oracle建站参考资料
HR伴侣技术培训之Apache服务器基础知识.配置好的,可以直接拿来用,亦可当作学习的例子!