activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "xinfang.yuan (JIRA)" <>
Subject [jira] Created: (AMQNET-151) In DoNET tthe ActiveMQ 5.2's MaximumPendingMessageLimit is doesn't work
Date Mon, 16 Mar 2009 16:29:42 GMT
In DoNET tthe ActiveMQ 5.2's MaximumPendingMessageLimit is doesn't work 

                 Key: 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
            Reporter: xinfang.yuan
            Assignee: Jim Gomes

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!-td22447336r0.html

by the way there have another people test it , it also doesn't work for Java.


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.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

---- 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.

View raw message