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

          Activity

          Hide
          tabish121 Timothy Bish added a comment -

          The code will now trim off any extra whitespace at the start or end of the destination name to prevent this sort of situation from happening again.

          Show
          tabish121 Timothy Bish added a comment - The code will now trim off any extra whitespace at the start or end of the destination name to prevent this sort of situation from happening again.

            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: