Hi
I switched the log to DEBUG level and I simplified the test leaving
only one route (and reducing the concurrent consumers from 2 to 4).
The issue still happens.
ActiveMQ has a subscription:
queue://Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.>
with one consumer and no pending messages after the route is removed.
You can see the extracted log in attachment.
> Il giorno 30 mar 2020, alle ore 07:27, Ralf Claussnitzer
> <[email protected]> ha scritto:
>
> Hi Riccardo,
>
> what is happening in DEBUG log when you call the remove?
>
> Maybe you are dealing with inflight exchanges here?
>
> Can you try to instead just stop the routes?
>
> -Ralf
>
> On 3/27/20 2:20 PM, Modanese, Riccardo wrote:
>> Hi all,
>>
>> I'm experimenting with programmatically routes creation and removal
>> (Camel version 2.17).
>> The routes are created and removed at runtime through my custom RouteBuilder
>> instance and are consuming from ActiveMQ 5 (with virtual topic enabled).
>> Once a route is removed (*) all the subscriptions (for this specific route)
>> to the broker are removed except for one.
>> So one subscription to the broker still remains active.
>>
>> Unfortunately I have no simple test code to reproduce the behavior I'm
>> seeing.
>>
>> Has someone any idea if I'm missing something or can point me to the right
>> direction?
>>
>> Thank you.
>>
>> Riccardo
>>
>>
>> (*)
>> getContext().removeRouteDefinition(getContext().getRouteDefinition(routeId));
[pool-2-thread-1] INFO c.e.e.s.r.loader.CamelRouteLoader - Stopping and
removing route my-route-id
[pool-2-thread-1] INFO o.a.c.impl.DefaultShutdownStrategy - Starting to
graceful shutdown 1 routes (timeout 300 seconds)
[pool-2-thread-1] DEBUG o.a.c.i.DefaultExecutorServiceManager - Created new
ThreadPool for source: org.apache.camel.impl.DefaultShutdownStrategy@5a7e155
with name: ShutdownTask. ->
org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@79a46e29[Running,
pool size = 0, active threads = 0, queued tasks = 0, completed tasks =
0][ShutdownTask]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.impl.DefaultShutdownStrategy - There are 1 routes to shutdown
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.c.j.DefaultJmsMessageListenerContainer - Stopping listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@351e8b66 with
cacheLevel: 3 and sharedConnectionEnabled: true
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.c.j.DefaultJmsMessageListenerContainer - Stopping shared connection on
listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@351e8b66
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.impl.DefaultShutdownStrategy - Route: my-route-id suspended and shutdown
deferred, was consuming from:
Endpoint[activemq://queue:Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.%3E?acknowledgementModeName=CLIENT_ACKNOWLEDGE&asyncConsumer=true&concurrentConsumers=2&maxConcurrentConsumers=4&transacted=false]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.c.j.DefaultJmsMessageListenerContainer - Stopping listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@351e8b66 with
cacheLevel: 3 and sharedConnectionEnabled: true
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.c.j.DefaultJmsMessageListenerContainer - Stopping shared connection on
listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@351e8b66
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.c.j.DefaultJmsMessageListenerContainer - Destroying listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@351e8b66 with
cacheLevel: 3 and sharedConnectionEnabled: true
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.c.j.DefaultJmsMessageListenerContainer - Shutting down JMS listener
container
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.c.j.DefaultJmsMessageListenerContainer - Waiting for shutdown of message
listener invokers
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.c.j.DefaultJmsMessageListenerContainer - Still waiting for shutdown of 2
message listener invokers
[Camel (camelContext) thread #33 -
JmsConsumer[Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.%3E]]
DEBUG o.a.c.c.j.DefaultJmsMessageListenerContainer - Lowered scheduled invoker
count: 1
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.c.j.DefaultJmsMessageListenerContainer - Still waiting for shutdown of 1
message listener invokers
[Camel (camelContext) thread #32 -
JmsConsumer[Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.%3E]]
DEBUG o.a.c.c.j.DefaultJmsMessageListenerContainer - Lowered scheduled invoker
count: 0
[Camel (camelContext) thread #32 -
JmsConsumer[Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.%3E]]
DEBUG o.s.j.c.CachingConnectionFactory - Closing cached Session:
ActiveMQSession
{id=ID:9f4b657352da-43065-1585557112055-4:1:34,started=true,closed=false}
java.lang.Object@4045826
[Camel (camelContext) thread #32 -
JmsConsumer[Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.%3E]]
DEBUG o.a.activemq.ActiveMQMessageConsumer - remove:
ID:9f4b657352da-43065-1585557112055-4:1:34:1, lastDeliveredSequenceId: -1
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.i.DefaultExecutorServiceManager - Forcing shutdown of ExecutorService:
java.util.concurrent.ThreadPoolExecutor@53fb86ee[Running, pool size = 2, active
threads = 0, queued tasks = 0, completed tasks = 2]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName:
org.apache.camel:context=camelContext,type=threadpools,name="JmsConsumer(0x5cd0fb00)"
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.camel.component.jms.JmsConsumer - Stopping consumer:
Consumer[activemq://queue:Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.%3E?acknowledgementModeName=CLIENT_ACKNOWLEDGE&asyncConsumer=true&concurrentConsumers=2&maxConcurrentConsumers=4&transacted=false]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.component.bean.BeanProducer - Stopping producer:
Producer[bean:camelFilter?method=bindSession]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName:
org.apache.camel:context=camelContext,type=producers,name=BeanProducer(0x419e46b2)
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.component.bean.BeanProducer - Stopping producer:
Producer[bean:camelRouteRetryHandling?method=dropMessageToDlq]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName:
org.apache.camel:context=camelContext,type=producers,name=BeanProducer(0x7a76bcd3)
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.component.bean.BeanProducer - Stopping producer:
Producer[bean:restEndpointComposer?method=initRouteProperties]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName:
org.apache.camel:context=camelContext,type=producers,name=BeanProducer(0x16f27c3d)
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.component.bean.BeanProducer - Stopping producer:
Producer[bean:camelToJsonConverter?method=convertToJson]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName:
org.apache.camel:context=camelContext,type=producers,name=BeanProducer(0x665153cd)
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.component.bean.BeanProducer - Stopping producer:
Producer[bean:camelAuthenticationSetterBean?method=basic]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName:
org.apache.camel:context=camelContext,type=producers,name=BeanProducer(0x55c93263)
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.component.bean.BeanProducer - Stopping producer:
Producer[bean:restEndpointComposer?method=composeEndpoint]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName:
org.apache.camel:context=camelContext,type=producers,name=BeanProducer(0x1343df3e)
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.component.http4.HttpProducer - Stopping producer:
Producer[my-route-id://camel-rest-cluster.web-server.io:8080/route_0_out?headerFilterStrategy=restHeaderFilter]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.component.bean.BeanProducer - Stopping producer:
Producer[bean:restResultChecker?method=checkResult]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName:
org.apache.camel:context=camelContext,type=producers,name=BeanProducer(0x16d54aff)
[ActiveMQ VMTransport:
vm://message-broker?transport.allowLinkStealing=true&create=false#7-5] DEBUG
o.a.a.broker.jmx.ManagementContext - Unregistering MBean
org.apache.activemq:type=Broker,brokerName=message-broker,destinationType=Queue,destinationName=Consumer.my-route-subs-idEXACTLY_ONCE.VirtualTopic.my-subs.>,endpoint=Consumer,clientId=ID_9f4b657352da-43065-1585557112055-3_1,consumerId=ID_9f4b657352da-43065-1585557112055-4_1_34_1
[ActiveMQ VMTransport:
vm://message-broker?transport.allowLinkStealing=true&create=false#7-5] DEBUG
o.a.a.broker.region.AbstractRegion - message-broker removing consumer:
ID:9f4b657352da-43065-1585557112055-4:1:34:1 for destination:
queue://Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.>
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.component.bean.BeanProducer - Stopping producer:
Producer[bean:camelFilter?method=unbindSession]
[Camel (camelContext) thread #36 - ShutdownTask] DEBUG
o.a.c.m.DefaultManagementAgent - Unregistered MBean with ObjectName:
org.apache.camel:context=camelContext,type=producers,name=BeanProducer(0x66b0c3d4)
[Camel (camelContext) thread #36 - ShutdownTask] INFO
o.a.c.impl.DefaultShutdownStrategy - Route: my-route-id shutdown complete, was
consuming from:
Endpoint[activemq://queue:Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.%3E?acknowledgementModeName=CLIENT_ACKNOWLEDGE&asyncConsumer=true&concurrentConsumers=2&maxConcurrentConsumers=4&transacted=false]
[ActiveMQ VMTransport:
vm://message-broker?transport.allowLinkStealing=true&create=false#7-5] DEBUG
o.a.activemq.broker.region.Queue -
queue://Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.> remove
sub: QueueSubscription: consumer=ID:9f4b657352da-43065-1585557112055-4:1:34:1,
destinations=1, dispatched=0, delivered=0, pending=0, prefetch=2,
prefetchExtension=0, lastDeliveredSeqId: -1, dequeues: 1, dispatched: 1,
inflight: 0, groups: 0
[ActiveMQ VMTransport:
vm://message-broker?transport.allowLinkStealing=true&create=false#7-5] DEBUG
o.a.activemq.broker.region.Queue -
queue://Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.>,
subscriptions=1, memory=0%, size=0, pending=0 toPageIn: 0, force:false,
Inflight: 0, pagedInMessages.size 0, pagedInPendingDispatch.size 0,
enqueueCount: 1, dequeueCount: 1, memUsage:0, maxPageSize:200
[pool-2-thread-1] INFO o.a.c.impl.DefaultShutdownStrategy - Graceful shutdown
of 1 routes completed in 0 seconds
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping services
on route: my-route-id
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id ->
Consumer[activemq://queue:Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.%3E?acknowledgementModeName=CLIENT_ACKNOWLEDGE&asyncConsumer=true&concurrentConsumers=2&maxConcurrentConsumers=4&transacted=false]
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=consumers,name=JmsConsumer(0x5cd0fb00)
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel[Multicast[[Channel.....
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Multicast[[Channel[Pipeline[[Channel.....
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="multicast1"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel[Multicast[[Channel[Pipeline.....
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Pipeline.....
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="my-custom-http4-endpoint"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel[Pipeline.....
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> sendTo(...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="to17"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> SetHeader...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="setHeader1"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> SetHeader...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="setHeader2"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> SetHeader...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="setHeader3"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel[...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> SetHeader...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="setHeader4"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> SetHeader...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="setHeader5"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> SetHeader...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="setHeader6"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> SetHeader...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="setHeader7"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> SetHeader...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="setHeader8"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> choice...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="null-my-subs-3549389292418194739"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Filter...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Pipeline...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> sendTo...
[ActiveMQ Journal Checkpoint Worker] DEBUG o.a.a.store.kahadb.MessageDatabase -
Checkpoint started.
[ActiveMQ Journal Checkpoint Worker] DEBUG o.a.a.store.kahadb.MessageDatabase -
Checkpoint done.
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="to18"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> sendTo...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="to19"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> sendTo...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="to20"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> sendTo...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="to21"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> RecipientList...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="recipientList1"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> DeadLetterChannel...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=errorhandlers,name=DeadLetterChannelBuilder(0x3b950de6)
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> RecipientList...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> sendTo...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="to22"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> sendTo...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="to23"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> sendTo...
[pool-2-thread-1] DEBUG o.a.c.m.DefaultManagementAgent - Unregistered MBean
with ObjectName:
org.apache.camel:context=camelContext,type=processors,name="to24"
[pool-2-thread-1] DEBUG org.apache.camel.impl.RouteService - Stopping child
service on route: my-route-id -> Channel...
[pool-2-thread-1] INFO o.a.camel.spring.SpringCamelContext - Route:
my-route-id is stopped, was consuming from:
Endpoint[activemq://queue:Consumer.my-route-subs-id:EXACTLY_ONCE.VirtualTopic.my-subs.%3E?acknowledgementModeName=CLIENT_ACKNOWLEDGE&asyncConsumer=true&concurrentConsumers=2&maxConcurrentConsumers=4&transacted=false]
