Posted on 2016-10-12 16:32
Milo的海域 閱讀(1537)
評(píng)論(0) 編輯 收藏 所屬分類:
Java
用Spring JMS 的JmsTemplate從消息隊(duì)列消費(fèi)消息時(shí)發(fā)現(xiàn)，使用了CLIENT_ACKNOWLEDGE模式，消息返回后總是自動(dòng)被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 就不會(huì)出現(xiàn)這個(gè)情況，搜了下google，發(fā)現(xiàn)果然存在這個(gè)問題
https://jira.spring.io/browse/SPR-12995
https://jira.spring.io/browse/SPR-13255
http://louisling.iteye.com/blog/241073
同步方式拉取消息，暫時(shí)沒找到好的封裝，只能暫時(shí)用這。或者盡量用listener, 這個(gè)問題暫時(shí)標(biāo)記下，或者誰(shuí)有更好的解決方案可以comment我