Hi JB,
this doesn't work either.
This are the relevant log parts from karaf.log and activemq.log for further
investigation:
#### KARAF LOG
2022-02-17T17:06:55,593 | INFO | CM Configuration Updater (Update:
pid=org.ops4j.pax.logging) | EventAdminConfigurationNotifier | 6 -
org.ops4j.pax.logging.pax-logging-api - 1.11.13 | Sending Event Admin
notification (configuration successful) to org/ops4j/pax/logging/Configuration
2022-02-17T17:08:52,202 | INFO | pipe-bundle:restart 337 | BlueprintExtender
| 22 - org.apache.aries.blueprint.core - 1.10.3 | Destroying
container for blueprint bundle
de.dfs.services.xxx.xxx.xxx.CatoAftnFilterRouter/3.0.0.SNAPSHOT
2022-02-17T17:08:52,205 | INFO | pipe-bundle:restart 337 |
AbstractCamelContext | 78 - org.apache.camel.camel-base-engine -
3.11.5 | Apache Camel 3.11.5 (CATO-FILTER-Context) shutting down (timeout:5s)
2022-02-17T17:08:53,180 | INFO | pipe-bundle:restart 337 |
AbstractCamelContext | 78 - org.apache.camel.camel-base-engine -
3.11.5 | Routes shutdown summary (total:1 stopped:1)
2022-02-17T17:08:53,180 | INFO | pipe-bundle:restart 337 |
AbstractCamelContext | 78 - org.apache.camel.camel-base-engine -
3.11.5 | Stopped CATO-FILTER-Router
(opsActivemq://topic:aftn.inbound.records)
2022-02-17T17:08:53,196 | INFO | pipe-bundle:restart 337 |
AbstractCamelContext | 78 - org.apache.camel.camel-base-engine -
3.11.5 | Apache Camel 3.11.5 (CATO-FILTER-Context) shutdown in 991ms
(uptime:3m4s)
2022-02-17T17:08:53,201 | INFO | pipe-bundle:restart 337 | CommandExtension
| 188 - org.apache.karaf.shell.core - 4.2.15 | Unregistering
commands for bundle
de.dfs.services.xxx.xxx.xxx.CatoAftnFilterRouter/3.0.0.SNAPSHOT
2022-02-17T17:08:53,218 | INFO | pipe-bundle:restart 337 |
AbstractCamelContextFactoryBean | 91 - org.apache.camel.camel-core-xml -
3.11.5 | Using custom ShutdownStrategy:
org.apache.camel.impl.engine.DefaultShutdownStrategy@abb6303
2022-02-17T17:08:53,222 | INFO | pipe-bundle:restart 337 |
BlueprintCamelStateService | 139 - org.apache.camel.karaf.camel-blueprint
- 3.11.5 | Karaf BundleStateService not accessible. Bundle state won't reflect
Camel context state
2022-02-17T17:08:53,223 | INFO | pipe-bundle:restart 337 |
BlueprintContainerImpl | 22 - org.apache.aries.blueprint.core -
1.10.3 | Blueprint bundle
de.dfs.services.xxx.xxx.xxx.CatoAftnFilterRouter/3.0.0.SNAPSHOT has been started
2022-02-17T17:08:53,223 | INFO | Blueprint Event Dispatcher: 1 |
BlueprintCamelContext | 139 - org.apache.camel.karaf.camel-blueprint
- 3.11.5 | Attempting to start CamelContext: CATO-FILTER-Context
2022-02-17T17:08:53,226 | INFO | Blueprint Event Dispatcher: 1 |
JmxManagementStrategy | 111 - org.apache.camel.camel-management -
3.11.5 | JMX is enabled2022-02-17T17:08:53,257 | WARN | Blueprint Event
Dispatcher: 1 | CoreTypeConverterRegistry | 77 -
org.apache.camel.camel-base - 3.11.5 | Overriding type converter from:
StaticMethodTypeConverter: public static
org.apache.activemq.command.ActiveMQDestination
org.apache.activemq.camel.converter.ActiveMQConverter.toDestination(java.lang.String)
to: org.apache.camel.support.SimpleTypeConverter@6b36dbea
2022-02-17T17:08:53,257 | WARN | Blueprint Event Dispatcher: 1 |
CoreTypeConverterRegistry | 77 - org.apache.camel.camel-base - 3.11.5 |
Overriding type converter from: InstanceMethodTypeConverter: public
org.apache.activemq.command.ActiveMQMessage
org.apache.activemq.camel.converter.ActiveMQMessageConverter.toMessage(org.apache.camel.Exchange)
throws javax.jms.JMSException to:
org.apache.camel.support.SimpleTypeConverter@1bb26af7
2022-02-17T17:08:53,257 | WARN | Blueprint Event Dispatcher: 1 |
CoreTypeConverterRegistry | 77 - org.apache.camel.camel-base - 3.11.5 |
Overriding type converter from: InstanceMethodTypeConverter: public
org.apache.camel.Processor
org.apache.activemq.camel.converter.ActiveMQMessageConverter.toProcessor(javax.jms.MessageListener)
to: org.apache.camel.support.SimpleTypeConverter@44944087
2022-02-17T17:08:53,270 | INFO | Blueprint Event Dispatcher: 1 |
AbstractCamelContext | 78 - org.apache.camel.camel-base-engine -
3.11.5 | Routes startup summary (total:1 started:1)
2022-02-17T17:08:53,270 | INFO | Blueprint Event Dispatcher: 1 |
AbstractCamelContext | 78 - org.apache.camel.camel-base-engine -
3.11.5 | Started CATO-FILTER-Router
(opsActivemq://topic:aftn.inbound.records)
2022-02-17T17:08:53,270 | INFO | Blueprint Event Dispatcher: 1 |
AbstractCamelContext | 78 - org.apache.camel.camel-base-engine -
3.11.5 | Apache Camel 3.11.5 (CATO-FILTER-Context) started in 48ms (build:1ms
init:9ms start:38ms)
2022-02-17T17:08:53,274 | INFO | pipe-bundle:restart 337 | CommandExtension
| 188 - org.apache.karaf.shell.core - 4.2.15 | Registering
commands for bundle
de.dfs.services.xxx.xxx.xxx.CatoAftnFilterRouter/3.0.0.SNAPSHOT
2022-02-17T17:09:28,590 | INFO | pipe-logout | LogoutAction
| 186 - org.apache.karaf.shell.commands - 4.2.15 | Disconnecting from
current session...
2022-02-17T17:09:32,829 | INFO | Karaf Shutdown Socket Thread |
ShutdownSocketThread | 6 - org.ops4j.pax.logging.pax-logging-api -
1.11.13 | Karaf shutdown socket: received shutdown command. Stopping
framework...
#### ActiveMQ / CAMEL Log
2022-02-17 17:08:52,149 [e[dise] Task-11] - DEBUG Queue
- aftn.outbound -
queue://aftn.outbound, subscriptions=0, memory=5%, size=341, pending=0
toPageIn: 11, force:false, Inflight: 0, pagedInMessages.size 330,
pagedInPendingDispatch.size 330, enqueueCount: 341, dequeueCount: 100,
memUsage:598016, maxPageSize:200
2022-02-17 17:08:52,171 [ vm://dise#17-1] - DEBUG Queue
- vm://dise - dise Message
ID:clienthost-40191-1645113948293-4:5:1:1:86 sent to queue://aftn.outbound
2022-02-17 17:08:52,171 [e[dise] Task-11] - DEBUG Queue
- aftn.outbound -
queue://aftn.outbound, subscriptions=0, memory=5%, size=342, pending=0
toPageIn: 12, force:false, Inflight: 0, pagedInMessages.size 330,
pagedInPendingDispatch.size 330, enqueueCount: 342, dequeueCount: 100,
memUsage:599596, maxPageSize:200
2022-02-17 17:08:53,169 [nbound.records]] - DEBUG ActiveMQMessageConsumer
- - remove:
ID:clienthost-40191-1645113948293-8:1:1:1, lastDeliveredSequenceId: 1154285264
2022-02-17 17:08:53,190 [dle:restart 337] - DEBUG ThreadPoolUtils
- - Shutdown of
ExecutorService: java.util.concurrent.ThreadPoolExecutor@66fc82ca[Terminated,
pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 342] is
shutdown: true and terminated: false took: 0.000 seconds.
2022-02-17 17:08:53,191 [dle:restart 337] - DEBUG ThreadPoolUtils
- - Shutdown of
ExecutorService: java.util.concurrent.ThreadPoolExecutor@4dee60a1[Terminated,
pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is
shutdown: true and terminated: true took: 0.000 seconds.
2022-02-17 17:08:53,191 [0.7:61616@54932] - DEBUG ThreadPoolUtils
- - Shutdown of
ExecutorService: java.util.concurrent.ThreadPoolExecutor@889e3b[Terminated,
pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is
shutdown: true and terminated: true took: 0.000 seconds.
2022-02-17 17:08:53,191 [dle:restart 337] - DEBUG FailoverTransport
- - Stopped
tcp://hostname:61616
2022-02-17 17:08:53,191 [dle:restart 337] - DEBUG ThreadPoolUtils
- - Forcing shutdown of
ExecutorService: java.util.concurrent.ThreadPoolExecutor@2864d088[Running, pool
size = 0, active threads = 0, queued tasks = 0, completed tasks = 2]
2022-02-17 17:08:53,192 [dle:restart 337] - DEBUG TcpTransport
- - Stopping transport
tcp://hostname/xxx.xxx.xxx.xxx:61616@54932
2022-02-17 17:08:53,192 [dle:restart 337] - DEBUG TaskRunnerFactory
- - Initialized
TaskRunnerFactory[ActiveMQ Task] using ExecutorService:
java.util.concurrent.ThreadPoolExecutor@780bfee[Running, pool size = 0, active
threads = 0, queued tasks = 0, completed tasks = 0]
2022-02-17 17:08:53,193 [ActiveMQ Task-1] - DEBUG TcpTransport
- - Closed socket
Socket[addr=hostname/xxx.xxx.xxx.xxx,port=61616,localport=54932]
2022-02-17 17:08:53,193 [dle:restart 337] - DEBUG ThreadPoolUtils
- - Forcing shutdown of
ExecutorService: java.util.concurrent.ThreadPoolExecutor@780bfee[Running, pool
size = 1, active threads = 0, queued tasks = 0, completed tasks = 1]
2022-02-17 17:08:53,266 [e[dise] Task-11] - DEBUG TaskRunnerFactory
- - Initialized
TaskRunnerFactory[ActiveMQ VMTransport: vm://dise#25] using ExecutorService:
java.util.concurrent.ThreadPoolExecutor@5ace9ef1[Running, pool size = 0, active
threads = 0, queued tasks = 0, completed tasks = 0]
2022-02-17 17:08:53,266 [t Dispatcher: 1] - DEBUG TaskRunnerFactory
- - Initialized
TaskRunnerFactory[ActiveMQ VMTransport: vm://dise#24] using ExecutorService:
java.util.concurrent.ThreadPoolExecutor@c271484[Running, pool size = 0, active
threads = 0, queued tasks = 0, completed tasks = 0]
2022-02-17 17:08:53,268 [ vm://dise#25-1] - DEBUG TransportConnection
- vm://dise - Setting up new
connection id: ID:clienthost-40191-1645113948293-16:1, address: vm://dise#24,
info: ConnectionInfo {commandId = 1, responseRequired = true, connectionId =
ID:clienthost-40191-1645113948293-16:1, clientId =
ID:clienthost-40191-1645113948293-15:1, clientIp = null, userName = yyyyyyyyy,
password = *****, brokerPath = null, brokerMasterConnector = false, manageable
= true, clientMaster = true, faultTolerant = false, failoverReconnect = false}
2022-02-17 17:08:53,268 [ vm://dise#25-1] - DEBUG TransportConnector
- vm://dise - Publishing: vm://dise
for broker transport URI: vm://dise
2022-02-17 17:08:53,268 [ vm://dise#25-1] - DEBUG TransportConnector
- vm://dise - Publishing: vm://dise
for broker transport URI: vm://dise
2022-02-17 17:08:53,268 [ vm://dise#25-1] - DEBUG AbstractRegion
- vm://dise - dise adding consumer:
ID:clienthost-40191-1645113948293-16:1:-1:1 for destination:
ActiveMQ.Advisory.TempQueue,ActiveMQ.Advisory.TempTopic
2022-02-17 17:08:53,268 [ vm://dise#25-1] - DEBUG PolicyEntry
- vm://dise - Setting the
maximumPendingMessages size to: 1000 for consumer:
ID:clienthost-40191-1645113948293-16:1:-1:1
2022-02-17 17:08:53,270 [ vm://dise#25-1] - DEBUG AbstractRegion
- vm://dise - dise adding consumer:
ID:clienthost-40191-1645113948293-16:1:1:1 for destination:
topic://aftn.inbound.records
2022-02-17 17:08:53,270 [ vm://dise#25-1] - DEBUG PolicyEntry
- vm://dise - Setting the
maximumPendingMessages size to: 1000 for consumer:
ID:clienthost-40191-1645113948293-16:1:1:1
2022-02-17 17:08:53,271 [ vm://dise#25-1] - DEBUG TransportConnector
- vm://dise - Publishing: vm://dise
for broker transport URI: vm://dise
2022-02-17 17:08:53,271 [ vm://dise#25-1] - DEBUG TransportConnector
- vm://dise - Publishing: vm://dise
for broker transport URI: vm://dise
2022-02-17 17:08:53,271 [ vm://dise#25-1] - DEBUG AbstractRegion
- vm://dise - dise adding
destination: topic://ActiveMQ.Advisory.Consumer.Topic.aftn.inbound.records
2022-02-17 17:08:53,272 [nbound.records]] - DEBUG TaskRunnerFactory
- - Initialized
TaskRunnerFactory[ActiveMQ Session Task] using ExecutorService:
java.util.concurrent.ThreadPoolExecutor@4a07d63e[Running, pool size = 0, active
threads = 0, queued tasks = 0, completed tasks = 0]
2022-02-17 17:08:53,595 [eckpoint Worker] - DEBUG MessageDatabase
- dise - Checkpoint started.
2022-02-17 17:08:53,601 [eckpoint Worker] - DEBUG MessageDatabase
- dise - Checkpoint done.
2022-02-17 17:08:58,607 [eckpoint Worker] - DEBUG MessageDatabase
- dise - Checkpoint started.
2022-02-17 17:08:58,607 [eckpoint Worker] - DEBUG MessageDatabase
- dise - Checkpoint done.
2022-02-17 17:09:03,614 [eckpoint Worker] - DEBUG MessageDatabase
- dise - Checkpoint started.
2022-02-17 17:09:03,614 [eckpoint Worker] - DEBUG MessageDatabase
- dise - Checkpoint done.
2022-02-17 17:09:08,622 [eckpoint Worker] - DEBUG MessageDatabase
- dise - Checkpoint started.
Regards
Frank
-----Ursprüngliche Nachricht-----
Von: Jean-Baptiste Onofré <[email protected]>
Gesendet: Donnerstag, 17. Februar 2022 17:53
An: [email protected]
Betreff: EXT:Re: Lost connection to ActiveMQ for Camel routes after
configuration changes
Hi Frank,
does restarting the blueprint container help (not the bundle, I mean restarting
the route using camel:* commands for instance) ?
Regards
JB
On Thu, Feb 17, 2022 at 3:37 PM Zinner, Frank Uwe Alfred
<[email protected]> wrote:
>
>
> Hi,
> I have a running Kafka 4.2.15 with Camel 3.11.5 and ActiveMQ 5.16.2 with a
> Camel route to an external ActiveMQ broker.
> When I start my local Karaf, the Camel routes connect both ActiveMQ servers
> local and external and all works as expected.
> Then when I change the local configuration, Karaf restarts the route but the
> connection is lost.
> I can see on the external broker side, that the client connection is not
> present after configuration changed or if I restart the bundle.
>
> The configuration properties got promoted to the camel component e.g. when I
> change one of the values but I wasn't able to track/debug this down further
> why the connection is lost.
> Only a restart of the hole Karaf, brings the connection up again.
>
> Any ideas what I can do here or has someone experienced the same as me?
>
> The external ActiveMQ broker has version 5.13.3 the local broker has version
> 5.16.2.
>
> I connect to an external topic and I use a RouteBuilder to create this route:
>
> from(source).id("Router").description("Filter messages")
> .choice()
> .when(predicate) // predicate is a Camel Predicate
> .to(destination) // this is a topic on a local
> ActiveMQ broker
> .otherwise()
> .to(destinationFiltered); // also a topic on a
> local ActiveMQ broker
>
> BrokerURL is tcp://hostname:61616 where hostname is the external 5.13.3
> ActiveMQ broker.
>
> Nothing special there. The route connects to the remote broker topic, fetches
> the incoming messages, filters them and sends them to the local broker.
> Again, when I change a parameter in the configuration.cfg file on my local
> running Karaf or even restart the bundle this causes camel to lose the
> connection.
>
>
> Frank Uwe Alfred Zinner (extern)
>
> DFS Deutsche Flugsicherung GmbH
> SH/AM
> Am DFS-Campus 7
> 63225 Langen
>
> Mail:
> [email protected]<mailto:frank.uwe.alfred.zinner@
> externe.dfs.de>
>
>
>
> DFS Deutsche Flugsicherung GmbH * Am DFS-Campus * 63225 Langen * Tel.:
> +49 6103 707-0 * Sitz der Gesellschaft: Langen/Hessen * Zust?ndiges
> Registergericht: AG Offenbach am Main, HRB 34977 * Vorsitzende des
> Aufsichtsrats: Antje Geese * Gesch?ftsf?hrer: Arndt Schoenemann
> (Vors.), Dr. Kerstin B?cker, Dirk Mahns, Friedrich-Wilhelm Menge *
> www.dfs.de<http://www.dfs.de>
>
> Sollten Sie nicht der richtige Empf?nger dieser E-Mail sein, l?schen Sie
> diese bitte.
DFS Deutsche Flugsicherung GmbH • Am DFS-Campus • 63225 Langen • Tel.: +49 6103
707-0 • Sitz der Gesellschaft: Langen/Hessen • Zuständiges Registergericht: AG
Offenbach am Main, HRB 34977 • Vorsitzende des Aufsichtsrats: Antje Geese •
Geschäftsführer: Arndt Schoenemann (Vors.), Dr. Kerstin Böcker, Dirk Mahns,
Friedrich-Wilhelm Menge • www.dfs.de<http://www.dfs.de>
Sollten Sie nicht der richtige Empfänger dieser E-Mail sein, löschen Sie diese
bitte.
