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