如何不通过 solace JMS 发送有保证的消息

Question

我有一个非常简单的生产者类型程序，它尝试向主题发送 ByteMessage。

我的程序收到错误com.solacesystems.jms.ConfigurationException: Error sending message - operation not supported on router (Cannot send assured message: Assured message delivery is not enabled on this channel.)

如何确保发送的消息不是有保证的消息？这是一些安慰配置变量吗？这是我尝试使用的简单 JMS 相关代码，其中bytes 是我要发送的对象：

val connection = connectionFactory.createConnection()
val session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
val publishDestination = session.createTopic(solace.TOPIC)
val message = new SolBytesMessage()
message.writeBytes(bytes)
val producer = session.createProducer(publishDestination)
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT)
log.info("Sending message")
producer.send(publishDestination, message)

Answer 1

请确认Direct Transport 已在设备的连接出厂设置中选中。

连接工厂中的Direct Transport 设置控制用于非持久消息的传输。

Answer 2

这可以通过执行 QOS 来解决：

    JmsTemplate jmsTemplate = new JmsTemplate(cachingConnectionFactory);
    jmsTemplate.setDefaultDestinationName(topic);
    jmsTemplate.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
    jmsTemplate.setExplicitQosEnabled(true);