【发布时间】:2015-02-02 18:34:03
【问题描述】:
我正在尝试将消息放入 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 标头的消息。有人可以帮助我了解问题出在哪里吗?可以在消费端吗?可能是错误或缺少 SPLUNK 配置??
【问题讨论】: