Adding dev. See PR[1] for the implementation.
[1] - https://github.com/wso2/product-mb/pull/32 Hemika Kodikara Software Engineer WSO2 Inc. lean . enterprise . middleware http://wso2.com Mobile : +94777688882 On Mon, Feb 23, 2015 at 11:38 AM, Hemika Kodikara <[email protected]> wrote: > Looping MB team. > > Just to give some context : I modified the andes client that is being used > for test cases. When closing a consumer, I am getting the mentioned error. > But this gets fixed when the closing part is running inside a separate > thread. > > Hemika Kodikara > Software Engineer > WSO2 Inc. > lean . enterprise . middleware > http://wso2.com > > Mobile : +94777688882 > > On Mon, Feb 23, 2015 at 11:33 AM, Akalanka Pagoda Arachchi < > [email protected]> wrote: > >> this is the AndesClient >> >> On Mon, Feb 23, 2015 at 11:33 AM, Akalanka Pagoda Arachchi < >> [email protected]> wrote: >> >>> error is thrown from org.wso2.andes.client.util.BlockingWaiter.block >>> method >>> >>> /** >>> * Blocks until an object is received that is handled by process, or >>> the specified timeout >>> * has passed. >>> >>> if (nanoTimeout <= 0 && !_ready && _error == >>> null) >>> { >>> line 176 - _error = new AMQTimeoutException("Server did >>> not respond in a timely fashion", null); >>> _ready = true; >>> } >>> >>> what is the functionality of this method? >>> >>> >>> On Mon, Feb 23, 2015 at 11:09 AM, Hemika Kodikara <[email protected]> >>> wrote: >>> >>>> Hi all, >>>> >>>> I removed the separate thread for closing the andes client. The >>>> stopping of the client would include closing the receiver, session and >>>> connection. I am getting the following issue when not using a separate >>>> thread of closing. Any Idea ? >>>> >>>> INFO [org.wso2.mb.integration.common.clients.AndesJMSConsumer] - >>>> Closing Consumer >>>> ERROR [org.wso2.mb.integration.common.clients.AndesJMSConsumer] - Error >>>> in stopping client. >>>> org.wso2.andes.client.JMSAMQException: Error closing consumer: >>>> org.wso2.andes.AMQTimeoutException: Server did not respond in a timely >>>> fashion [error code 408: Request Timeout] >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.close(BasicMessageConsumer.java:580) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.close(BasicMessageConsumer.java:536) >>>> at >>>> org.wso2.andes.client.QueueReceiverAdaptor.close(QueueReceiverAdaptor.java:83) >>>> at >>>> org.wso2.mb.integration.common.clients.AndesJMSConsumer.stopClient(AndesJMSConsumer.java:230) >>>> at >>>> org.wso2.mb.integration.common.clients.AndesJMSConsumer.onMessage(AndesJMSConsumer.java:450) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:728) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:702) >>>> at >>>> org.wso2.andes.client.AMQSession$Dispatcher.notifyConsumer(AMQSession.java:3432) >>>> at >>>> org.wso2.andes.client.AMQSession$Dispatcher.dispatchMessage(AMQSession.java:3376) >>>> at >>>> org.wso2.andes.client.AMQSession$Dispatcher.access$900(AMQSession.java:3151) >>>> at org.wso2.andes.client.AMQSession.dispatch(AMQSession.java:3144) >>>> at >>>> org.wso2.andes.client.message.UnprocessedMessage.dispatch(UnprocessedMessage.java:54) >>>> at org.wso2.andes.client.AMQSession$Dispatcher.run(AMQSession.java:3302) >>>> at java.lang.Thread.run(Thread.java:695) >>>> Caused by: org.wso2.andes.AMQTimeoutException: Server did not respond >>>> in a timely fashion [error code 408: Request Timeout] >>>> at >>>> org.wso2.andes.client.util.BlockingWaiter.block(BlockingWaiter.java:176) >>>> at >>>> org.wso2.andes.client.protocol.BlockingMethodFrameListener.blockForFrame(BlockingMethodFrameListener.java:123) >>>> at >>>> org.wso2.andes.client.protocol.AMQProtocolHandler.writeCommandFrameAndWaitForReply(AMQProtocolHandler.java:648) >>>> at >>>> org.wso2.andes.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:669) >>>> at >>>> org.wso2.andes.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:663) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer_0_8.sendCancel(BasicMessageConsumer_0_8.java:72) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.close(BasicMessageConsumer.java:574) >>>> ... 13 more >>>> Feb 23, 2015 11:05:49 AM org.wso2.andes.client.BasicMessageConsumer >>>> notifyMessage >>>> SEVERE: reNotification : Caught exception (dump follows) - ignoring... >>>> java.lang.RuntimeException: JMSException : Error in stopping client. >>>> at >>>> org.wso2.mb.integration.common.clients.AndesJMSConsumer.stopClient(AndesJMSConsumer.java:248) >>>> at >>>> org.wso2.mb.integration.common.clients.AndesJMSConsumer.onMessage(AndesJMSConsumer.java:450) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:728) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:702) >>>> at >>>> org.wso2.andes.client.AMQSession$Dispatcher.notifyConsumer(AMQSession.java:3432) >>>> at >>>> org.wso2.andes.client.AMQSession$Dispatcher.dispatchMessage(AMQSession.java:3376) >>>> at >>>> org.wso2.andes.client.AMQSession$Dispatcher.access$900(AMQSession.java:3151) >>>> at org.wso2.andes.client.AMQSession.dispatch(AMQSession.java:3144) >>>> at >>>> org.wso2.andes.client.message.UnprocessedMessage.dispatch(UnprocessedMessage.java:54) >>>> at org.wso2.andes.client.AMQSession$Dispatcher.run(AMQSession.java:3302) >>>> at java.lang.Thread.run(Thread.java:695) >>>> Caused by: org.wso2.andes.client.JMSAMQException: Error closing >>>> consumer: org.wso2.andes.AMQTimeoutException: Server did not respond in a >>>> timely fashion [error code 408: Request Timeout] >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.close(BasicMessageConsumer.java:580) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.close(BasicMessageConsumer.java:536) >>>> at >>>> org.wso2.andes.client.QueueReceiverAdaptor.close(QueueReceiverAdaptor.java:83) >>>> at >>>> org.wso2.mb.integration.common.clients.AndesJMSConsumer.stopClient(AndesJMSConsumer.java:230) >>>> ... 10 more >>>> Caused by: org.wso2.andes.AMQTimeoutException: Server did not respond >>>> in a timely fashion [error code 408: Request Timeout] >>>> at >>>> org.wso2.andes.client.util.BlockingWaiter.block(BlockingWaiter.java:176) >>>> at >>>> org.wso2.andes.client.protocol.BlockingMethodFrameListener.blockForFrame(BlockingMethodFrameListener.java:123) >>>> at >>>> org.wso2.andes.client.protocol.AMQProtocolHandler.writeCommandFrameAndWaitForReply(AMQProtocolHandler.java:648) >>>> at >>>> org.wso2.andes.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:669) >>>> at >>>> org.wso2.andes.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:663) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer_0_8.sendCancel(BasicMessageConsumer_0_8.java:72) >>>> at >>>> org.wso2.andes.client.BasicMessageConsumer.close(BasicMessageConsumer.java:574) >>>> ... 13 more >>>> >>>> >>>> >>>> >>>> Hemika Kodikara >>>> Software Engineer >>>> WSO2 Inc. >>>> lean . enterprise . middleware >>>> http://wso2.com >>>> >>>> Mobile : +94777688882 >>>> >>> >>> >>> >>> -- >>> *Darshana Akalanka Pagoda Arachchi,* >>> *Software Engineer* >>> *078-4721791* >>> >> >> >> >> -- >> *Darshana Akalanka Pagoda Arachchi,* >> *Software Engineer* >> *078-4721791* >> > >
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
