activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: ACKs not being delivered correctly in ActiveMQ 5.1 (QueueSize growing)
Date Wed, 13 Aug 2008 21:10:32 GMT
Hi Sateesh - can you share some more details of your setup ?

cheers,

Rob

On 13 Aug 2008, at 19:45, sateesh wrote:

>
> Hi,
>
>  I am also having the same Issue ..Our Application worked fine with  
> 4.1
> version and after switching to 5.1.0 the JMS Client will pick up few
> messages ( i am not sure it is exactly 11) the messges are not  
> dispatched to
> the Consumers..!!!
>
>
> Regards
> Sateesh
>
>
>
>
>
> sparky2708 wrote:
>>
>> I was using a C# client (NMS) to connect to the ActiveMQ 5.1 Broker  
>> and I
>> am noticing that the broker always sends me 11 messages and then  
>> stops
>> sending (am expecting to get about 200). I can reproduce this  
>> consistently
>> - it always sends me 11 messages. When I open JConsole it looks  
>> like the
>> size of the Queue (QueueSize in jconsole) on the broker keeps  
>> growing for
>> the Queue that I am subscribing to. When I make a connection in C#  
>> I call:
>>
>>  IConnectionFactory connectionFactory = new ConnectionFactory(new
>> Uri(url));
>>            _connection = connectionFactory.CreateConnection();
>>            _connection.ExceptionListener += new
>> ExceptionListener(_connection_ExceptionListener);
>>            _connection.ClientId =
>> System.Environment.GetEnvironmentVariable("USERNAME") + "@" +
>> System.Environment.GetEnvironmentVariable("COMPUTERNAME") + "-" +
>> DateTime.Now + "--" + _connection.ClientId;
>>            _connection.AcknowledgementMode =
>> AcknowledgementMode.AutoAcknowledge;
>>            _connection.Start();
>>
>> I tried to change the AcknowledgementMode to
>>            _connection.AcknowledgementMode =
>> AcknowledgementMode.ClientAcknowledge;
>>
>> and acknowledge the messages myself when I receive them. Both
>> AutoAcknowledge and ClientAcknowledge (with my acknowledgments)
>> consistently receive only 11 messages out of 200 that I am  
>> expecting to
>> receive. My QueueSize in JConsole always increases in multiples of  
>> 11 when
>> I start the client. InFlightCount always says 11 also. It looks  
>> like the
>> Producer that sends those messages is throttling down or maybe  
>> ActiveMQ is
>> throttling down because it is not receiving ACKs [my theory]. Any  
>> ideas?
>>
>> When I startup the broker 4.1.0-incubator which I was using before  
>> and
>> connect the same C# client to it then everything works as expected  
>> both
>> when I use ClientAcknowledge and AutoAcknowledge mode so this  
>> points to
>> something being wrong in the 5.1 broker that seems to be working  
>> correctly
>> in 4.1.0.
>>
>
> -- 
> View this message in context: http://www.nabble.com/ACKs-not-being-delivered-correctly-in-ActiveMQ-5.1-%28QueueSize-growing%29-tp18944691p18968885.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>


Mime
View raw message