Uploaded image for project: 'FUSE Message Broker'
  1. FUSE Message Broker
  2. MB-1067

Space at end of queue name is not honored by consumers

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: 5.5.1-fuse-01-11
    • Fix Version/s: 5.6.0-fuse-00-00
    • Component/s: None
    • Labels:
      None

      Description

      Hi,

      Matt is on-site for a potential customer and noted the following behavior in 5.5.1-fuse-01-20:

      1. Create a queue with a space on the end.. "MyQueue "
      2. Publish X number of messages to "MyQueue "
      3. Create a queue, same name w/o space on the end. "MyQueue"
      4. Publish Y number of messages to "MyQueue"
      5. Attempt to consume messages from "MyQueue" fails.

      To reproduce the issue here, use the producer demo:

      1. ant producer -Durl=tcp://Susan-Javureks-MacBook-Pro-3.local:61616 -Dsubject="TEST.FOO " -Dmax=5
      2. ant producer -Durl=tcp://Susan-Javureks-MacBook-Pro-3.local:61616 -Dsubject="TEST.FOO" -Dmax=5

      Via jconsole, you'll see two queues created. Looking closely at the name attribute, you can see the space if you highlight the entire name (see attached jconsole.jpg).

      3. ant consumer -Durl=tcp://Susan-Javureks-MacBook-Pro-3.local:61616 -Dsubject="TEST.FOO" -Dmax=10

      Will work grab all 10 messages regardless of the "space" at the end:

      Susan-Javureks-MacBook-Pro-3:example sjavurek$ ant consumer -Durl=tcp://Susan-Javureks-MacBook-Pro-3.local:61616 -Dsubject="TEST.FOO" -Dmax=10
      Buildfile: /Users/sjavurek/Fuse/activemq/5.5.1/apache-activemq-5.5.1-fuse-01-20/example/build.xml

      init:

      compile:

      consumer:
           [echo] Running consumer against server at $url = tcp://Susan-Javureks-MacBook-Pro-3.local:61616 for subject $subject = TEST.FOO
           [java] Connecting to URL: tcp://Susan-Javureks-MacBook-Pro-3.local:61616 (:)
           [java] Consuming queue: TEST.FOO
           [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] [Thread-3] Received: 'Message: 0 sent at: Tue Jan 24 17:14:27 EST 2012  ...' (length 1000)
           [java] [Thread-3] Received: 'Message: 1 sent at: Tue Jan 24 17:14:27 EST 2012  ...' (length 1000)
           [java] [Thread-3] Received: 'Message: 2 sent at: Tue Jan 24 17:14:27 EST 2012  ...' (length 1000)
           [java] [Thread-3] Received: 'Message: 3 sent at: Tue Jan 24 17:14:27 EST 2012  ...' (length 1000)
           [java] [Thread-3] Received: 'Message: 4 sent at: Tue Jan 24 17:14:27 EST 2012  ...' (length 1000)
           [java] [Thread-3] Received: 'Message: 0 sent at: Tue Jan 24 17:14:35 EST 2012  ...' (length 1000)
           [java] [Thread-3] Received: 'Message: 1 sent at: Tue Jan 24 17:14:35 EST 2012  ...' (length 1000)
           [java] [Thread-3] Received: 'Message: 2 sent at: Tue Jan 24 17:14:35 EST 2012  ...' (length 1000)
           [java] [Thread-3] Received: 'Message: 3 sent at: Tue Jan 24 17:14:35 EST 2012  ...' (length 1000)
           [java] [Thread-3] Received: 'Message: 4 sent at: Tue Jan 24 17:14:35 EST 2012  ...' (length 1000)
           [java] [Thread-3] Closing connection
           [java] All threads completed their work
       
      BUILD SUCCESSFUL
      Total time: 2 seconds
      Susan-Javureks-MacBook-Pro-3:example sjavurek$ 

      The queue size for both queues goes to 0. Running consumer with -Dmax=1 for -Dsubject="TEST.FOO " twice in a row results in one message pulled of "TEST.FOO " and one from "TEST.FOO".

      Seems a bit confused ....

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                tabish121 Timothy Bish
                Reporter:
                sjavurek Susan Javurek
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: