activemq與spring整合,配置消費(fèi)者監(jiān)聽器設(shè)置sessionAcknowledgeMode

LiuRhoRamen 發(fā)布于2019-08-14 17:47 / 2861人閱讀

摘要：最近在研究的消息確認(rèn)機(jī)制，在與整合時(shí)遇到的了一個(gè)問題。這時(shí)只需要把的值設(shè)置成自定義的類型即可。

最近在研究activemq的ack消息確認(rèn)機(jī)制，在activemq與spring整合時(shí)遇到的了一個(gè)問題。
JMS規(guī)范的ack消息確認(rèn)機(jī)制有一下四種，定于在session對(duì)象中：
AUTO_ACKNOWLEDGE = 1 ：自動(dòng)確認(rèn)
CLIENT_ACKNOWLEDGE = 2：客戶端手動(dòng)確認(rèn)
DUPS_OK_ACKNOWLEDGE = 3：自動(dòng)批量確認(rèn)
SESSION_TRANSACTED = 0：事務(wù)提交并確認(rèn)
但是在activemq補(bǔ)充了一個(gè)自定義的ACK模式:
INDIVIDUAL_ACKNOWLEDGE = 4：?jiǎn)螚l消息確認(rèn)

如果想設(shè)置ack消息確認(rèn)機(jī)制為客戶端手動(dòng)確認(rèn)，在spring總配置消費(fèi)者監(jiān)聽器的時(shí)候，設(shè)置sessionAcknowledgeMode的值為2，代碼如下：

但這樣設(shè)置是無效的，請(qǐng)看spring類org.springframework.jms.listener.AbstractMessageListenerContainer的一段源碼：

protected void commitIfNecessary(Session session, Message message) throws JMSException {
        // Commit session or acknowledge message.
        if (session.getTransacted()) {
            // Commit necessary - but avoid commit call within a JTA transaction.
            if (isSessionLocallyTransacted(session)) {
                // Transacted session created by this container -> commit.
                JmsUtils.commitIfNecessary(session);
            }
        }
        else if (message != null && isClientAcknowledge(session)) {
            message.acknowledge();
        }
    }

protected boolean isClientAcknowledge(Session session) throws JMSException {
        return (session.getAcknowledgeMode() == Session.CLIENT_ACKNOWLEDGE);
}

就是當(dāng)設(shè)置sessionAcknowledgeMode為2時(shí)，雖然是客戶端手動(dòng)確認(rèn)，但是卻被spring自動(dòng)確認(rèn)了，造成設(shè)置無效。這時(shí)只需要把sessionAcknowledgeMode的值設(shè)置成activemq自定義的類型INDIVIDUAL_ACKNOWLEDGE = 4即可。