[
https://issues.apache.org/activemq/browse/AMQ-721?page=comments#action_36458 ]
Robert Winslow commented on AMQ-721:
------------------------------------
I also have been dealing with this issue.
While I dont know if this is the correct solution (Dont know the code well
enough yet) however, it did fix the issue for me.
Th eonly change I made was to MessageConsumer::DispatchAsyncMessages I added a
call to AutoAcknowledge. This allowed me to get past the 1000 message Limit
[code]
public void DispatchAsyncMessages()
{
while (Listener != null)
{
IMessage message = dispatcher.DequeueNoWait();
if (message != null)
{
Listener(message);
**AutoAcknowledge(message);**
}
else
{
break;
}
}
}
[/code]
> Openwire client hangs after receiving 999 messages
> --------------------------------------------------
>
> Key: AMQ-721
> URL: https://issues.apache.org/activemq/browse/AMQ-721
> Project: ActiveMQ
> Type: Bug
> Components: JMS client
> Versions: 4.0
> Environment: .NET 2.0 ,C# + trunk
> Reporter: vincent boilay
> Priority: Blocker
>
>
> Openwire client hangs after receiving 999 messages
> changing Session.Prefetch postpone the problem...
> Current code is :
> public class Session : ISession
> {
> :
> :
> private int prefetchSize = 1000;
> this block at message #999
> changing private int prefetchSize = 2000 ==> blocks at message #1999
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see:
http://www.atlassian.com/software/jira
