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]> 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]> > Envoyé : lundi 10 mai 2021 15:21 > À : user <[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 >> <applewebdata://A390C941-339E-4C86-A235-91CB988EFD86> >> 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 >> <applewebdata://A390C941-339E-4C86-A235-91CB988EFD86> >> 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.
