send hangs using vm://

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