JMS消息头
@Override public void onMessage(Message msg) { try { //消息的持久化模式,2代表持久化;1代表非持久化 System.out.println(msg.getJMSDeliveryMode()); //指定消息什么时候过期,默认0永不过期 //只有在这个有效期内，消息消费者才可以消费这个消息 System.out.println(msg.getJMSExpiration()); //消息的唯一标识符，通常以"ID:"开头，其他字符应由服务器生成 System.out.println(msg.getJMSMessageID()); //消息的优先级别，支持0~9个优先级。默认是4 System.out.println(msg.getJMSPriority()); //判断消息是否为重复发送的标志 //因为有时消费者没有确认他已经收到消息或者JMS提供者不确定消费者是否已经收到 System.out.println(msg.getJMSRedelivered()); //消息发送的时间戳 //当发送者调用send()方法的时候，JMSTimestamp会被自动设置为当前时间 System.out.println(msg.getJMSTimestamp()); // 开发者的自定义消息类型 System.out.println(msg.getJMSType()); //消息的目的地类型及名称 System.out.println(msg.getJMSDestination()); //有时消息生产者希望消费者回复一个消息，JMSReplyTo为一个Destination，表示需要回复的目的地,当然消费者可以不理会它 System.out.println(msg.getJMSReplyTo()); // 通常用来关联多个Message。例如需要回复一个消息，可以把JMSCorrelationID设置为所收到的消息的JMSMessageID System.out.println(msg.getJMSCorrelationID()); } catch (JMSException e) { e.printStackTrace(); } }
?
