Yeah is the right direction but what i see is more the amqp component that was recreated and is trying to get connectionFactory with no success
Michael. ________________________________ De : Jean-Baptiste Onofre <[email protected]> Envoyé : lundi 10 mai 2021 16:10 À : [email protected] <[email protected]> Objet : Re: Karaf and camel amqp Yeah, and my point is that parallelProcessing created new Exchanges, so, as I would test with "forcing" the connection factory. Did you try ? Regards JB Le 10 mai 2021 à 15:34, michael e <[email protected]<mailto:[email protected]>> a écrit : Ok thanks for the response but first as i explained the connection is used (autoDetectConnectionFactory=true by default) and work but not when i do parallel processing Second even doing that i got the exception `"&connectionFactory=#pooledConnectionFactoryFactory"` <reference id="pooledConnectionFactoryFactory" interface="org.ops4j.pax.jms.service.PooledConnectionFactoryFactory" filter="(&(pool=pooledjms)(xa=false))"/> Michael. ________________________________ De : Jean-Baptiste Onofre <[email protected]<mailto:[email protected]>> Envoyé : lundi 10 mai 2021 15:21 À : user <[email protected]<mailto:[email protected]>> Objet : Re: Karaf and camel amqp Just using service is not enough: you have to specify the connection factory on the URI. Regards JB Le 10 mai 2021 à 14:59, michael e <[email protected]<mailto:[email protected]>> a écrit : karaf@root()> service:list javax.jms.ConnectionFactory [javax.jms.ConnectionFactory] ----------------------------- connectionFactoryType = ConnectionFactory felix.fileinstall.filename = file:/D:/karaf/apache-karaf-4.3.1/etc/org.ops4j.connectionfactory-amqp.cfg jms.password = admin jms.url = amqp://localhost:5672 jms.username = admin name = jms/amqp osgi.jndi.service.name = jms/amqp pax.jms.managed = true pool.blockIfSessionPoolIsFull = true pool.idleTimeout = 100 pool.maxConnections = 123 protocol = amqp service.bundleid = 268 service.factoryPid = org.ops4j.connectionfactory service.id<http://service.id/> = 352 service.pid = org.ops4j.connectionfactory.6fc1ffd0-4842-4237-b7bf-f2fa8038cefe service.scope = singleton type = artemis Provided by : OPS4J Pax JMS Config (268) Used by: INTEG :: SCHEDULER (140) By bunle (140) already use the service as i explained in my message i get exception only when i use parallelProcessing() like there is no pool of connections i don't see anything in camel amqp or jms that allow to control producer threads Michael. ________________________________ De : michael e <[email protected]<mailto:[email protected]>> Envoyé : lundi 10 mai 2021 13:49 À : [email protected]<mailto:[email protected]> <[email protected]<mailto:[email protected]>> Objet : Karaf and camel amqp Hello, I'm getting in trouble trying to use camel amqp with karaf I have a simple route when i use parrallel processing i got Trace: java.lang.IllegalArgumentException: connectionFactory must be specified. Some messages are sended from(getInput()) .routeId(TO_BROKER_ROUTE_ID) .process().message(ToBrokerProcessor::setContextHeaders) .recipientList("amqp:queue1", "amqp:queue2").parallelProcessing(); i use jmsconnectionFactory connectionFactoryType = ConnectionFactory name = jms/amqp osgi.jndi.service.name = jms/amqp type = artemis protocol = amqp jms.url = amqp://localhost:5672 jms.username = admin jms.password = admin pool = pooledjms xa = false pool.idleTimeout = 100 pool.maxConnections = 1 pool.blockIfSessionPoolIsFull = true (i use rabbitMq with amqp 1.0) Michael.
