Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-1034

Queue Browse message prefetch is being ignored

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • None
    • JBoss A-MQ 6.2
    • amqp
    • None

    • jboss-a-mq-6.2.0.redhat-117
      qpid-jms-client-0.2.0-1.el6.noarch

    • Compatibility/Configuration, User Experience
    • Hide

      1) Send to broker 1200 messages via AMQP (check they are really there)
      ./aac1_sender.java.sh --broker amqp://admin:admin@localhost:5672 --address queue_thousands --count 10000

      2) Use QueueBrowser on the same queue with specified queueBrowserPrefetch (=1000)
      ./aac1_receiver.java.sh --log-msgs dict --broker admin:admin@localhost:5672?jms.prefetchPolicy.queueBrowserPrefetch=1000 --address queue_thousands --recv-browse true | wc -l
      400

      We should get an Enumeration of 1000 messages. In my case I always get 400 messages. With or without specified prefetch argument.

      Show
      1) Send to broker 1200 messages via AMQP (check they are really there) ./aac1_sender.java.sh --broker amqp://admin:admin@localhost:5672 --address queue_thousands --count 10000 2) Use QueueBrowser on the same queue with specified queueBrowserPrefetch (=1000) ./aac1_receiver.java.sh --log-msgs dict --broker admin:admin@localhost:5672?jms.prefetchPolicy.queueBrowserPrefetch=1000 --address queue_thousands --recv-browse true | wc -l 400 We should get an Enumeration of 1000 messages. In my case I always get 400 messages. With or without specified prefetch argument.

      The message browsing prefetch does not work properly in AMQP JMS client.
      I always receive 400 messsages (when there is more then 400 msgs in queue), despite the fact, I am using option:
      jms.prefetchPolicy.queueBrowserPrefetch=1000

              Unassigned Unassigned
              mtoth@redhat.com Michal Toth
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: