关于spring+activemq的问题

Question

环境：spring+activemq

错误：在spring配置文件中配置了两个不同container，两个container使用同一个自定义listener。

启动服务后的现象是：每隔5秒钟，控制台打印出：

[INFO ] [2012-12-13 15:59:09] [FailoverTransport:doReconnect:878] Successfully connected to tcp://127.0.0.1:61616?wireFormat.maxInactivityDuration=10000

进行一次重连。

换用不同的listener就不出现了。

两个container配置

<bean id="TopicContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="topicListenConnectionFactory"/>
        <property name="destination" ref="Topic"/>
        <property name="messageListener" ref="actMessageListener"/>
        <!-- JMS Selector消息过滤器 -->
        <!--<property name="messageSelector" value="objectType='user'"/>-->
        <!-- 持久化订阅者 -->
        <property name="subscriptionDurable" value="true"/>
        <property name="autoStartup" value="true"/>
    </bean>

 <!-- 异步接收Topic消息Container -->
    <bean id="entityUpdateTopicContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="topicListenConnectionFactory"/>
        <property name="destination" ref="cacheTopic"/>
        <property name="messageListener" ref="actMessageListener"/>
        <!-- JMS Selector消息过滤器 -->
        <!--<property name="messageSelector" value="objectType='user'"/>-->
        <!-- 持久化订阅者 -->
        <property name="subscriptionDurable" value="true"/>
    </bean>

Answer 1

好吧，自己找到答案了。

public void setMessageListener(Object messageListener) {
		checkMessageListener(messageListener);
		this.messageListener = messageListener;
		if (this.durableSubscriptionName == null) {
			this.durableSubscriptionName = getDefaultSubscriptionName(messageListener);
		}
	}

因为没有设置durableSubscriptionName，都设置为了listener类的名字，导致

String clientId = context.getClientId();
            String subscriptionName = info.getSubscriptionName();
            SubscriptionKey key = new SubscriptionKey(clientId, subscriptionName);
            DurableTopicSubscription sub = durableSubscriptions.get(key);
            if (sub != null) {
                if (sub.isActive()) {
                    throw new JMSException("Durable consumer is in use for client: " + clientId + " and subscriptionName: " + subscriptionName);
                }

注册消费者时候出错了

报错为：

javax.jms.JMSException: Durable consumer is in use for client: TEST-Windows 7-wayne-2.11.100-20121213-1639 
and subscriptionName: com.wayne.act.message.ActMessageListener