通过MessageProducer的setJMSDeliveryMode方法设置的模式可以影响发送消息的传送模式,为什么通过message.setJMSDeliveryMode设置的传递模式却没有影响传送消息的传递模式,
下面以Queue为例来看下为什么会出现上面的情况:
ActiveMQMessageProducerSupport:
public void send(Message message) throws JMSException {
this.send(this.getDestination(),
message,
this.defaultDeliveryMode,
this.defaultPriority,
this.defaultTimeToLive);
}
看到这里就应该明白了,通过message对象设置消息的delivermode不会影响messageproducer传递消息时的传递模式,但是通过messageproducer的setJMSDeliveryMode修改传递模式时:
public void setDeliveryMode(int newDeliveryMode) throws JMSException {
if (newDeliveryMode != DeliveryMode.PERSISTENT && newDeliveryMode != DeliveryMode.NON_PERSISTENT) {
throw new javax.jms.IllegalStateException("unknown delivery mode: " + newDeliveryMode);
}
checkClosed();
this.defaultDeliveryMode = newDeliveryMode;
}
相信通过上面两个方法对比,大家应该知道其中缘由了!
当然也可以通过producer的另一个重载方法来显性设置某个消息的传递模式:
send(
Destination destination,
Message message,
int deliveryMode, //直接传入传递模式
int priority,
long timeToLive)