activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From MaximeBelanger <maxime.belan...@uquebec.ca>
Subject problem configuring durable subscriber with Spring and Atomikos (XA issue?)
Date Mon, 16 Jul 2012 15:18:56 GMT
Hello,

I am not sure if this is an ActiveMQ issue, but my search so far as turned
up empty, so I have to start somewhere.
I am trying to setup a DefaultMessageListenerContainer using an ActiveMq
Durable subscriber (ActiveMQ 5.6.0), and Atomikos as TX manager for JTA,
configuring everything through Spring. I need to specify a clientId on the
connection for the durable subscriber. This is my config:
	<bean
		class="org.springframework.jms.listener.DefaultMessageListenerContainer">
		<property name="connectionFactory" ref="jmsListenerConnectionFactory" />
		<property name="concurrentConsumers" value="1" />
		<property name="destinationName" value="topic.name" />
		<property name="durableSubscriptionName" value="durable.name" />
		<property name="subscriptionDurable" value="true" />
		<property name="messageListener" ref="integrationMdp" />
		<property name="transactionManager" ref="JtaTransactionManager" />
		<property name="sessionAcknowledgeModeName" value="CLIENT_ACKNOWLEDGE" />
		<property name="pubSubDomain" value="true" />
		<property name="sessionTransacted" value="true" />
		<property name="clientId" value="msgListener" />
	</bean>

	<bean id="jmsListenerConnectionFactory"
class="com.atomikos.jms.AtomikosConnectionFactoryBean">
		<property name="uniqueResourceName" value="ActiveMQXAListener"/>
		<property name="maxPoolSize" value="1"/>
		<property name="xaConnectionFactory">
			<bean class="org.apache.activemq.ActiveMQXAConnectionFactory">
				<property name="brokerURL" value="${jms.brokerURL}"  />
				<property name="userName" value="${jms.username}" />
				<property name="password" value="${jms.password}" />
			</bean>
		</property>
		<property name="localTransactionMode" value="false"></property>
	</bean>

If I do this, I will get the following exception:

[org.springframework.jms.listener.DefaultMessageListenerContainer#0-1] WARN 
com.atomikos.jms.AbstractJmsProxy  - Failed to create durable
TopicSubscriber: null 
javax.jms.JMSException: You cannot create a durable subscriber without
specifying a unique clientID on a Connection
	at
org.apache.activemq.ActiveMQConnection.checkClientIDWasManuallySpecified(ActiveMQConnection.java:1255)
	at
org.apache.activemq.ActiveMQSession.createDurableSubscriber(ActiveMQSession.java:1295)

On the other hand, if I set the clientId on the connectionFactory, I get the
following:

[org.springframework.jms.listener.DefaultMessageListenerContainer#0-1] WARN 
com.atomikos.jms.AbstractJmsProxy  - Could not create an XASession on the
javax.jms.XAConnectionFactory's XAConnection - check if your JMS backend is
configured for XA? 
javax.jms.InvalidClientIDException: Broker: localhost - Client: msgListener
already connected from tcp://127.0.0.1:57501
	at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:223)
	at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)
[...]
[org.springframework.jms.listener.DefaultMessageListenerContainer#0-1] WARN 
com.atomikos.jms.AbstractJmsProxy  - Error delegating 'createSession' call
to JMS driver 
javax.jms.InvalidClientIDException: Broker: localhost - Client: msgListener
already connected from tcp://127.0.0.1:57501
	at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:223)
	at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85)
[...]


I seem to be caught in a catch-22 type problem here... Anyone had success
with this kind of config?

Thanks for your help,
Max

--
View this message in context: http://activemq.2283324.n4.nabble.com/problem-configuring-durable-subscriber-with-Spring-and-Atomikos-XA-issue-tp4654049.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message