快速业务通道

spring整合activeMq并调试JMS - 编程入门网

作者 佚名技术 来源 NET编程 浏览 发布时间 2012-06-14
           long sendTime = textMsg.getJMSTimestamp();      Date date = new Date(sendTime);      DateFormat f = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");      String temp = f.format(date);               System.out.println("消息发送时间:" + temp);          System.out.println("消息失效时间:" + textMsg.getJMSExpiration()); // 这里是一个 整 型值 0 表示 该消息永远不会过期      System.out.println("消息优先级:" + textMsg.getJMSPriority()); // 优先级 0~9, 0 表 示最低      System.out.println("关联编码:" + textMsg.getJMSCorrelationID());                   System.out.println("回复消息的地址:" + textMsg.getJMSReplyTo());    // 回复消 息的地址(Destination类型),由发送者设定      System.out.println("消息类型:" + textMsg.getJMSType()); // jms 不使用该字段, 一般 类型是由 用户自己定义      System.out.println("是否签收过:" + textMsg.getJMSRedelivered()); // 如果是 真 ,表 示客户端收到过该消息,但是并没有签收               // 消息属性 (properties)          System.out.println("用户编码:" + textMsg.getStringProperty("JMSXUserID"));      System.out.println("应用程序编码:" + textMsg.getStringProperty("JMSXApp1ID"));      System.out.println("已经尝试发送消息的次数:" + textMsg.getStringProperty ("JMSXDeliveryCount"));                        //     消息体(body) 中传递的内容          System.out.println("消息内容:" + textMsg.getText());                        }catch(JMSException e){      e.printStackTrace();      }catch(Exception e){      e.printStackTrace();      } } }

spring整合activeMq并调试JMS(4)

时间:2011-11-02 未知

5:测试发送消息的类:

public class TestMessageSender { 
private static ApplicationContext ctx = null; 
    
static{ 
     ctx = new FileSystemXmlApplicationContext(new String[] { "WebRoot/jms_sender.xml" 

}); 
} 
    
public static void sentTextMsg(){ 
     MessageSender messageSender = (MessageSender)ctx.getBean("messageSender"); 
     messageSender.sendTextMsg("这个世界真的很无奈!"); 
} 
    
public static void main(String[] args){ 
     sentTextMsg(); 
} 
}

6:测试接收消息的类:

public class TestMessageReceiver { 
    
private static ApplicationContext ctx = null; 
static { 
     ctx = new FileSystemXmlApplicationContext(new String[] { "WebRoot/jms_receiver.xml" 

}); 
} 
public static void getTextMsg(){ 
     MessageReceiver messageSender = (MessageReceiver) ctx.getBean("messageReceiver"); 
     messageSender.receiverTextMsg(); 
} 
    
public static void main(String[] args) { 
     getTextMsg(); 
} 
}

7: 测试结果:

消息编码:ID:hc-369a3f54b2b0-1440-1224731999968-1:0:1:1:1
目标对象:

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务,公司网站:http://www.lingzhong.cn 为了给广大客户了解更多的技术信息,本技术文章收集来源于网络,凌众科技尊重文章作者的版权,如果有涉及你的版权有必要删除你的文章,请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息,谢谢!

分享到: 更多

Copyright ©1999-2011 厦门凌众科技有限公司 厦门优通互联科技开发有限公司 All rights reserved

地址(ADD):厦门软件园二期望海路63号701E(东南融通旁) 邮编(ZIP):361008

电话:0592-5908028 传真:0592-5908039 咨询信箱:web@lingzhong.cn 咨询OICQ:173723134

《中华人民共和国增值电信业务经营许可证》闽B2-20100024  ICP备案:闽ICP备05037997号