java - 使用 JMS 将消息放入 MQ 队列并使用 SPLUNK 的消息

Question

我正在尝试将消息放入 MQ 队列。这是我的源代码:

        QueueConnection queueConn;
        QueueSession queueSession;
        QueueSender queueSender;

        queueConn = connectionFactory.getConnection();
        queueSession = queueConn.createQueueSession(false,
                Session.AUTO_ACKNOWLEDGE);
        queueSender = queueSession.createSender(queueSession
                .createQueue(KEY_CONFIG_QUEUE_NAME));
        queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

        TextMessage message = queueSession.createTextMessage(logBase);

        queueSender.send(message);

我没有来自队列消费者的源代码，也就是将消息发送到 SPLUNK 的源代码。但是在 SPLUNK 控制台，我可以意识到消息是由 JMS HEADER + 我的文本消息 (logBase) 组成的。

我喜欢没有 JMS header 的消息。有人可以帮助我了解问题出在哪里吗？可以在消费者那里吗？可能是 SPLUNK 配置错误或缺失？？

Answer 1

假设您无法在消费者处更改源代码，则有一种管理方式可以做到这一点。您可以更改队列定义，以便不将这些消息属性提供给获取应用程序。

ALTER QLOCAL(q-name) PROPCTL(NONE)

相关链接

• PROPCTL queue options