Hi:
ok. that's what I thought.
So, here is my scenario. I have 4 karaf instances, and each instance has
two pax-jms configurations(one for producer and one for consumer). But, in
the connections tab, I see just one connection per instance. Is this a
normal behavior? Because, I have two pax-jms configs and shldn't they have
two connections per instance, in this case? I have to verify this thing
with my previous implementation (while deploying broker as an artifact).
Regards,
Cooshal.
On Tuesday, June 18, 2019 at 3:45:41 PM UTC+2, Jean-Baptiste Onofré wrote:
>
> 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]> 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";
>>> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
>>> xmlns:cm="
>>> http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.3.0";
>>> xsi:schemaLocation="
>>> http://www.osgi.org/xmlns/blueprint/v1.0.0
>>> 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/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"
>>> 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"
>>> 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 = 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.
>>>>>>>
>>>>>> --
>>>>> --
>>>>> ------------------
>>>>> 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.
>>>>>
>>>> --
>>> --
>>> ------------------
>>> 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/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.
>>>
>> --
> --
> ------------------
> 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/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/f44f861b-9793-4155-af05-57a60182c5a4%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
