Hi,
That's the way JMS works.
You create a ConnectionFactory. The connection factory provides connections.
A connection provides several sessions. A session is single threaded,
and "assigned" to an action (consume or produce).
So, inside a single connection (for one client), you can have bunch of
sessions (some producing, some consuming). In Camel, you can define the
number of sessions per connection.
For consuming, you can use the receive() method or a MessageListener.
The session is also where you define the ACK mode (AUTO, CLIENT, DUPS,
TRANSACTED).
If you need more details, don't hesitate to ping me directly ;)
Regards
JB
On 18/06/2019 15:31, Kushal Gautam wrote:
> Hi again:
>
> I have a query on this issue.
>
> From the connections tab in the activemq webconsle, I see that my
> hundreds of connections are reduced to very few connections. That
> helped me resolve some jms-error issues, where my packets were being
> dropped because my broker was overloaded.
>
> When I look at the details of the connection, I see multiple consumer
> sessions.
>
> I am not able to comprehend the working method of this. Are all these
> sessions using just one connection??
>
> Regards,
> Cooshal.
>
>
> On Monday, June 17, 2019 at 2:10:28 PM UTC+2, Grzegorz Grzybek wrote:
>
> Hello
>
> Hmm
>
> You wrote two similar blueprint files containing:
>
> <bean id="activemqConnectionFactory"
> class="org.apache.activemq.ActiveMQConnectionFactory">
> <property name="brokerURL" value="${URL}" />
> <property name="userName" value="${USERNAME}" />
> <property name="password" value="${PASSWORD}" />
> </bean>
>
> Having etc/org.ops4j.connectionfactory-producer.cfg doesn't affect
> your ActiveMQCOnnectionFactory +
> org.apache.activemq.pool.PooledConnectionFactory beans...
>
> With pax-jms, you should expose underlying connection
> javax.jms.ConnectionFactory OSGi service
> (ActiveMQConnectionFactory) without
> org.apache.activemq.pool.PooledConnectionFactory.
>
> Probably with pax-jms you have 3 layers: pooled-jms →
> PooledConnectionFactory → ActiveMQConnectionFactory.
>
> Now you don't need
> org.apache.activemq.pool.PooledConnectionFactory beans.
>
> regards
> Grzegorz Grzybek
>
>
> pon., 17 cze 2019 o 13:05 Kushal Gautam <[email protected]
> <javascript:>> napisał(a):
>
> Hi:
>
> this was my previous config:
>
> <?xml version="1.0" encoding="UTF-8"?>
> <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0
> <http://www.osgi.org/xmlns/blueprint/v1.0.0>"
>
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance
> <http://www.w3.org/2001/XMLSchema-instance>"
>
> xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.3.0
> <http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.3.0>"
> xsi:schemaLocation="
> http://www.osgi.org/xmlns/blueprint/v1.0.0
> <http://www.osgi.org/xmlns/blueprint/v1.0.0>
> https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
> <https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd>
>
> http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.3.0
> <http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.3.0>
> http://aries.apache.org/schemas/blueprint-cm/blueprint-cm-1.3.0.xsd
> <http://aries.apache.org/schemas/blueprint-cm/blueprint-cm-1.3.0.xsd>
> ">
>
> <cm:property-placeholder persistent-id="prs-eai-broker"
> update-strategy="reload" >
> <cm:default-properties>
> <cm:property name="URL"
> value="tcp://localhost:61616" />
> <cm:property name="USERNAME" value="system" />
> <cm:property name="PASSWORD" value="manager" />
> <cm:property name="MAX_CONNECTIONS" value="20" />
> <cm:property name="PRODUCER_JNDI_NAME"
> value="jms/producer" />
> <cm:property name="CONSUMER_JNDI_NAME"
> value="jms/consumer" />
> </cm:default-properties>
> </cm:property-placeholder>
>
> <bean id="activemqConnectionFactory"
> class="org.apache.activemq.ActiveMQConnectionFactory">
> <property name="brokerURL" value="${URL}" />
> <property name="userName" value="${USERNAME}" />
> <property name="password" value="${PASSWORD}" />
> </bean>
>
> <bean id="consumerPooledConnectionFactory"
> class="org.apache.activemq.pool.PooledConnectionFactory">
> <property name="maxConnections"
> value="${MAX_CONNECTIONS}" />
> <property name="connectionFactory"
> ref="activemqConnectionFactory" />
> </bean>
>
> <bean id="producerPooledConnectionFactory"
> class="org.apache.activemq.pool.PooledConnectionFactory">
> <property name="maxConnections"
> value="${MAX_CONNECTIONS}" />
> <property name="connectionFactory"
> ref="activemqConnectionFactory" />
> </bean>
>
> <service ref="producerPooledConnectionFactory"
> interface="javax.jms.ConnectionFactory">
> <service-properties>
> <entry key="name" value="producer" />
> <entry key="osgi.jndi.service.name
> <http://osgi.jndi.service.name/>" value="${PRODUCER_JNDI_NAME}" />
> </service-properties>
> </service>
>
> <service ref="consumerPooledConnectionFactory"
> interface="javax.jms.ConnectionFactory">
> <service-properties>
> <entry key="name" value="consumer" />
> <entry key="osgi.jndi.service.name
> <http://osgi.jndi.service.name/>" value="${CONSUMER_JNDI_NAME}" />
> </service-properties>
> </service>
>
> </blueprint>
>
> I will try to see if I can get the stack trace. This problem
> is currently there in the prod. system. So, I have to check
> that once.
>
> Regards,
> Cooshal.
>
> On Monday, June 17, 2019 at 12:20:52 PM UTC+2, Grzegorz
> Grzybek wrote:
>
> Hello
>
> What was your previous configuration? Is there a chance to
> get a stack trace from under the debugger in the place
> where message is put into queue?
>
> regards
> Grzegorz Grzybek
>
> pon., 17 cze 2019 o 12:11 Kushal Gautam
> <[email protected]> napisał(a):
>
> Currently, I am observing some lag in putting the
> messages in one of the queues. Roughly, the number is
> about 1-4 messages per second. And, this is way too
> slow than my previous configuration.
>
> I checked this from the activemq console.
>
> I will try to see if I can produce some performance
> metrics. But, the thing is that I observed the
> enqueue/dequeue rates to be extremely slow.
>
> Regards,
> Cooshal.
>
> On Monday, June 17, 2019 at 11:02:40 AM UTC+2,
> Grzegorz Grzybek wrote:
>
> Hello
>
> What kind of processing performance problems do
> you have? pax-jms doesn't add any special
> processing - it only deals with exposing
> connection factories to your
> beans/components/services/...
>
> PooledJMS itself MAY add some processing overhead,
> but it of course depends on its configuration.
> After your application calls
> javax.jms.ConnectionFactory.getConnection(), it's
> all up to you/camel-jms/spring-jms how to
> use/cache/not-cache it...
>
> I'm interested in some numbers, logs maybe - how
> did you find out that the performance is worse?
>
> thanks in advance for any help/feedback
> regards
> Grzegorz Grzybek
>
> pon., 17 cze 2019 o 10:57 Kushal Gautam
> <[email protected]> napisał(a):
>
> Hi:
>
> I am using Camel with Karaf, and ActiveMQ
>
> Before using pax-jms, I was providing
> connectionfactories as artifact. But, since it
> was not configurable, I planned to switch it
> to pax-jms.
>
> But, so far, after switching to pax-jms, I
> have noticed performance lag in message
> processing. I am not entirely sure, if this is
> due to pax-jms.
>
> Thus, in general, does pax-jms degrade the
> message processing performance at all?
>
> For example, my jms-config looks like:
>
> name = eai-producer
> jms.url = tcp://localhost:61616
> jms.username = system
> jms.password = manager
> type = activemq
> pool = pooledjms
> osgi.jndi.service.name
> <http://osgi.jndi.service.name> = jms/producer
> org.apache.karaf.features.configKey =
> org.ops4j.connectionfactory-producer
>
> Regards,
> Cooshal.
> --
> --
> ------------------
> OPS4J - http://www.ops4j.org -
> [email protected]
>
> ---
> You received this message because you are
> subscribed to the Google Groups "OPS4J" group.
> To unsubscribe from this group and stop
> receiving emails from it, send an email to
> [email protected].
> To view this discussion on the web visit
>
> https://groups.google.com/d/msgid/ops4j/dc425a85-23d9-4f47-a855-9d9d96a70689%40googlegroups.com
>
> <https://groups.google.com/d/msgid/ops4j/dc425a85-23d9-4f47-a855-9d9d96a70689%40googlegroups.com?utm_medium=email&utm_source=footer>.
> For more options, visit
> https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>.
>
> --
> --
> ------------------
> OPS4J - http://www.ops4j.org - [email protected]
>
> ---
> You received this message because you are subscribed
> to the Google Groups "OPS4J" group.
> To unsubscribe from this group and stop receiving
> emails from it, send an email to [email protected].
> To view this discussion on the web visit
>
> https://groups.google.com/d/msgid/ops4j/3c8d060e-8f7b-4c47-aee3-1b955d217aef%40googlegroups.com
>
> <https://groups.google.com/d/msgid/ops4j/3c8d060e-8f7b-4c47-aee3-1b955d217aef%40googlegroups.com?utm_medium=email&utm_source=footer>.
> For more options, visit
> https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>.
>
> --
> --
> ------------------
> OPS4J - http://www.ops4j.org - [email protected]
> <javascript:>
>
> ---
> You received this message because you are subscribed to the
> Google Groups "OPS4J" group.
> To unsubscribe from this group and stop receiving emails from
> it, send an email to [email protected] <javascript:>.
> To view this discussion on the web visit
>
> https://groups.google.com/d/msgid/ops4j/13c998f7-3dc2-4a5e-b894-8622ce1dbad4%40googlegroups.com
>
> <https://groups.google.com/d/msgid/ops4j/13c998f7-3dc2-4a5e-b894-8622ce1dbad4%40googlegroups.com?utm_medium=email&utm_source=footer>.
> For more options, visit https://groups.google.com/d/optout
> <https://groups.google.com/d/optout>.
>
> --
> --
> ------------------
> OPS4J - http://www.ops4j.org - [email protected]
>
> ---
> You received this message because you are subscribed to the Google
> Groups "OPS4J" group.
> To unsubscribe from this group and stop receiving emails from it, send
> an email to [email protected]
> <mailto:[email protected]>.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/ops4j/0f4804ab-4425-4a3d-a830-4d021f07422f%40googlegroups.com
> <https://groups.google.com/d/msgid/ops4j/0f4804ab-4425-4a3d-a830-4d021f07422f%40googlegroups.com?utm_medium=email&utm_source=footer>.
> For more options, visit https://groups.google.com/d/optout.
--
--
------------------
OPS4J - http://www.ops4j.org - [email protected]
---
You received this message because you are subscribed to the Google Groups
"OPS4J" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To view this discussion on the web visit
https://groups.google.com/d/msgid/ops4j/41a0b3b5-abdc-ecdf-3069-2a30131393d8%40gmail.com.
For more options, visit https://groups.google.com/d/optout.
