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 = 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.
