For Artemis, is there a way to set consumerWindowSize differently on per JMS consumer basis?

classic Classic list List threaded Threaded
5 messages Options
Reply | Threaded
Open this post in threaded view
|

For Artemis, is there a way to set consumerWindowSize differently on per JMS consumer basis?

Youyu Shao
Hello,

We are using Artemis 2.6.2 as JMS server/broker. We have one JMS connection
created from
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.

We have two JMS queues, both are used as task distribution/load-balancing
mechanism.
One queue contains complex tasks taking long time to process, while the
other
contains simple tasks taking little time to finish.

Each queue have multiple JMS consumers. We would like to see if there is a
way
to configure the consumers of the complex task queue with
consumerWindowSize=0,
and configure the consumers of the simple task queue with
consumerWindowSize=-1.

Simply put, is there a way to set consumerWindowSize differently on per JMS
consumer basis?

Thanks

Youyu



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Reply | Threaded
Open this post in threaded view
|

Re: For Artemis, is there a way to set consumerWindowSize differently on per JMS consumer basis?

christopher.l.shannon
When version 2.7.0 is released you will be able to set a default
consumerWindowSize per address so you should be able to accomplish what you
want.

See
https://github.com/apache/activemq-artemis/blob/master/docs/user-manual/en/address-model.md#configuring-addresses-and-queues-via-address-settings
At the bottom there is a new config parameter called
"default-consumer-window-size"

On Fri, Dec 14, 2018 at 8:59 AM Youyu Shao <[hidden email]> wrote:

> Hello,
>
> We are using Artemis 2.6.2 as JMS server/broker. We have one JMS connection
> created from
> org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.
>
> We have two JMS queues, both are used as task distribution/load-balancing
> mechanism.
> One queue contains complex tasks taking long time to process, while the
> other
> contains simple tasks taking little time to finish.
>
> Each queue have multiple JMS consumers. We would like to see if there is a
> way
> to configure the consumers of the complex task queue with
> consumerWindowSize=0,
> and configure the consumers of the simple task queue with
> consumerWindowSize=-1.
>
> Simply put, is there a way to set consumerWindowSize differently on per JMS
> consumer basis?
>
> Thanks
>
> Youyu
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>
Reply | Threaded
Open this post in threaded view
|

Re: For Artemis, is there a way to set consumerWindowSize differently on per JMS consumer basis?

Youyu Shao
Thank you very much. This is very helpful. What is the timeframe for 2.7.0?

Thanks again,




--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Reply | Threaded
Open this post in threaded view
|

Re: For Artemis, is there a way to set consumerWindowSize differently on per JMS consumer basis?

clebertsuconic
It would be nice to set producing credits per address as well.  (Me
thinking as an user)

I will need to check about anonymous producers thought.

On Fri, Dec 14, 2018 at 1:24 PM Youyu Shao <[hidden email]> wrote:

> Thank you very much. This is very helpful. What is the timeframe for 2.7.0?
>
> Thanks again,
>
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>
--
Clebert Suconic
Reply | Threaded
Open this post in threaded view
|

Re: For Artemis, is there a way to set consumerWindowSize differently on per JMS consumer basis?

clebertsuconic
I just send a dev list post with a heads up.


If you guys could answer it there.

I’m planning 2.7.0 soon.  We won’t probably be doing many 2.6.x unless
really needed.


On Mon, Dec 17, 2018 at 10:54 AM Clebert Suconic <[hidden email]>
wrote:

> It would be nice to set producing credits per address as well.  (Me
> thinking as an user)
>
> I will need to check about anonymous producers thought.
>
> On Fri, Dec 14, 2018 at 1:24 PM Youyu Shao <[hidden email]> wrote:
>
>> Thank you very much. This is very helpful. What is the timeframe for
>> 2.7.0?
>>
>> Thanks again,
>>
>>
>>
>>
>> --
>> Sent from:
>> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>>
> --
> Clebert Suconic
>
--
Clebert Suconic