如何为JMS客户端设置持久性？

Question

我使用使用SSL的安全通道通过JMS与Weblogic IBM Webpsphere MQ建立了连接。我在Weblogic上的应用程序收到了来自MQ的消息。正在将应答发送到应答队列。响应头存在MQMD，它填充java。在参数持久化JMS发送值“1”中。其他系统需要在持久化时接收值“0”。如何将此参数设置为java？我猜这个参数是javax。jms。deliverymode。但我不知道怎么设置。

无论如何，谢谢你的帮助。

Answer 1

I 0x5a4d的答案是可以的，但最好像IBM最佳实践那样使用它

//Persistentmode = 1 
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
//Persistentmode = 2 
producer.setDeliveryMode(DeliveryMode.PERSISTENT);

Answer 2

你应该这样尝试：

public String sendMessage(ConnectionFactory connectionFactory,
                      Destination destination,
                      Destination jmsReplyTo,
                      CorrelationType correlationType,
                      CallOptions<String> callOptions,
                      String rqUid,
                      JMSAbstract transport) throws JMSException {
Connection connection = null;
Session session = null;
MessageProducer producer = null;

try {

    connection = connectionFactory.createConnection();
    session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

    producer = session.createProducer(destination);

    // Set JMS DeliverMode (1/2)
    producer.setDeliveryMode(1);

    // create message
    Message message = createTextMessage(session, jmsReplyTo, correlationType, callOptions, rqUid, transport);

    // send message
    producer.send(message);

    return correlationType.getCorrelationId(message);

    } finally {
        closeResource(connection, session, null, producer, rqUid);
    }
}

这只是一个java示例。您还可以在IBM WebSphere的队列配置中设置持久性标志。我的意思是MQQueue具有方法setPersistence。如果在项目中使用IBM java对象，可以通过调用该方法设置持久性：

MQQueue mqQueue = new MQQueue("QueueName");
mqQueue.setPersistence(1);

Answer 3

JMS上的相应属性是传递模式（要设置的Int参数），用于设置持久和非持久消息。

您可以参考此URL从IBM详细信息