You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Charles Moulliard (JIRA)" <ji...@apache.org> on 2010/02/22 16:04:40 UTC
[jira] Created: (AMQ-2621) Unexpected failure. at
org.apache.activemq.transport.failover.FailoverTransport.oneway
Unexpected failure. at org.apache.activemq.transport.failover.FailoverTransport.oneway
------------------------------------------------------------------------------------------
Key: AMQ-2621
URL: https://issues.apache.org/activemq/browse/AMQ-2621
Project: ActiveMQ
Issue Type: Bug
Affects Versions: 5.3.0
Environment: Fuse ESB 4.2.0-fuse-01-00 and ActiveMQ 5.3.0.fuse-01-00
Reporter: Charles Moulliard
Hi,
When transport of activemq is defined as vm:// (in file /etc/activemq-broker.xml of Fuse 4.2) then the following error is generated when we use a camel-cxf route :
Error
{code}
15:12:56,718 | ERROR | 0@qtp-28446306-0 | DefaultErrorHandler | rg.apache.camel.processor.Logger 248 | Failed delivery for exchangeId: 8114851b-c94c-484c-9638-4710a407da6e. Exhausted after delivery attempt: 1 caught: org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Unexpected failure.
org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Unexpected failure.
at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:308)
at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168)
at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:474)
at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:195)
at org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:375)
at org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:320)
at org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:150)
at org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97)
at org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95)
at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146)
at org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94)
at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82)
at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
at org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53)
at org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82)
at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:161)
at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
at org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177)
at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143)
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
at org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
at org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:74)
at org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:66)
at org.apache.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48)
at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
at org.apache.camel.component.cxf.CxfConsumer$1.invoke(CxfConsumer.java:91)
at org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:58)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at org.apache.cxf.workqueue.SynchronousExecutor.execute(SynchronousExecutor.java:37)
at org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:106)
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:243)
at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:109)
at org.apache.cxf.transport.http_jetty.JettyHTTPDestination.serviceRequest(JettyHTTPDestination.java:312)
at org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(JettyHTTPDestination.java:276)
at org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTTPHandler.java:70)
at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:765)
at org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:230)
at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)
at org.mortbay.jetty.Server.handle(Server.java:326)
at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542)
at org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:938)
at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:755)
at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218)
at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404)
at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:409)
at org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582)
Caused by: javax.jms.JMSException: Unexpected failure.
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1283)
at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1367)
at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:302)
at org.apache.activemq.pool.SessionPool.createSession(SessionPool.java:117)
at org.apache.activemq.pool.SessionPool.makeObject(SessionPool.java:85)
at org.apache.commons.pool.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:1148)
at org.apache.activemq.pool.SessionPool.borrowSession(SessionPool.java:54)
at org.apache.activemq.pool.ConnectionPool.createSession(ConnectionPool.java:108)
at org.apache.activemq.pool.PooledConnection.createSession(PooledConnection.java:141)
at org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:196)
at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:462)
... 46 more
Caused by: java.io.IOException: Unexpected failure.
at org.apache.activemq.transport.failover.FailoverTransport.oneway(FailoverTransport.java:462)
at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)
at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1261)
... 56 more
{code}
Route
{code}
<bean id="webservice" class="org.apache.camel.example.reportincident.internal.WebService" />
<bean id="feedback" class="org.apache.camel.example.reportincident.internal.Feedback" />
<cxf:bus>
<cxf:features>
<cxf:logging />
<wsa:addressing />
<wsrm-mgr:reliableMessaging>
<wsrm-policy:RMAssertion>
<wsrm-policy:BaseRetransmissionInterval Milliseconds="4000" />
<wsrm-policy:AcknowledgementInterval Milliseconds="2000" />
</wsrm-policy:RMAssertion>
<wsrm-mgr:destinationPolicy>
<wsrm-mgr:acksPolicy intraMessageThreshold="0" />
</wsrm-mgr:destinationPolicy>
</wsrm-mgr:reliableMessaging>
</cxf:features>
</cxf:bus>
<http:conduit name="{http://reportincident.example.camel.apache.org}ReportIncidentEndpoint.http-conduit">
<http:client DecoupledEndpoint="http://localhost:8080/cxf/camel-example/incident" />
</http:conduit>
<!-- webservice endpoint -->
<cxfcamel:cxfEndpoint
id="reportIncident"
address="http://localhost:8080/cxf/camel-example/incident"
serviceClass="org.apache.camel.example.reportincident.ReportIncidentEndpoint"
xmlns:s="http://reportincident.example.camel.apache.org">
</cxfcamel:cxfEndpoint>
<osgi:reference id="queuingservice" interface="org.apache.camel.Component" />
<camel:camelContext trace="true"
xmlns="http://camel.apache.org/schema/osgi">
<camel:route>
<camel:from uri="cxf:bean:reportIncident" />
<camel:convertBodyTo type="org.apache.camel.example.reportincident.InputReportIncident" />
<camel:to uri="bean:webservice" />
<camel:inOnly uri="queuingservice:queue:in" />
<camel:transform>
<camel:method bean="feedback" method="setOk" />
</camel:transform>
</camel:route>
</camel:camelContext>
{code}
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Closed: (AMQ-2621) Unexpected failure. at
org.apache.activemq.transport.failover.FailoverTransport.oneway
Posted by "Charles Moulliard (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Charles Moulliard closed AMQ-2621.
----------------------------------
Resolution: Fixed
The error reported is not at all in relation with activemq. Bad config in CXF WS-RM
> Unexpected failure. at org.apache.activemq.transport.failover.FailoverTransport.oneway
> ------------------------------------------------------------------------------------------
>
> Key: AMQ-2621
> URL: https://issues.apache.org/activemq/browse/AMQ-2621
> Project: ActiveMQ
> Issue Type: Bug
> Affects Versions: 5.3.0
> Environment: Fuse ESB 4.2.0-fuse-01-00 and ActiveMQ 5.3.0.fuse-01-00
> Reporter: Charles Moulliard
>
> Hi,
> When transport of activemq is defined as vm:// (in file /etc/activemq-broker.xml of Fuse 4.2) then the following error is generated when we use a camel-cxf route :
> Error
> {code}
> 15:12:56,718 | ERROR | 0@qtp-28446306-0 | DefaultErrorHandler | rg.apache.camel.processor.Logger 248 | Failed delivery for exchangeId: 8114851b-c94c-484c-9638-4710a407da6e. Exhausted after delivery attempt: 1 caught: org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Unexpected failure.
> org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Unexpected failure.
> at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:308)
> at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168)
> at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:474)
> at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:195)
> at org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:375)
> at org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:320)
> at org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:150)
> at org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97)
> at org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95)
> at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146)
> at org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94)
> at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82)
> at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
> at org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53)
> at org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82)
> at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:161)
> at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
> at org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177)
> at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143)
> at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
> at org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
> at org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228)
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:74)
> at org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:66)
> at org.apache.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48)
> at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
> at org.apache.camel.component.cxf.CxfConsumer$1.invoke(CxfConsumer.java:91)
> at org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:58)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
> at java.util.concurrent.FutureTask.run(FutureTask.java:138)
> at org.apache.cxf.workqueue.SynchronousExecutor.execute(SynchronousExecutor.java:37)
> at org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:106)
> at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:243)
> at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:109)
> at org.apache.cxf.transport.http_jetty.JettyHTTPDestination.serviceRequest(JettyHTTPDestination.java:312)
> at org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(JettyHTTPDestination.java:276)
> at org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTTPHandler.java:70)
> at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:765)
> at org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:230)
> at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)
> at org.mortbay.jetty.Server.handle(Server.java:326)
> at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542)
> at org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:938)
> at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:755)
> at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218)
> at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404)
> at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:409)
> at org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582)
> Caused by: javax.jms.JMSException: Unexpected failure.
> at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
> at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1283)
> at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1367)
> at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:302)
> at org.apache.activemq.pool.SessionPool.createSession(SessionPool.java:117)
> at org.apache.activemq.pool.SessionPool.makeObject(SessionPool.java:85)
> at org.apache.commons.pool.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:1148)
> at org.apache.activemq.pool.SessionPool.borrowSession(SessionPool.java:54)
> at org.apache.activemq.pool.ConnectionPool.createSession(ConnectionPool.java:108)
> at org.apache.activemq.pool.PooledConnection.createSession(PooledConnection.java:141)
> at org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:196)
> at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:462)
> ... 46 more
> Caused by: java.io.IOException: Unexpected failure.
> at org.apache.activemq.transport.failover.FailoverTransport.oneway(FailoverTransport.java:462)
> at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
> at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)
> at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)
> at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1261)
> ... 56 more
> {code}
> Route
> {code}
> <bean id="webservice" class="org.apache.camel.example.reportincident.internal.WebService" />
> <bean id="feedback" class="org.apache.camel.example.reportincident.internal.Feedback" />
> <cxf:bus>
> <cxf:features>
> <cxf:logging />
> <wsa:addressing />
> <wsrm-mgr:reliableMessaging>
> <wsrm-policy:RMAssertion>
> <wsrm-policy:BaseRetransmissionInterval Milliseconds="4000" />
> <wsrm-policy:AcknowledgementInterval Milliseconds="2000" />
> </wsrm-policy:RMAssertion>
> <wsrm-mgr:destinationPolicy>
> <wsrm-mgr:acksPolicy intraMessageThreshold="0" />
> </wsrm-mgr:destinationPolicy>
> </wsrm-mgr:reliableMessaging>
> </cxf:features>
> </cxf:bus>
> <http:conduit name="{http://reportincident.example.camel.apache.org}ReportIncidentEndpoint.http-conduit">
> <http:client DecoupledEndpoint="http://localhost:8080/cxf/camel-example/incident" />
> </http:conduit>
> <!-- webservice endpoint -->
> <cxfcamel:cxfEndpoint
> id="reportIncident"
> address="http://localhost:8080/cxf/camel-example/incident"
> serviceClass="org.apache.camel.example.reportincident.ReportIncidentEndpoint"
> xmlns:s="http://reportincident.example.camel.apache.org">
> </cxfcamel:cxfEndpoint>
> <osgi:reference id="queuingservice" interface="org.apache.camel.Component" />
> <camel:camelContext trace="true"
> xmlns="http://camel.apache.org/schema/osgi">
> <camel:route>
> <camel:from uri="cxf:bean:reportIncident" />
> <camel:convertBodyTo type="org.apache.camel.example.reportincident.InputReportIncident" />
> <camel:to uri="bean:webservice" />
> <camel:inOnly uri="queuingservice:queue:in" />
> <camel:transform>
> <camel:method bean="feedback" method="setOk" />
> </camel:transform>
> </camel:route>
> </camel:camelContext>
> {code}
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.