[jira] Resolved: (AMQNET-151) In DoNET tthe ActiveMQ 5.2's MaximumPendingMessageLimit is doesn't work

["Jim Gomes (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/activemq/browse/AMQNET-151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jim Gomes resolved AMQNET-151.
------------------------------

    Resolution: Incomplete

If there is an issue here, it seems that it would be a Broker issue, and not a client issue.  The description states that even the Java client had the same problem.  Therefore, it is either a Broker issue, or a mis-configured test.

> In DoNET tthe ActiveMQ 5.2's MaximumPendingMessageLimit is doesn't work 
> ------------------------------------------------------------------------
>
>                 Key: AMQNET-151
>                 URL: https://issues.apache.org/activemq/browse/AMQNET-151
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: ActiveMQ Client
>         Environment: ActiveMQ 5.1, XP 64,NMS, NMS.ActiveMQ, vs2008 ,java1.6  ant build the activemq
>            Reporter: xinfang.yuan
>            Assignee: Jim Gomes
>             Fix For: 1.1
>
>
> i tried to test the  MaximumPendingMessageLimit  property in donet . but it doesn't work.  i tried to setup it in Code, or ActiveMQ.XML ,it both doesn't work
> 1. create a durable consumer
> 2. create a producer and send message in topic (persistent send)
> 3. consumer get message and try to block the consumer speed. (speed is slow )
> 4  Go to web console check the pendingmessage number 
>     The number should be keep the maxpendingmessage number. my consumer is slow the producer is faster. but i found out the number is still grow. 
>   
> i will create another test poster and  attach the test file in there
> http://www.nabble.com/pendingmessagelimit-option-seems-doesn%27t-work!-td22447336r0.html
> by the way there have another people test it , it also doesn't work for Java. 
> http://www.nabble.com/Fast-producers%2Cslow-consumer...-queue-growing-forever-td22373306.html
> thanks
> sample code---- include connection ,session ,consumer and producer
> ---------
>    public TopicConnection(IConnectionFactory connectionFactory, string clientId, string topicName)
>         {
>             this.connection = connectionFactory.CreateConnection() as Connection ;
>             this.connection.ClientId = clientId;
>             if (!this.connection.IsStarted)
>             {
>                 this.connection.Start();
>             }
>             this.session = this.connection.CreateSession(AcknowledgementMode.ClientAcknowledge) as Session;
>             session.MaximumPendingMessageLimit = 10;
>             session.PrefetchSize = 20;
>             this.topic = new ActiveMQTopic(topicName);
>           
>         }
> -------------------------------
> ----- running another console to get message--
>   IMessageConsumer consumer = this.session.CreateDurableConsumer(this.topic, consumerId, "2 > 1", false);
>   consumer.Listener += new MessageListener(consumer_Listener);
>  void consumer_Listener(IMessage message)
>         {
>               ActiveMQTextMessage msg = message as ActiveMQTextMessage;
>               Console.WriteLine("Message received:" + "Id = " + msg.NMSMessageId + ", Content:" + msg.Text);
>               Thread.sleep(1000);//block here
>               message.Acknowledge();
>         }
> ---- running another console to send message
>  IMessageProducer producer = this.session.CreateProducer(this.topic);
>  while (true)
>       {
>                      publisher.SendMessage("Message:" + DateTime.Now.ToString("yyyy-mm-dd HH:MM:ss") + "---" + i.ToString() );
>      }
> -------------

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