[
https://issues.apache.org/jira/browse/CAMEL-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15095864#comment-15095864
]
dharshana vanderbona commented on CAMEL-9509:
---------------------------------------------
I debugged it up to the isSingleton method of CometdProducer. in version
2.9.0/2.10.0 isSingleton is delegated to the parent, which always returns true.
In the new releases the default method delegates the call to the endpoint
which is returning false in this case, making the producer shutdown during
refresh the refresh.
hread [main] (Suspended (breakpoint at line 169 in CometdComponent))
owns: LinkedHashMap<K,V> (id=113)
owns: RouteService (id=94)
owns: SpringCamelContext (id=95)
owns: Object (id=96)
owns: DefaultContextCache (id=97)
DefaultActiveMqConfiguration$1(CometdComponent).disconnect(CometdProducerConsumer)
line: 169
DefaultActiveMqConfiguration$1$1(CometdEndpoint).disconnect(CometdProducerConsumer)
line: 107
CometdProducer.stop() line: 60
ServiceHelper.stopService(Object) line: 141
ServiceHelper.stopAndShutdownService(Object) line: 204
ProducerCache.releaseProducer(Endpoint, Producer) line: 139
SendProcessor.doStart() line: 223
SendProcessor(ServiceSupport).start() line: 61
ServiceHelper.startService(Service) line: 74
ServiceHelper.startService(Object) line: 59
ServiceHelper.startServices(Collection<?>) line: 103
ServiceHelper.startServices(Object...) line: 89
InstrumentationProcessor(DelegateAsyncProcessor).doStart() line: 79
InstrumentationProcessor(ServiceSupport).start() line: 61
ServiceHelper.startService(Service) line: 74
ServiceHelper.startService(Object) line: 59
ServiceHelper.startServices(Collection<?>) line: 103
ServiceHelper.startServices(Object...) line: 89
DefaultErrorHandler(RedeliveryErrorHandler).doStart() line: 1272
DefaultErrorHandler(ChildServiceSupport).start(boolean) line: 44
DefaultErrorHandler(ChildServiceSupport).start() line: 31
ServiceHelper.startService(Service) line: 74
ServiceHelper.startService(Object) line: 59
ServiceHelper.startServices(Collection<?>) line: 103
ServiceHelper.startServices(Object...) line: 89
DefaultChannel.doStart() line: 155
DefaultChannel(ServiceSupport).start() line: 61
ServiceHelper.startService(Service) line: 74
ServiceHelper.startService(Object) line: 59
ServiceHelper.startServices(Collection<?>) line: 103
ServiceHelper.startService(Object) line: 61
ServiceHelper.startServices(Collection<?>) line: 103
ServiceHelper.startServices(Object...) line: 89
Pipeline(MulticastProcessor).doStart() line: 1122
Pipeline(ServiceSupport).start() line: 61
ServiceHelper.startService(Service) line: 74
ServiceHelper.startService(Object) line: 59
ServiceHelper.startServices(Collection<?>) line: 103
ServiceHelper.startServices(Object...) line: 89
CamelInternalProcessor(DelegateAsyncProcessor).doStart() line: 79
CamelInternalProcessor(ServiceSupport).start() line: 61
ServiceHelper.startService(Service) line: 74
RouteService.startChildService(Route, List<Service>) line: 340
RouteService.warmUp() line: 182
SpringCamelContext(DefaultCamelContext).doWarmUpRoutes(Map<Integer,DefaultRouteStartupOrder>,
boolean) line: 3090
SpringCamelContext(DefaultCamelContext).safelyStartRouteServices(boolean,
boolean, boolean, boolean, Collection<RouteService>) line: 3020
SpringCamelContext(DefaultCamelContext).doStartOrResumeRoutes(Map<String,RouteService>,
boolean, boolean, boolean, boolean) line: 2797
SpringCamelContext(DefaultCamelContext).doStartCamel() line: 2653
DefaultCamelContext.access$000(DefaultCamelContext) line: 167
DefaultCamelContext$2.call() line: 2467
DefaultCamelContext$2.call() line: 2463
SpringCamelContext(DefaultCamelContext).doWithDefinedClassLoader(Callable<T>)
line: 2486
SpringCamelContext(DefaultCamelContext).doStart() line: 2463
SpringCamelContext(ServiceSupport).start() line: 61
SpringCamelContext(DefaultCamelContext).start() line: 2432
RoutesCollector.onApplicationEvent(ContextRefreshedEvent) line: 67
RoutesCollector.onApplicationEvent(ApplicationEvent) line: 29
SimpleApplicationEventMulticaster.invokeListener(ApplicationListener,
ApplicationEvent) line: 163
SimpleApplicationEventMulticaster.multicastEvent(ApplicationEvent,
ResolvableType) line: 136
AnnotationConfigApplicationContext(AbstractApplicationContext).publishEvent(Object,
ResolvableType) line: 381
AnnotationConfigApplicationContext(AbstractApplicationContext).publishEvent(ApplicationEvent)
line: 335
AnnotationConfigApplicationContext(AbstractApplicationContext).finishRefresh()
line: 855
AnnotationConfigApplicationContext(AbstractApplicationContext).refresh() line:
541
I have written a workaround by overriding the isSingleton method of the
CometdProducer to return true as the older versions which makes the system work.
> camel-cometd is not working with camel 2.15.2
> ---------------------------------------------
>
> Key: CAMEL-9509
> URL: https://issues.apache.org/jira/browse/CAMEL-9509
> Project: Camel
> Issue Type: Bug
> Components: camel-cometd
> Affects Versions: 2.15.2
> Reporter: dharshana vanderbona
>
> I see that the Jetty server is getting stopped as soon as it was started. See
> the log below:
> 08:59:23.229 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=tracer,name=BacklogDebugger
> 08:59:23.233 [default] [main] DEBUG o.a.c.p.interceptor.DefaultChannel -
> Initialize channel for target: 'SetHeader[Exception,
> simple{${exception.message}}]'
> 08:59:23.257 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=errorhandlers,name="DefaultErrorHandlerBuilder(ref:CamelDefaultErrorHandlerBuilder)"
>
> 08:59:23.260 [default] [main] DEBUG o.a.c.p.interceptor.DefaultChannel -
> Initialize channel for target:
> 'RecipientList[simple{activemq:DLQ.${exchangeProperty.Queue},bean:metoEnvironmentHealthIndicator}]'
>
> 08:59:23.261 [default] [main] DEBUG org.apache.camel.model.LogDefinition -
> The LogName is null. Falling back to create logger by using the route id
> cometdRoute.
> 08:59:23.261 [default] [main] DEBUG o.a.c.p.interceptor.DefaultChannel -
> Initialize channel for target: 'Log[Sending message to Cometd]'
> 08:59:23.265 [default] [main] DEBUG o.a.camel.spring.SpringCamelContext -
> Using ComponentResolver:
> org.apache.camel.impl.DefaultComponentResolver@1e308cc to resolve component
> with name: cometd
> 08:59:23.265 [default] [main] DEBUG o.s.b.f.s.DefaultListableBeanFactory -
> Returning cached instance of singleton bean 'cometd'
> 08:59:23.265 [default] [main] DEBUG o.a.c.impl.DefaultComponentResolver -
> Found component: cometd in registry:
> mydomain.service.tada_messaging.DefaultActiveMqConfiguration$1@ff6bd5
> 08:59:23.265 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=components,name="cometd"
> 08:59:23.266 [default] [main] DEBUG o.apache.camel.impl.DefaultComponent -
> Creating endpoint uri=[cometd://0.0.0.0:9999/cometdBroadcastChannel],
> path=[0.0.0.0:9999/cometdBroadcastChannel]
> 08:59:23.266 [default] [main] DEBUG o.a.camel.spring.SpringCamelContext -
> cometd://0.0.0.0:9999/cometdBroadcastChannel converted to endpoint:
> Endpoint[cometd://0.0.0.0:9999/cometdBroadcastChannel] by component:
> mydomain.service.tada_messaging.DefaultActiveMqConfiguration$1@ff6bd5
> 08:59:23.268 [default] [main] DEBUG o.a.c.p.interceptor.DefaultChannel -
> Initialize channel for target:
> 'To[cometd://0.0.0.0:9999/cometdBroadcastChannel]'
> 08:59:23.271 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=services,name=MetricsRoutePolicy(0x1fa486)
>
> 08:59:23.277 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=services,name=MetricsRegistryService
> 08:59:23.277 [default] [main] DEBUG o.s.b.f.s.DefaultListableBeanFactory -
> Returning cached instance of singleton bean 'metricRegistry'
> 08:59:23.294 [default] [main] INFO o.a.camel.spring.SpringCamelContext -
> AllowUseOriginalMessage is enabled. If access to the original message is not
> needed, then its recommended to turn this option off as it may improve
> performance.
> 08:59:23.294 [default] [main] INFO o.a.camel.spring.SpringCamelContext -
> StreamCaching is not in use. If using streams then its recommended to enable
> stream caching. See more details at
> http://camel.apache.org/stream-caching.html
> 08:59:23.295 [default] [main] DEBUG o.a.camel.spring.SpringCamelContext -
> Warming up route id: cometdRoute having autoStartup=true
> 08:59:23.295 [default] [main] DEBUG org.apache.camel.impl.RouteService -
> Starting services on route: cometdRoute
> 08:59:23.302 [default] [main] DEBUG o.a.c.component.jms.JmsQueueEndpoint -
> Using destinationName: MyBroadcastQueue on listenerContainer:
> org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@1ce9dc5
> 08:59:23.306 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=threadpools,name="JmsConsumer(0xdd070a)"
>
> 08:59:23.306 [default] [main] DEBUG o.a.c.i.DefaultExecutorServiceManager -
> Created new CachedThreadPool for source:
> Consumer[activemq://MyBroadcastQueue] with name:
> JmsConsumer[MyBroadcastQueue]. ->
> java.util.concurrent.ThreadPoolExecutor@f92404[Running, pool size = 0, active
> threads = 0, queued tasks = 0, completed tasks = 0]
> 08:59:23.307 [default] [main] DEBUG org.apache.camel.impl.RouteService -
> Starting child service on route: cometdRoute ->
> Pipeline[[Channel[Log(cometdRoute)[Sending message to Cometd]],
> Channel[sendTo(Endpoint[cometd://0.0.0.0:9999/cometdBroadcastChannel])]]]
> 08:59:23.307 [default] [main] DEBUG o.a.c.processor.DefaultErrorHandler -
> Redelivery enabled: false on error handler:
> DefaultErrorHandler[EvalExpression[Simple:
> activemq:DLQ.${exchangeProperty.Queue},bean:metoEnvironmentHealthIndicator]]
> 08:59:23.307 [default] [main] DEBUG o.a.camel.processor.RecipientList -
> RecipientList RecipientList[Simple:
> activemq:DLQ.${exchangeProperty.Queue},bean:metoEnvironmentHealthIndicator]
> using ProducerCache with default cache size
> 08:59:23.307 [default] [main] DEBUG o.a.c.processor.DefaultErrorHandler -
> Redelivery enabled: false on error handler:
> DefaultErrorHandler[Instrumentation:log[Log(cometdRoute)[Sending message to
> Cometd]]]
> 08:59:23.311 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=producers,name=CometdProducer(0x1908a5c)
>
> 08:59:23.321 [default] [main] DEBUG org.eclipse.jetty.util.log - Logging to
> Logger[org.eclipse.jetty.util.log] via org.eclipse.jetty.util.log.Slf4jLog
> 08:59:23.328 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.server.Server@141651e +
> org.eclipse.jetty.server.handler.ContextHandlerCollection@55bf45 as handler
> 08:59:23.329 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.server.Server@141651e +
> [email protected]:9999 as connector
> 08:59:23.345 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.server.Server@141651e -
> org.eclipse.jetty.server.handler.ContextHandlerCollection@55bf45 as handler
> 08:59:23.345 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.server.Server@141651e +
> o.e.j.s.ServletContextHandler{/,null} as handler
> 08:59:23.356 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> filterNameMap={}
> 08:59:23.357 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> pathFilters=null
> 08:59:23.357 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> servletFilterMap=null
> 08:59:23.357 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> servletPathMap={/cometd/*=org.cometd.server.CometdServlet-c5fe9b}
> 08:59:23.357 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> servletNameMap={org.cometd.server.CometdServlet-c5fe9b=org.cometd.server.CometdServlet-c5fe9b}
>
> 08:59:23.357 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> filterNameMap={}
> 08:59:23.357 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> pathFilters=null
> 08:59:23.357 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> servletFilterMap=null
> 08:59:23.357 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> servletPathMap={/cometd/*=org.cometd.server.CometdServlet-c5fe9b,
> /=org.eclipse.jetty.servlet.DefaultServlet-17ca83e}
> 08:59:23.357 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> servletNameMap={org.cometd.server.CometdServlet-c5fe9b=org.cometd.server.CometdServlet-c5fe9b,
>
> org.eclipse.jetty.servlet.DefaultServlet-17ca83e=org.eclipse.jetty.servlet.DefaultServlet-17ca83e}
>
> 08:59:23.365 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting org.eclipse.jetty.server.Server@141651e
> 08:59:23.367 [default] [main] INFO org.eclipse.jetty.server.Server -
> jetty-8.1.18.v20150929
> 08:59:23.381 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.server.Server@141651e +
> qtp16541084{8<=0<=0/254,-1} as threadpool
> 08:59:23.381 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting o.e.j.s.ServletContextHandler{/,null}
> 08:59:23.394 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.servlet.ServletHandler@1aed797 +
> org.cometd.server.CometdServlet-c5fe9b as servlet
> 08:59:23.394 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.servlet.ServletHandler@1aed797 +
> org.eclipse.jetty.servlet.DefaultServlet-17ca83e as servlet
> 08:59:23.394 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.servlet.ServletHandler@1aed797 +
> [/cometd/*]=>org.cometd.server.CometdServlet-c5fe9b as servletMapping
> 08:59:23.394 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.servlet.ServletHandler@1aed797 +
> [/]=>org.eclipse.jetty.servlet.DefaultServlet-17ca83e as servletMapping
> 08:59:23.394 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.server.session.SessionHandler@1cc1503 +
> org.eclipse.jetty.servlet.ServletHandler@1aed797 as handler
> 08:59:23.394 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.server.session.SessionHandler@1cc1503 +
> org.eclipse.jetty.server.session.HashSessionManager@1778636 as sessionManager
> 08:59:23.394 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container o.e.j.s.ServletContextHandler{/,null} +
> org.eclipse.jetty.server.session.SessionHandler@1cc1503 as handler
> 08:59:23.394 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting org.eclipse.jetty.server.session.SessionHandler@1cc1503
> 08:59:23.394 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting org.eclipse.jetty.server.session.HashSessionManager@1778636
> 08:59:23.395 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.server.Server@141651e +
> org.eclipse.jetty.server.session.HashSessionIdManager@1397822 as
> sessionIdManager
> 08:59:23.395 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting org.eclipse.jetty.server.session.HashSessionIdManager@1397822
> 08:59:23.395 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED org.eclipse.jetty.server.session.HashSessionIdManager@1397822
> 08:59:23.396 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED org.eclipse.jetty.server.session.HashSessionManager@1778636
> 08:59:23.396 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting org.eclipse.jetty.servlet.ServletHandler@1aed797
> 08:59:23.396 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> filterNameMap={}
> 08:59:23.396 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> pathFilters=null
> 08:59:23.396 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> servletFilterMap=null
> 08:59:23.396 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> servletPathMap={/cometd/*=org.cometd.server.CometdServlet-c5fe9b,
> /=org.eclipse.jetty.servlet.DefaultServlet-17ca83e}
> 08:59:23.396 [default] [main] DEBUG o.e.jetty.servlet.ServletHandler -
> servletNameMap={org.cometd.server.CometdServlet-c5fe9b=org.cometd.server.CometdServlet-c5fe9b,
>
> org.eclipse.jetty.servlet.DefaultServlet-17ca83e=org.eclipse.jetty.servlet.DefaultServlet-17ca83e}
>
> 08:59:23.396 [default] [main] DEBUG o.e.j.server.handler.AbstractHandler -
> starting org.eclipse.jetty.servlet.ServletHandler@1aed797
> 08:59:23.396 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED org.eclipse.jetty.servlet.ServletHandler@1aed797
> 08:59:23.396 [default] [main] DEBUG o.e.j.server.handler.AbstractHandler -
> starting org.eclipse.jetty.server.session.SessionHandler@1cc1503
> 08:59:23.396 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED org.eclipse.jetty.server.session.SessionHandler@1cc1503
> 08:59:23.396 [default] [main] DEBUG o.e.j.server.handler.AbstractHandler -
> starting o.e.j.s.ServletContextHandler{/,null}
> 08:59:23.396 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting org.cometd.server.CometdServlet-c5fe9b
> 08:59:23.415 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting org.cometd.server.BayeuxServerImpl@868937
> 08:59:23.415 [default] [main] WARN o.c.server.BayeuxServerImpl@8816951 -
> setDebugEnabled not implemented
> 08:59:23.415 [default] [main] INFO o.c.server.BayeuxServerImpl@8816951 -
> JSONCommented=true
> 08:59:23.415 [default] [main] INFO o.c.server.BayeuxServerImpl@8816951 -
> interval=0
> 08:59:23.415 [default] [main] INFO o.c.server.BayeuxServerImpl@8816951 -
> logLevel=1
> 08:59:23.415 [default] [main] INFO o.c.server.BayeuxServerImpl@8816951 -
> maxInterval=30000
> 08:59:23.415 [default] [main] INFO o.c.server.BayeuxServerImpl@8816951 -
> multiFrameInterval=1500
> 08:59:23.415 [default] [main] INFO o.c.server.BayeuxServerImpl@8816951 -
> timeout=240000
> 08:59:23.417 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 -
> Added channel /meta
> 08:59:23.418 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 -
> Added channel /meta/handshake
> 08:59:23.418 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 -
> Added channel /meta/connect
> 08:59:23.418 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 -
> Added channel /meta/subscribe
> 08:59:23.418 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 -
> Added channel /meta/unsubscribe
> 08:59:23.418 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 -
> Added channel /meta/disconnect
> 08:59:23.420 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 -
> Allowed Transports: [callback-polling, long-polling]
> 08:59:23.421 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED org.cometd.server.BayeuxServerImpl@868937
> 08:59:23.421 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED org.cometd.server.CometdServlet-c5fe9b
> 08:59:23.421 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting org.eclipse.jetty.servlet.DefaultServlet-17ca83e
> 08:59:23.423 [default] [main] DEBUG org.eclipse.jetty.servlet.Holder -
> Holding class org.eclipse.jetty.servlet.DefaultServlet
> 08:59:23.423 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED org.eclipse.jetty.servlet.DefaultServlet-17ca83e
> 08:59:23.423 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED o.e.j.s.ServletContextHandler{/,null}
> 08:59:23.423 [default] [main] DEBUG o.e.j.server.handler.AbstractHandler -
> starting org.eclipse.jetty.server.Server@141651e
> 08:59:23.423 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting qtp16541084{8<=0<=0/254,-1}
> 08:59:23.424 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED qtp16541084{8<=7<=8/254,0}
> 08:59:23.424 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting [email protected]:9999
> 08:59:23.428 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting null/null
> 08:59:23.429 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED PooledBuffers [0/1024@6144,0/1024@16384,0/1024@-]/PooledBuffers
> [0/1024@6144,0/1024@32768,0/1024@-]
> 08:59:23.429 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> starting
> org.eclipse.jetty.server.nio.SelectChannelConnector$ConnectorSelectorManager@1e36e5e
>
> 08:59:23.436 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED
> org.eclipse.jetty.server.nio.SelectChannelConnector$ConnectorSelectorManager@1e36e5e
>
> 08:59:23.436 [default] [qtp16541084-30 Selector0] DEBUG
> org.eclipse.jetty.io.nio - Starting Thread[qtp16541084-30 Selector0,5,main]
> on org.eclipse.jetty.io.nio.SelectorManager$1@13b4f4c
> 08:59:23.437 [default] [main] INFO o.e.jetty.server.AbstractConnector -
> Started [email protected]:9999
> 08:59:23.437 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED [email protected]:9999
> 08:59:23.437 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STARTED org.eclipse.jetty.server.Server@141651e
> 08:59:23.453 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 - >
> {"id":"1","channel":"/meta/handshake"}
> /cometdBroadcastChannel_1ps6caf8lxivw14tib5lvs74mx
> 08:59:23.453 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 - >>
> {"id":"1","channel":"/meta/handshake"}
> 08:59:23.454 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 - <<
> {"id":"1","minimumVersion":"1.0","supportedConnectionTypes":["callback-polling","long-polling"],"successful":true,"channel":"/meta/handshake","clientId":"/cometdBroadcastChannel_1ps6caf8lxivw14tib5lvs74mx","version":"1.0"}
>
> 08:59:23.454 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 - <
> {"id":"1","minimumVersion":"1.0","supportedConnectionTypes":["callback-polling","long-polling"],"successful":true,"channel":"/meta/handshake","clientId":"/cometdBroadcastChannel_1ps6caf8lxivw14tib5lvs74mx","version":"1.0"}
>
> 08:59:23.455 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 - >
> {"id":"2","advice":{"interval":-1},"channel":"/meta/connect","clientId":"/cometdBroadcastChannel_1ps6caf8lxivw14tib5lvs74mx"}
> /cometdBroadcastChannel_1ps6caf8lxivw14tib5lvs74mx
> 08:59:23.455 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 - >>
> {"id":"2","advice":{"interval":-1},"channel":"/meta/connect","clientId":"/cometdBroadcastChannel_1ps6caf8lxivw14tib5lvs74mx"}
>
> 08:59:23.455 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 - <<
> {"id":"2","successful":true,"channel":"/meta/connect"}
> 08:59:23.455 [default] [main] DEBUG o.c.server.BayeuxServerImpl@8816951 - <
> {"id":"2","successful":true,"channel":"/meta/connect"}
> 08:59:23.456 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container org.eclipse.jetty.server.Server@141651e -
> [email protected]:9999 as connector
> 08:59:23.456 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping [email protected]:9999
> 08:59:23.456 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping
> org.eclipse.jetty.server.nio.SelectChannelConnector$ConnectorSelectorManager@1e36e5e
>
> 08:59:23.457 [default] [qtp16541084-30 Selector0] DEBUG
> org.eclipse.jetty.io.nio - Stopped Thread[qtp16541084-30 Selector0,5,main] on
> org.eclipse.jetty.io.nio.SelectorManager$1@13b4f4c
> 08:59:23.467 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED
> org.eclipse.jetty.server.nio.SelectChannelConnector$ConnectorSelectorManager@1e36e5e
>
> 08:59:23.467 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping PooledBuffers [0/1024@6144,0/1024@16384,0/1024@-]/PooledBuffers
> [0/1024@6144,0/1024@32768,0/1024@-]
> 08:59:23.467 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED null/null
> 08:59:23.468 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED [email protected]:9999
> 08:59:23.468 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping org.eclipse.jetty.server.Server@141651e
> 08:59:23.468 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping o.e.j.s.ServletContextHandler{/,null}
> 08:59:23.468 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping org.eclipse.jetty.server.session.SessionHandler@1cc1503
> 08:59:23.468 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping org.eclipse.jetty.server.session.HashSessionManager@1778636
> 08:59:23.468 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED org.eclipse.jetty.server.session.HashSessionManager@1778636
> 08:59:23.468 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping org.eclipse.jetty.servlet.ServletHandler@1aed797
> 08:59:23.468 [default] [main] DEBUG o.e.j.server.handler.AbstractHandler -
> stopping org.eclipse.jetty.servlet.ServletHandler@1aed797
> 08:59:23.469 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping org.eclipse.jetty.servlet.DefaultServlet-17ca83e
> 08:59:23.469 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED org.eclipse.jetty.servlet.DefaultServlet-17ca83e
> 08:59:23.469 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping org.cometd.server.CometdServlet-c5fe9b
> 08:59:23.469 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping org.cometd.server.BayeuxServerImpl@868937
> 08:59:23.469 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED org.cometd.server.BayeuxServerImpl@868937
> 08:59:23.470 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED org.cometd.server.CometdServlet-c5fe9b
> 08:59:23.470 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED org.eclipse.jetty.servlet.ServletHandler@1aed797
> 08:59:23.470 [default] [main] DEBUG o.e.j.server.handler.AbstractHandler -
> stopping org.eclipse.jetty.server.session.SessionHandler@1cc1503
> 08:59:23.470 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED org.eclipse.jetty.server.session.SessionHandler@1cc1503
> 08:59:23.470 [default] [main] DEBUG o.e.j.server.handler.AbstractHandler -
> stopping o.e.j.s.ServletContextHandler{/,null}
> 08:59:23.470 [default] [main] INFO o.e.j.server.handler.ContextHandler -
> stopped o.e.j.s.ServletContextHandler{/,null}
> 08:59:23.470 [default] [main] DEBUG o.e.jetty.util.component.Container -
> Container o.e.j.s.ServletContextHandler{/,null} -
> org.eclipse.jetty.server.session.SessionHandler@1cc1503 as handler
> 08:59:23.470 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED o.e.j.s.ServletContextHandler{/,null}
> 08:59:23.470 [default] [main] DEBUG o.e.j.server.handler.AbstractHandler -
> stopping org.eclipse.jetty.server.Server@141651e
> 08:59:23.470 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping org.eclipse.jetty.server.session.HashSessionIdManager@1397822
> 08:59:23.470 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED org.eclipse.jetty.server.session.HashSessionIdManager@1397822
> 08:59:23.470 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> stopping qtp16541084{8<=8<=8/254,0}
> 08:59:23.527 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED qtp16541084{8<=0<=0/254,4}
> 08:59:23.527 [default] [main] DEBUG o.e.j.u.component.AbstractLifeCycle -
> STOPPED org.eclipse.jetty.server.Server@141651e
> 08:59:23.527 [default] [main] DEBUG o.a.c.processor.DefaultErrorHandler -
> Redelivery enabled: false on error handler:
> DefaultErrorHandler[Instrumentation:to[sendTo(Endpoint[cometd://0.0.0.0:9999/cometdBroadcastChannel])]]
>
> 08:59:23.527 [default] [main] DEBUG org.apache.camel.impl.RouteService -
> Starting child service on route: cometdRoute ->
> Pipeline[[Channel[Log(cometdRoute)[Sending message to Cometd]],
> Channel[sendTo(Endpoint[cometd://0.0.0.0:9999/cometdBroadcastChannel])]]]
> 08:59:23.527 [default] [main] DEBUG org.apache.camel.impl.RouteService -
> Starting child service on route: cometdRoute -> Log(cometdRoute)[Sending
> message to Cometd]
> 08:59:23.534 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=processors,name="log2"
> 08:59:23.535 [default] [main] DEBUG org.apache.camel.impl.RouteService -
> Starting child service on route: cometdRoute ->
> Channel[Log(cometdRoute)[Sending message to Cometd]]
> 08:59:23.535 [default] [main] DEBUG org.apache.camel.impl.RouteService -
> Starting child service on route: cometdRoute ->
> sendTo(Endpoint[cometd://0.0.0.0:9999/cometdBroadcastChannel])
> 08:59:23.541 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=processors,name="to1"
> 08:59:23.541 [default] [main] DEBUG org.apache.camel.impl.RouteService -
> Starting child service on route: cometdRoute ->
> Channel[sendTo(Endpoint[cometd://0.0.0.0:9999/cometdBroadcastChannel])]
> 08:59:23.548 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=routes,name="cometdRoute"
> 08:59:23.548 [default] [main] DEBUG o.a.c.support.TimerListenerManager -
> Added TimerListener:
> org.apache.camel.management.mbean.ManagedSuspendableRoute@18afde8
> 08:59:23.549 [default] [main] DEBUG o.a.camel.spring.SpringCamelContext -
> Route: cometdRoute >>>
> EventDrivenConsumerRoute[Endpoint[activemq://MyBroadcastQueue] ->
> Pipeline[[Channel[Log(cometdRoute)[Sending message to Cometd]],
> Channel[sendTo(Endpoint[cometd://0.0.0.0:9999/cometdBroadcastChannel])]]]]
> 08:59:23.549 [default] [main] DEBUG o.a.camel.spring.SpringCamelContext -
> Starting consumer (order: 1000) on route: cometdRoute
> 08:59:23.552 [default] [main] DEBUG o.a.c.m.DefaultManagementAgent -
> Registered MBean with ObjectName:
> org.apache.camel:context=camel-1,type=consumers,name=JmsConsumer(0xdd070a)
> 08:59:23.552 [default] [main] DEBUG o.a.camel.component.jms.JmsConsumer -
> Starting consumer: Consumer[activemq://MyBroadcastQueue]
> 08:59:23.555 [default] [main] DEBUG o.a.a.thread.TaskRunnerFactory -
> Initialized TaskRunnerFactory[ActiveMQ VMTransport: vm://localhost#2] using
> ExecutorService: java.util.concurrent.ThreadPoolExecutor@4a7e7f[Running, pool
> size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
> 08:59:23.555 [default] [ActiveMQ BrokerService[localhost] Task-2] DEBUG
> o.a.a.thread.TaskRunnerFactory - Initialized TaskRunnerFactory[ActiveMQ
> VMTransport: vm://localhost#3] using ExecutorService:
> java.util.concurrent.ThreadPoolExecutor@b6fa5d[Running, pool size = 0, active
> threads = 0, queued tasks = 0, completed tasks = 0]
> 08:59:23.557 [default] [main] DEBUG
> o.a.c.c.j.DefaultJmsMessageListenerContainer - Established shared JMS
> Connection
> 08:59:23.558 [default] [main] DEBUG
> o.a.c.c.j.DefaultJmsMessageListenerContainer - Resumed paused task:
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker@9cef26
>
> 08:59:23.558 [default] [main] DEBUG
> o.a.c.c.j.DefaultJmsMessageListenerContainer - Resumed paused task:
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker@118d229
>
> 08:59:23.558 [default] [main] DEBUG
> o.a.c.c.j.DefaultJmsMessageListenerContainer - Resumed paused task:
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker@8da115
>
> 08:59:23.562 [default] [ActiveMQ VMTransport: vm://localhost#3-1] DEBUG
> o.a.a.broker.TransportConnection - Setting up new connection id:
> ID:EXXHSLSY4J-59436-1452675561504-3:2, address: vm://localhost#2, info:
> ConnectionInfo {commandId = 1, responseRequired = true, connectionId =
> ID:EXXHSLSY4J-59436-1452675561504-3:2, clientId =
> ID:EXXHSLSY4J-59436-1452675561504-2:1, clientIp = null, userName = null,
> password = *****, brokerPath = null, brokerMasterConnector = false,
> manageable = true, clientMaster = true, faultTolerant = false,
> failoverReconnect = false}
> 08:59:23.674 [default] [ActiveMQ VMTransport: vm://localhost#3-1] DEBUG
> o.a.a.broker.region.AbstractRegion - localhost adding destination:
> topic://ActiveMQ.Advisory.Connection
> 08:59:23.688 [default] [ActiveMQ VMTransport: vm://localhost#3-1] DEBUG
> o.a.a.broker.region.AbstractRegion - localhost adding consumer:
> ID:EXXHSLSY4J-59436-1452675561504-3:2:-1:1 for destination:
> ActiveMQ.Advisory.TempQueue,ActiveMQ.Advisory.TempTopic
> 08:59:23.698 [default] [main] DEBUG o.a.camel.component.jms.JmsConsumer -
> Started listener container
> org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@1ce9dc5 on
> destination MyBroadcastQueue
> 08:59:23.698 [default] [main] INFO o.a.camel.spring.SpringCamelContext -
> Route: cometdRoute started and consuming from:
> Endpoint[activemq://MyBroadcastQueue]
> 08:59:23.698 [default] [main] DEBUG
> o.a.c.m.DefaultManagementLifecycleStrategy - Load performance statistics
> disabled
> 08:59:23.698 [default] [main] INFO o.a.camel.spring.SpringCamelContext -
> Total 1 routes, of which 1 is started.
> 08:59:23.699 [default] [main] INFO o.a.camel.spring.SpringCamelContext -
> Apache Camel 2.15.2 (CamelContext: camel-1) started in 0.645 seconds
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
