正在加载图片...
/TODO Auto-generated method stub 注意:以上代码中声明的这个消息驱动Bean使用的消息目的是“jms/MyMDB”。ationConfig 声明消息的确认模式和消息目的类型(队列)。 4.在onMessage方法中漆加对消息处理的代码 这里假设接收的消息是TextMessage类型、object类型、Map类型、Stream类型,接 收到消息之后把消息输出到控制台。 修政onMessage方法,类MyMDB完整代码如下: package cn.edu.jms.impl; import java.io.ByteArrayoutputstream; import javax.ejb.ActivationConfigProperty import javax.ejb.MessageDriven; import javax.jms.BytesMessage; import javax.jms.MapMessage import s.Message import javax.jms.MessageListener. import iavax.ims.obiectMessage: import iavax.ims.StreamMessage import javax.jms.TextMessage import cn.edu.jms.bean.Man; eMessageDriven(activationconfig propertyvalue="javax.jms.Queue") eActivationconfigProperty(propertyName="destination", propertyvalue="ims/MyMDB1"). @ActivationconfigProperty(propertyName="acknowledgeMode", propertyValue="Auto-acknowledge") public class MyMDB implements MessageListener public void onMessage(Message msg)( try if (msg instanceof TextMessage)( TextMessage tmsg (TextMessage)msg String content tmsg.getText () System.out.printin(content); // TODO Auto-generated method stub } } 注意:以上代码中声明的这个消息驱动 Bean 使用的消息目的是“jms/MyMDB”。ationConfig 声明消息的确认模式和消息目的类型(队列)。 4.在 onMessage 方法中添加对消息处理的代码。 这里假设接收的消息是 TextMessage 类型、Object 类型、Map 类型、Stream 类型,接 收到消息之后把消息输出到控制台。 修改 onMessage 方法,类 MyMDB 完整代码如下: package cn.edu.jms.impl; import java.io.ByteArrayOutputStream; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; import javax.jms.BytesMessage; import javax.jms.MapMessage; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.ObjectMessage; import javax.jms.StreamMessage; import javax.jms.TextMessage; import cn.edu.jms.bean.Man; @MessageDriven(activationConfig = { @ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"), @ActivationConfigProperty(propertyName="destination", propertyValue="jms/MyMDB1"), @ActivationConfigProperty(propertyName="acknowledgeMode", propertyValue="Auto-acknowledge") }) public class MyMDB implements MessageListener { public void onMessage(Message msg) { try { if (msg instanceof TextMessage) { TextMessage tmsg = (TextMessage) msg; String content = tmsg.getText(); System.out.println(content);
<<向上翻页向下翻页>>
©2008-现在 cucdc.com 高等教育资讯网 版权所有