what does the os say about that connection. Can you use netstat to get the tcp connection status? with that information it may be possible to determine what timeouts are relevant.
Also, the prefetch for non persistent topic consumers is short-max, so you need to configure a value that will limit the amount of pending messages that are queued for that consumer while it is 'disconnected' but still present to the broker. see: http://activemq.apache.org/what-is-the-prefetch-limit-for.html 2009/11/11 SelvarajAM <selvara...@hcl.in>: > > Hi Gary, > > Thanks for your reply. > I have attached my jconsole screen shot. Kindly have a look at it. > > Though the client connection is lost (or has got error), jconsole says it > is NOT BLOCKED and NOT SLOW. > > Also i tried all the configuaration for discarding the messages as in > http://activemq.apache.org/slow-consumer-handling.html > But it did not work. Just the memory increases and activemq stops. > I dont know why the configuration is not working. > > Can you please tell me where to configure the timeouts???? > > One thing i noticed is, in jconsole->Connection->Stomp->[Diconnected > Client]->Operations->stop() > when i send the stop command, activemq started sending messages to other > clients without any problem. > > But i dont know how to identify the disonnected client...and close it > programatically... > > Another strange thing i see in jconsole is, the TotalDequeue count is less > compared to TotalEnqueue count. > > Below is the xml configuration which i use to reproduce the issue. The > system memory is very less (1mb) inorder to reproduce it faster. > > <beans > xmlns="http://www.springframework.org/schema/beans"; > xmlns:amq="http://activemq.apache.org/schema/core"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xsi:schemaLocation="http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans-2.0.xsd > http://activemq.apache.org/schema/core > http://activemq.apache.org/schema/core/activemq-core.xsd";> > > > <broker xmlns="http://activemq.apache.org/schema/core"; > persistent="false" useJmx="true" brokerName="PRI" > > > <destinationPolicy> > <policyMap> > <policyEntries> > <policyEntry topic="a" producerFlowControl="true" > memoryLimit="1 mb"> > <pendingMessageLimitStrategy> > <constantPendingMessageLimitStrategy > limit="10"/> > </pendingMessageLimitStrategy> > </policyEntry> > </policyEntries> > </policyMap> > </destinationPolicy> > > <systemUsage> > <systemUsage> > <memoryUsage> > <memoryUsage limit="1 mb"/> > </memoryUsage> > <storeUsage> > <storeUsage limit="1 mb" name="foo"/> > </storeUsage> > <tempUsage> > <tempUsage limit="1 mb"/> > </tempUsage> > </systemUsage> > </systemUsage> > > <transportConnectors> > <transportConnector name="StompNio" > uri="stomp://0.0.0.0:8084?jms.dispatchAsync=true"/> > <transportConnector name="Nio" > uri="nio://0.0.0.0:8086"/> > <transportConnector name="Tcp" > uri="tcp://0.0.0.0:8087"/> > </transportConnectors> > </broker> > </beans> > http://old.nabble.com/file/p26299914/Broker.jpg > http://old.nabble.com/file/p26299914/ClientDisconnect.jpg > -- > View this message in context: > http://old.nabble.com/Activemq-broker-hangs-when-stomp-client-disconnects-unexpectedly-tp26283384p26299914.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > -- http://blog.garytully.com Open Source Integration http://fusesource.com
