activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gary Tully (JIRA)" <j...@apache.org>
Subject [jira] Commented: (AMQ-2286) NetworkConnector PrefetchSize
Date Wed, 10 Jun 2009 16:19:35 GMT

    [ https://issues.apache.org/activemq/browse/AMQ-2286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=52185#action_52185
] 

Gary Tully commented on AMQ-2286:
---------------------------------

in this scenario the broker(2) needs to go slow, not just the consumers.

I wonder if you enable straight through processing, asyncDispatch=false and optimizeDispatch=true
for broker2, will the dispatch block the network consumer.
An alternative solution may be to restrict the memory available to broker2 and have it use
producer flow control such that it can only have a small number of messages outstanding. 

> NetworkConnector PrefetchSize
> -----------------------------
>
>                 Key: AMQ-2286
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2286
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.2.0
>         Environment: Sun solaris 10
>            Reporter: ying
>            Priority: Blocker
>
> I have an issue which greatly reduces the quality of service of a network of activemq
brokers.
> Here is what I have:
> 1. 4 brokers( broker1, broker2, broker3,  broker4) in a network by multicast discovery
> 2. i have 2 consumers of QueueA on broker1, 2 consumers of QueueA on broker2, and consumer
queuePrefetch=1, networkConnector prefetchSize=1. Queue is using RoundRobinDispatchPolicy
> 3. I publish to QueueA on broker3 with 100 msgs, 2 consumers on broker1 are fast and
they process fine but 2 consumers on broker2 are stuck. However, with this config, msgs are
still 50 goes to broker1, 50 goes to broker2, and when consumers on broker2 get stuck, those
50 msgs are stuck on broker2. It seems the prefetchSize=1 on networkConnector have no effect
at all.
> what I expect in this case will be that 98 msgs shall go to broker1, and only 2 msgs
stuck on broker2's consumers. I cannot lose a single msg so ConstantPendingMessageLimit will
not help.
> Please help. Thanks

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message