Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-16796

camel-cxf - Problem with inflight message count being -1

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 3.11.0
    • 3.11.1, 3.12.0
    • came-core, came-cxf
    • None
    • Unknown

    Description

      Following our discussion on zulip:

      https://camel.zulipchat.com/#narrow/stream/257298-camel/topic/inflight.20repository

      i've created this ticket to investigate the issue.

       

      The two stacktraces of the call to the remove method of DefaultInflightRepository:

      at org.apache.camel.impl.engine.DefaultInflightRepository.remove(DefaultInflightRepository.java:62)
          at org.apache.camel.impl.engine.DefaultUnitOfWork.done(DefaultUnitOfWork.java:241)
          at org.apache.camel.support.UnitOfWorkHelper.doneUow(UnitOfWorkHelper.java:59)
          at org.apache.camel.support.DefaultConsumer.doneUoW(DefaultConsumer.java:124)
          at org.apache.camel.component.cxf.CxfConsumer$CxfConsumerInvoker.asyncInvoke(CxfConsumer.java:201)
          at org.apache.camel.component.cxf.CxfConsumer$CxfConsumerInvoker.invoke(CxfConsumer.java:161)
          at org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:59)
          at org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:96)
          at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:308)
          at org.apache.cxf.phase.PhaseInterceptorChain.resume(PhaseInterceptorChain.java:278)
          at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:78)
          at org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:265)
          at org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(JettyHTTPDestination.java:247)
          at org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTTPHandler.java:79)
          at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
          at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:235)
          at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1435)
          at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:190)
          at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1350)
          at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
          at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:191)
          at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
          at org.eclipse.jetty.server.Server.handleAsync(Server.java:559)
          at org.eclipse.jetty.server.HttpChannel.lambda$handle$2(HttpChannel.java:396)
          at org.eclipse.jetty.server.HttpChannel$$Lambda$629.1395631876.dispatch(Unknown Source:-1)
          at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:633)
          at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:396)
          at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277)
          at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
          at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)
          at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)
          at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:882)
          at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1036)
          at java.lang.Thread.run(Thread.java:748)
      
       
      at org.apache.camel.impl.engine.DefaultInflightRepository.remove(DefaultInflightRepository.java:62) at org.apache.camel.impl.engine.DefaultUnitOfWork.done(DefaultUnitOfWork.java:241) at org.apache.camel.support.UnitOfWorkHelper.doneUow(UnitOfWorkHelper.java:59) at org.apache.camel.component.cxf.util.CxfUtils.closeCamelUnitOfWork(CxfUtils.java:46) at org.apache.camel.component.cxf.CxfConsumer.lambda$createServer$0(CxfConsumer.java:87) at org.apache.camel.component.cxf.CxfConsumer$$Lambda$583.392278313.onMessage(Unknown Source:-1) at org.apache.cxf.phase.PhaseInterceptorChain.wrapExceptionAsFault(PhaseInterceptorChain.java:374) at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:332) at org.apache.cxf.phase.PhaseInterceptorChain.resume(PhaseInterceptorChain.java:278) at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:78) at org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:265) at org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(JettyHTTPDestination.java:247) at org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTTPHandler.java:79) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:235) at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1435) at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:190) at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1350) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:191) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) at org.eclipse.jetty.server.Server.handleAsync(Server.java:559) at org.eclipse.jetty.server.HttpChannel.lambda$handle$2(HttpChannel.java:396) at org.eclipse.jetty.server.HttpChannel$$Lambda$629.1395631876.dispatch(Unknown Source:-1) at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:633) at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:396) at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277) at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105) at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:882) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1036) at java.lang.Thread.run(Thread.java:748)
      

      Attachments

        Activity

          People

            ffang Freeman Yue Fang
            TCke83 Tom Cassimon
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: