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
              Permalink
              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: