Posted on 2016-10-12 16:32
Milo的海域 閱讀(1538)
評論(0) 編輯 收藏 所屬分類:
Java
用Spring JMS 的JmsTemplate從消息隊列消費消息時發現，使用了CLIENT_ACKNOWLEDGE模式，消息返回后總是自動被ack，也就是被broker "Dequeued"
protected Message doReceive(Session session, MessageConsumer consumer) throws JMSException {
try {
// Use transaction timeout (if available).
long timeout = getReceiveTimeout();
JmsResourceHolder resourceHolder =
(JmsResourceHolder) TransactionSynchronizationManager.getResource(getConnectionFactory());
if (resourceHolder != null && resourceHolder.hasTimeout()) {
timeout = Math.min(timeout, resourceHolder.getTimeToLiveInMillis());
}
Message message = doReceive(consumer, timeout);
if (session.getTransacted()) {
// Commit necessary - but avoid commit call within a JTA transaction.
if (isSessionLocallyTransacted(session)) {
// Transacted session created by this template -> commit.
JmsUtils.commitIfNecessary(session);
}
}
else if (isClientAcknowledge(session)) {
// Manually acknowledge message, if any.
if (message != null) {
message.acknowledge();
}
}
return message;
}
finally {
JmsUtils.closeMessageConsumer(consumer);
}
}
但是使用異步listener 就不會出現這個情況，搜了下google，發現果然存在這個問題
https://jira.spring.io/browse/SPR-12995
https://jira.spring.io/browse/SPR-13255
http://louisling.iteye.com/blog/241073
同步方式拉取消息，暫時沒找到好的封裝，只能暫時用這。或者盡量用listener, 這個問題暫時標記下，或者誰有更好的解決方案可以comment我