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]> 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 <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]> > Envoyé : lundi 10 mai 2021 13:49 > À : [email protected] <[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.
