activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jevans12 <>
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"
		<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 id="jmsTemplate"
		<property name="connectionFactory" ref="connectionFactory" />
		<property name="defaultDestination">
			<bean class="org.activemq.message.ActiveMQQueue">
					value="queue://indication,topic://subscription" />
		<property name="deliveryPersistent" value="false" />

<bean id="indicationPersisterContainer"
		<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" />
		<property name="messageListener" ref="indicationPersister" />
		<property name="taskExecutor">
				<property name="queueCapacity" value="0" />
				<property name="threadFactory">
						<property name="name"
							value="IndicationPersister" />

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 - ActiveMQ
connector started: TcpTransportServerChannel@tcp://****:61616
[Shutdown] INFO - 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 - ActiveMQ
connector started: VmTransportServerChannel@vm://localhost
[Shutdown] INFO org.activemq.ActiveMQConnectionFactory - Embedded JMS Broker
has started
[IndicationPersister-0] INFO -
Adding new client: ID:****-4389-1146512395248-4:0 on transport:
VmTransportChannel: null
[Shutdown] INFO - Got duplicate
client with id: ID:****-4389-1146512395248-4:0. Giving the existing client
5000 millis to prove it's alive.
[Shutdown] WARN - Unknown Packet
received: RECEIPT_INFO: id = 3 Receipt{ brokerMessageCapacity = 100,
correlationId = '1' , brokerName = 'null' , clusterName = 'null' , exception
= null, failed = false }
[Shutdown] INFO - 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 - Removing
client: ID:SC060270-4389-1146512395248-4:0 on transport: VmTransportChannel:
[Shutdown] INFO - Adding new
client: ID:SC060270-4389-1146512395248-4:0 on transport: VmTransportChannel:

View this message in context:
Sent from the ActiveMQ - User forum at

View raw message