PlanetJava
Custom Search

java-activemq-devel
[Top] [All Lists]

[jira] [Created] (AMQ-3313) When prefetch size=1 and ack-mode=CLIENT_ACK

Subject: [jira] [Created] (AMQ-3313) When prefetch size=1 and ack-mode=CLIENT_ACKNOWLEDGE, 2 messages are dispatched to client actually.
Date: Tue, 10 May 2011 15:32:47 +0000 (UTC)
When prefetch size=1 and ack-mode=CLIENT_ACKNOWLEDGE, 2 messages are dispatched 
to client actually.
---------------------------------------------------------------------------------------------------
                 Key: AMQ-3313
                 URL: https://issues.apache.org/jira/browse/AMQ-3313
             Project: ActiveMQ
          Issue Type: Bug
          Components: Broker
    Affects Versions: 5.4.2
         Environment: RHEL5/ MAC OS X 10.6.7
            Reporter: Fengming Lou
            Priority: Minor
Setups:
1. use producer/consumer code come with the packaged examples.
2. Send 10 messages to test queue
3. Start up consumer. The consumer is modified to consume 1 messages every 30 
seconds.
4. The ackMode is set to CLIENT_ACKNOWLEDGE
5. prefetch size=1 and 4 are tested
6. Monitor and reset queue data through jconsole
Conclusion:
1. For prefetch size=1, broker actually dispatches 2 (1 more than prefetch).
2. For prefetch size=4, broker dispatch exactly 4 messages.
Deatails:
Test prefetch=1
1. Reset queue statistics, my.test (through jconsole)
2. Sent 10 messages to my.test(through jconsole)
3. Start up consumer:
ant consumer -Durl=tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=1 
-Dmax=10 -Ddurable=false -DtimeToLive=600000 -Dack-mode=CLIENT_ACKNOWLEDGE 
-Dsubject=my.test
4. monitor consumer logs and jconsole stats.
  The InFlight number was always equal to 2 before 9 messages were consumed.
consumer:
     [echo] Running consumer against server at $url = 
tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=1 for subject $subject = 
my.test
     [java] Connecting to URL: 
tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=1
     [java] Consuming queue: my.test
     [java] Using a non-durable subscription
     [java] Running 1 parallel threads
     [java] [Thread-3] We are about to wait until we consume: 10 message(s) 
then we will shutdown
     [java] [1302639994466 Thread-3] Received: 'Test 1' (length 6)
     [java] [1302640024469 Thread-3] Received: 'Test 2' (length 6)
     [java] [1302640054470 Thread-3] Received: 'Test 3' (length 6)
     [java] [1302640084470 Thread-3] Received: 'Test 4' (length 6)
     [java] [1302640114469 Thread-3] Received: 'Test 5' (length 6)
     [java] [1302640144469 Thread-3] Received: 'Test 6' (length 6)
     [java] [1302640174469 Thread-3] Received: 'Test 7' (length 6)
     [java] [1302640204470 Thread-3] Received: 'Test 8' (length 6)
     [java] [1302640234470 Thread-3] Received: 'Test 9' (length 6)
     [java] [1302640264470 Thread-3] Received: 'Test 10' (length 7)
Above test was repeated for prefetch=4. The Inflight indicates exactly 4 
messages were dispatched.
consumer:
     [echo] Running consumer against server at $url = 
tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=4 for subject $subject = 
my.test
     [java] Connecting to URL: 
tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=4
     [java] Consuming queue: my.test
     [java] Using a non-durable subscription
     [java] Running 1 parallel threads
     [java] [Thread-3] We are about to wait until we consume: 10 message(s) 
then we will shutdown
     [java] [1302640654692 Thread-3] Received: 'Test 1' (length 6)
     [java] [1302640684694 Thread-3] Received: 'Test 2' (length 6)
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
msgmiddle
<Prev in Thread] Current Thread [Next in Thread>
  • [jira] [Created] (AMQ-3313) When prefetch size=1 and ack-mode=CLIENT_ACKNOWLEDGE, 2 messages are dispatched to client actually.,
Current Sitemap | © 2012 planetjava | Contact | Privacy Policy