[
https://issues.apache.org/activemq/browse/SM-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Pryvalov updated SM-1909:
------------------------------
Description:
There are 2 service-units involved to message exchange.
Here is a SNIPPET of code of first service-unit:
/////////////// 1st service-unit, lw-container
public class ServiceFirst extends ComponentSupport implements
org.apache.servicemix.jbi.listener.MessageExchangeListener{
protected synchronized ServiceMixClient getServicemixClient(){
if (smClient==null)
smClient = new ServiceMixClientFacade( getContext() );
return smClient;
}
public void onMessageExchange(MessageExchange exchange) throws
MessagingException {
QName destService = ...; // qname of destination service (2nd service) is used
here.
EndpointResolver endpointResolver =
getServicemixClient().createResolverForService(destService);
InOnly inOnly = smClient.createInOnlyExchange(endpointResolver);
... // fill content of message
boolean result = smClient.sendSync(inOnly);
// result was FALSE here (!)
}
}
/////////////// 2nd service-unit, servicemix-bean
///////////////////////////////
public class ServiceTwo implements MessageExchangeListener{
@Resource
private DeliveryChannel channel;
public void onMessageExchange(MessageExchange exchange) throws
MessagingException {
if (if (exchange.getStatus() == ExchangeStatus.ACTIVE) {
...
exchange.setStatus(ExchangeStatus.DONE); // also cath
Exception uses ERROR status
}
channel.send(); // Excpetion occured here (!)
}
}
/////////////////////////////////////// stackTrace
///////////////////////////////////////
2009-11-09 09:44:52,946 | ERROR | AsyncBaseLifeCycle |
pool-flow.seda.servicemix-bean-thread-13591 | | Error processing exchange
InOnly[
id: ID:127.0.0.1-124c547e987-26:79012
status: Error
role: provider
service: {http://example.com}some_router_service
endpoint: jbi
in: ...
error: java.lang.RuntimeException: sendSync timeout for
ID:127.0.0.1-124c547e987-26:79012
]
org.apache.servicemix.jbi.ExchangeTimeoutException: Exchange has timed out:
InOnly[
id: ID:127.0.0.1-124c547e987-26:79012
status: Error
role: provider
service: {http://example.com}some_router_service
endpoint: jbi
in: ...
error: java.lang.RuntimeException: sendSync timeout for
ID:127.0.0.1-124c547e987-26:79012
]
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:362)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
at
org.apache.servicemix.common.EndpointDeliveryChannel.send(EndpointDeliveryChannel.java:88)
at
org.apache.servicemix.bean.BeanEndpoint$PojoChannel.send(BeanEndpoint.java:628)
at
com.example.MessageExchangeListenerImpl.onMessageExchange(MessageExchangeListenerImpl.java:182)
at
org.apache.servicemix.bean.BeanEndpoint.onProviderExchange(BeanEndpoint.java:230)
at
org.apache.servicemix.bean.BeanEndpoint.process(BeanEndpoint.java:217)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:627)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:581)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:535)
at
org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown
Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
2009-11-09 09:44:53,069 | ERROR | AsyncBaseLifeCycle |
pool-flow.seda.servicemix-bean-thread-13591 | | Error setting exchange status
to ERROR
org.apache.servicemix.jbi.ExchangeTimeoutException: Exchange has timed out:
InOnly[
id: ID:127.0.0.1-124c547e987-26:79012
status: Error
role: provider
service: {http://example.com}some_router_service
endpoint: jbi
in: ...
error: org.apache.servicemix.jbi.ExchangeTimeoutException: Exchange has timed
out: InOnly[
id: ID:127.0.0.1-124c547e987-26:79012
status: Error
role: provider
service: {http://example.com}some_router_service
endpoint: jbi
in: ...
error: java.lang.RuntimeException: sendSync timeout for
ID:127.0.0.1-124c547e987-26:79012
]
]
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:362)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:551)
at
org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown
Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
was:
There are 2 service-units involved to message exchange.
Here is a SNIPPET of code of first service-unit:
/////////////// 1st service-unit, lw-container
public class ServiceFirst extends ComponentSupport implements
org.apache.servicemix.jbi.listener.MessageExchangeListener{
protected synchronized ServiceMixClient getServicemixClient(){
if (smClient==null)
smClient = new ServiceMixClientFacade( getContext() );
return smClient;
}
public void onMessageExchange(MessageExchange exchange) throws
MessagingException {
QName destService = ...; // qname of destination service (2nd service) is used
here.
EndpointResolver endpointResolver =
getServicemixClient().createResolverForService(destService);
InOnly inOnly = smClient.createInOnlyExchange(endpointResolver);
... // fill content of message
boolean result = smClient.sendSync(inOnly);
// result was FALSE here (!)
}
}
/////////////// 2nd service-unit, servicemix-bean
///////////////////////////////
public class ServiceTwo implements MessageExchangeListener{
@Resource
private DeliveryChannel channel;
public void onMessageExchange(MessageExchange exchange) throws
MessagingException {
if (if (exchange.getStatus() == ExchangeStatus.ACTIVE) {
...
exchange.setStatus(ExchangeStatus.DONE); // also cath
Exception uses ERROR status
}
channel.send(); // Excpetion occured here (!)
}
}
/////////////////////////////////////// stackTrace
///////////////////////////////////////
2009-11-09 09:44:52,946 | ERROR | AsyncBaseLifeCycle |
pool-flow.seda.servicemix-bean-thread-13591 | | Error processing exchange
InOnly[
id: ID:127.0.0.1-124c547e987-26:79012
status: Error
role: provider
service: {http://example.com}some_router_service
endpoint: jbi
in: ...
error: java.lang.RuntimeException: sendSync timeout for
ID:127.0.0.1-124c547e987-26:79012
]
org.apache.servicemix.jbi.ExchangeTimeoutException: Exchange has timed out:
InOnly[
id: ID:127.0.0.1-124c547e987-26:79012
status: Error
role: provider
service: {http://example.com}some_router_service
endpoint: jbi
in: ...
error: java.lang.RuntimeException: sendSync timeout for
ID:127.0.0.1-124c547e987-26:79012
]
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:362)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
at
org.apache.servicemix.common.EndpointDeliveryChannel.send(EndpointDeliveryChannel.java:88)
at
org.apache.servicemix.bean.BeanEndpoint$PojoChannel.send(BeanEndpoint.java:628)
at
com.example.MessageExchangeListenerImpl.onMessageExchange(MessageExchangeListenerImpl.java:182)
at
org.apache.servicemix.bean.BeanEndpoint.onProviderExchange(BeanEndpoint.java:230)
at
org.apache.servicemix.bean.BeanEndpoint.process(BeanEndpoint.java:217)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:627)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:581)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:535)
at
org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown
Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
2009-11-09 09:44:53,069 | ERROR | AsyncBaseLifeCycle |
pool-flow.seda.servicemix-bean-thread-13591 | | Error setting exchange status
to ERROR
org.apache.servicemix.jbi.ExchangeTimeoutException: Exchange has timed out:
InOnly[
id: ID:127.0.0.1-124c547e987-26:79012
status: Error
role: provider
service: {http://example.com}some_router_service
endpoint: jbi
in: ...
error: org.apache.servicemix.jbi.ExchangeTimeoutException: Exchange has timed
out: InOnly[
id: ID:127.0.0.1-124c547e987-26:79012
status: Error
role: provider
service: {http://example.com}some_router_service
endpoint: jbi
in: ...
error: java.lang.RuntimeException: sendSync timeout for
ID:127.0.0.1-124c547e987-26:79012
]
]
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:362)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:551)
at
org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown
Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
> Timeout Exception under heavy load
> ----------------------------------
>
> Key: SM-1909
> URL: https://issues.apache.org/activemq/browse/SM-1909
> Project: ServiceMix
> Issue Type: Bug
> Affects Versions: 3.3.1
> Environment: SM 3.3.1,
> Windown XP SP3
> Reporter: Ivan Pryvalov
>
> There are 2 service-units involved to message exchange.
> Here is a SNIPPET of code of first service-unit:
> /////////////// 1st service-unit, lw-container
> public class ServiceFirst extends ComponentSupport implements
> org.apache.servicemix.jbi.listener.MessageExchangeListener{
> protected synchronized ServiceMixClient getServicemixClient(){
> if (smClient==null)
> smClient = new ServiceMixClientFacade( getContext() );
> return smClient;
> }
> public void onMessageExchange(MessageExchange exchange) throws
> MessagingException {
> QName destService = ...; // qname of destination service (2nd service) is
> used here.
> EndpointResolver endpointResolver =
> getServicemixClient().createResolverForService(destService);
> InOnly inOnly = smClient.createInOnlyExchange(endpointResolver);
>
> ... // fill content of message
> boolean result = smClient.sendSync(inOnly);
> // result was FALSE here (!)
> }
> }
> /////////////// 2nd service-unit, servicemix-bean
> ///////////////////////////////
> public class ServiceTwo implements MessageExchangeListener{
> @Resource
> private DeliveryChannel channel;
>
> public void onMessageExchange(MessageExchange exchange) throws
> MessagingException {
> if (if (exchange.getStatus() == ExchangeStatus.ACTIVE) {
> ...
> exchange.setStatus(ExchangeStatus.DONE); // also cath
> Exception uses ERROR status
> }
>
> channel.send(); // Excpetion occured here
> (!)
> }
> }
> /////////////////////////////////////// stackTrace
> ///////////////////////////////////////
> 2009-11-09 09:44:52,946 | ERROR | AsyncBaseLifeCycle |
> pool-flow.seda.servicemix-bean-thread-13591 | | Error processing exchange
> InOnly[
> id: ID:127.0.0.1-124c547e987-26:79012
> status: Error
> role: provider
> service: {http://example.com}some_router_service
> endpoint: jbi
> in: ...
> error: java.lang.RuntimeException: sendSync timeout for
> ID:127.0.0.1-124c547e987-26:79012
> ]
> org.apache.servicemix.jbi.ExchangeTimeoutException: Exchange has timed out:
> InOnly[
> id: ID:127.0.0.1-124c547e987-26:79012
> status: Error
> role: provider
> service: {http://example.com}some_router_service
> endpoint: jbi
> in: ...
> error: java.lang.RuntimeException: sendSync timeout for
> ID:127.0.0.1-124c547e987-26:79012
> ]
> at
> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:362)
> at
> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
> at
> org.apache.servicemix.common.EndpointDeliveryChannel.send(EndpointDeliveryChannel.java:88)
> at
> org.apache.servicemix.bean.BeanEndpoint$PojoChannel.send(BeanEndpoint.java:628)
> at
> com.example.MessageExchangeListenerImpl.onMessageExchange(MessageExchangeListenerImpl.java:182)
> at
> org.apache.servicemix.bean.BeanEndpoint.onProviderExchange(BeanEndpoint.java:230)
> at
> org.apache.servicemix.bean.BeanEndpoint.process(BeanEndpoint.java:217)
> at
> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:627)
> at
> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:581)
> at
> org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:535)
> at
> org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
> at
> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
> at
> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
> at
> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
> at
> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown
> Source)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> at java.lang.Thread.run(Unknown Source)
> 2009-11-09 09:44:53,069 | ERROR | AsyncBaseLifeCycle |
> pool-flow.seda.servicemix-bean-thread-13591 | | Error setting exchange status
> to ERROR
> org.apache.servicemix.jbi.ExchangeTimeoutException: Exchange has timed out:
> InOnly[
> id: ID:127.0.0.1-124c547e987-26:79012
> status: Error
> role: provider
> service: {http://example.com}some_router_service
> endpoint: jbi
> in: ...
> error: org.apache.servicemix.jbi.ExchangeTimeoutException: Exchange has
> timed out: InOnly[
> id: ID:127.0.0.1-124c547e987-26:79012
> status: Error
> role: provider
> service: {http://example.com}some_router_service
> endpoint: jbi
> in: ...
> error: java.lang.RuntimeException: sendSync timeout for
> ID:127.0.0.1-124c547e987-26:79012
> ]
> ]
> at
> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:362)
> at
> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
> at
> org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:551)
> at
> org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
> at
> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
> at
> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
> at
> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
> at
> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown
> Source)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> at java.lang.Thread.run(Unknown Source)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
