Any one with an answer for this question?   from reading activemq doc and
forum, the lockup is understandable, how it what it does not make sense is
that it is still locked up when there only one client left.

Thanks

-dan


Dan Tran wrote:
> 
> 
> Hello, I have an embedded AMQ with 2 clients using vm:// and tcp://
> respectively.  The tcp://client mostly used to send lots of messages to
> the vm:// client.  The vm://client periodically sends control massages to
> tcp:// client.
> 
> The issue I am facing right now is the send operation from vm:// client
> hangs indefinitely when the broker in is under stress processing messaging
> sending from tcp:// client. It continues to hang when I stop the tcp://
> client and all of its messages are consumed. 
> 
> here is the stack trace
> 
> Daemon Thread [Thread-14] (Suspended)
> Unsafe.park(boolean, long) line: not available [native method]
> LockSupport.park(Object) line: 158
> AbstractQueuedSynchronizer$ConditionObject.await() line: 1925
> ArrayBlockingQueue<E>.take() line: 317
> FutureResponse.getResult() line: 40
> ResponseCorrelator.request(Object) line: 80
> ActiveMQConnection.syncSendPacket(Command) line: 1233
> ActiveMQSession.send(ActiveMQMessageProducer, ActiveMQDestination,
> Message, int, int, long, MemoryUsage, int) line: 1659
> ActiveMQMessageProducer.send(Destination, Message, int, int, long) line:
> 227
> ActiveMQMessageProducer(ActiveMQMessageProducerSupport).send(Message)
> line: 241
> JmsTemplate.doSend(MessageProducer, Message) line: 597
> JmsTemplate.doSend(Session, Destination, MessageCreator) line: 574
> JmsTemplate$4.doInJms(Session) line: 551
> JmsTemplate.execute(SessionCallback, boolean) line: 471
> JmsTemplate.send(String, MessageCreator) line: 548
> OracleSGAAgentProxy(AbstractAsyncAgentProxy).sendMessageToAgent(String)
> line: 92
> OracleSGAAgentProxy(AbstractAsyncAgentProxy).pingAgent() line: 147 
> 
> My configuration is a typical default settings.
> 
> is there a work around?  is there a way for me to set some timeout at
> ArrayBlockingQueue<E>.take() ??
> 
> This post also is at https://issues.apache.org/activemq/browse/AMQ-1375
> 
> sorry about the noise 
> 
> Any help is greatly appreciated.
> 
> 
> -Dan
> 

-- 
View this message in context: 
http://www.nabble.com/send-hangs-using-vm%3A---tp24301370p24562740.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to