activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jevans12 <jevan...@harris.com>
Subject AMQ 3.2.2 and Spring 2.0
Date Thu, 04 May 2006 16:35:48 GMT

Environment: Spring 2.0 M3, ActiveMQ 3.2.2

<!-- JMS Beans -->
	<bean id="connectionFactory"
		class="org.springframework.jms.connection.SingleConnectionFactory">
		<property name="targetConnectionFactory">
			<bean class="org.activemq.ActiveMQConnectionFactory">
				<property name="brokerURL" value="vm://localhost" />
				<property name="brokerXmlConfig" value="activemq.xml" />
				<property name="copyMessageOnSend" value="false" />
				<property name="useEmbeddedBroker" value="true" />
			</bean>
		</property>
	</bean>

	<bean id="jmsTemplate"
		class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="connectionFactory" />
		<property name="defaultDestination">
			<bean class="org.activemq.message.ActiveMQQueue">
				<constructor-arg
					value="queue://indication,topic://subscription" />
			</bean>
		</property>
		<property name="deliveryPersistent" value="false" />
	</bean>


<bean id="indicationPersisterContainer"
		class="org.springframework.jms.listener.DefaultMessageListenerContainer">		
		<property name="concurrentConsumers"
			value="${indication.persister.concurrent}" />
		<property name="connectionFactory" ref="connectionFactory" />
		<property name="destination">
			<bean class="org.activemq.message.ActiveMQQueue">
				<constructor-arg value="indication" />
			</bean>
		</property>
		<property name="messageListener" ref="indicationPersister" />
		<property name="taskExecutor">
			<bean
			
class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
				<property name="queueCapacity" value="0" />
				<property name="threadFactory">
					<bean
						class="util.NamingThreadFactory">
						<property name="name"
							value="IndicationPersister" />
					</bean>
				</property>
			</bean>
		</property>
	</bean>

This is our setup for a queue. We are seeing failures when the concurrent
consumers is >3 consistently at 5 concurrent consumers
The removeConsumer call on DurableQueueBoundedMessageContainer is what makes
the thread die (depending on the timing). 
Consistently get this whole "replaing/removing client" log messages every
time it doesn't work.
The removal call is the culprit
INFO level output. Looking for any insight. thanks. 


Shutdown] INFO org.activemq.broker.impl.BrokerConnectorImpl - ActiveMQ
connector started: TcpTransportServerChannel@tcp://****:61616
[Shutdown] INFO org.activemq.broker.impl.BrokerContainerImpl - ActiveMQ JMS
Message Broker (ID:****-4389-1146512395248-0:0) has started
[Shutdown] INFO org.activemq.transport.vm.VmTransportServerChannel -
Listening for connections at: vm://localhost
[Shutdown] INFO org.activemq.broker.impl.BrokerConnectorImpl - ActiveMQ
connector started: VmTransportServerChannel@vm://localhost
[Shutdown] INFO org.activemq.ActiveMQConnectionFactory - Embedded JMS Broker
has started
[IndicationPersister-0] INFO org.activemq.broker.impl.BrokerContainerImpl -
Adding new client: ID:****-4389-1146512395248-4:0 on transport:
VmTransportChannel: null
[Shutdown] INFO org.activemq.broker.impl.BrokerContainerImpl - Got duplicate
client with id: ID:****-4389-1146512395248-4:0. Giving the existing client
5000 millis to prove it's alive.
[Shutdown] WARN org.activemq.broker.impl.BrokerClientImpl - Unknown Packet
received: RECEIPT_INFO: id = 3 Receipt{ brokerMessageCapacity = 100,
correlationId = '1' , brokerName = 'null' , clusterName = 'null' , exception
= null, failed = false }
[Shutdown] INFO org.activemq.broker.impl.BrokerContainerImpl - Replacing
client: ID:SC060270-4389-1146512395248-4:0 on transport: VmTransportChannel:
null (Client did not respond in time) with client on transport:
VmTransportChannel: null
[Shutdown] INFO org.activemq.broker.impl.BrokerContainerImpl - Removing
client: ID:SC060270-4389-1146512395248-4:0 on transport: VmTransportChannel:
null
[Shutdown] INFO org.activemq.broker.impl.BrokerContainerImpl - Adding new
client: ID:SC060270-4389-1146512395248-4:0 on transport: VmTransportChannel:
null

--
View this message in context: http://www.nabble.com/AMQ-3.2.2-and-Spring-2.0-t1558336.html#a4232827
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message