I pulled down the HornetQ source code and unless I am reading it wrong it seems like the escaping code doesn't respect the Stomp specification as it is described at http://stomp.github.io/stomp-specification-1.2.html . It looks like the code is just putting slashes before special characters instead of converting them to the stomp equivalents.

Here is the code I am talking about at https://github.com/hornetq/hornetq/blob/master/hornetq-protocols/hornetq-stomp-protocol/src/main/java/org/hornetq/core/protocol/stomp/StompFrame.java :

 public String escape(String str)
   {
      int len = str.length();


      char[] buffer = new char[2 * len];
      int iBuffer = 0;
      for (int i = 0; i < len; i++)
      {
         char c = str.charAt(i);
         if (c == '\n')
         {
            buffer[iBuffer++] = '\\';
            buffer[iBuffer] = 'n';
         }
         else if (c == '\\')
         {
            buffer[iBuffer++] = '\\';
            buffer[iBuffer] = '\\';
         }
         else if (c == ':')
         {
            buffer[iBuffer++] = '\\';
            buffer[iBuffer] = ':';
         }
         else
         {
            buffer[iBuffer] = c;
         }
         iBuffer++;
      }


      char[] total = new char[iBuffer];
      System.arraycopy(buffer, 0, total, 0, iBuffer);


      return new String(total);
   }

So unless I am reading this wrong it appears that rather than converting ':' to '\c' it is converting it to \: .

On #1 - That is confusing to me as well. It doesn't appear that the Apache client is doing that. I don't think that it is because I put some print debug statements right after the .NET client code converts the bytes it received from the stream to UTF8 and I see the 'c' characters. Another thing that is puzzling to me is the fact that some of them are converted to just 'c' and others are '\c'.

On #2 - Dumb Question -  Can you point me to some documentation on how to set up my development environment to work on the project?

I am using Intellij Idea and the "Import project from pom.xmls" didn't work right out of the box.

I must be doing something wrong because I did exactly that and there are dependencies missing all over the place in terms of:

• Maven libraries not being assigned to projects
• Sub-projects not depending on the correct other projects
• Idea not being able to see test source from projects

What version of Maven are you using?

Yong - Welcome back from vacation.

I have a test client ready in a self contained zip file that has everything you need.

What is the best way for me to share that with you?

I don't see an option to attach a file here.

Here is the client.

I haven't been able to successfully compile the HornetQ source in idea.

I did add my test and run the maven build outside, but it hung before it got to my integration test.

I'll keep trying but at least you have this client in the mean time.

Check out the README.txt inside. You should be able to run it as is from the debug or release directory, but I included all the source in there as well.

I was finally able to get this to work after trying to pull the source again and import the project again with some different maven settings.

Additionally I was able to create an integration test that reproduces the problem in the StompV11Test class.

Here is my pull request for the integration test: https://github.com/hornetq/hornetq/pull/1900

Additionally here is the code:

@Test
    public void testSendAndReceiveWithEscapedCharactersInSenderId() throws Exception
    {
        connV11.connect(defUser, defPass);
        ClientStompFrame frame = connV11.createFrame("SEND");
        frame.addHeader("destination", getQueuePrefix() + getQueueName());
        frame.addHeader("content-type", "text/plain");
        frame.setBody("Hello World 1!");


        ClientStompFrame response = connV11.sendFrame(frame);
        assertNull(response);


        //subscribe
        StompClientConnection newConn = StompClientConnectionFactory.createClientConnection("1.1", hostname, port);
        newConn.connect(defUser, defPass);


        ClientStompFrame subFrame = newConn.createFrame("SUBSCRIBE");
        subFrame.addHeader("id", "ID\\cMYMACHINE-50616-635482262727823605-1\\c1\\c1\\c1");
        subFrame.addHeader("destination", getQueuePrefix() + getQueueName());
        subFrame.addHeader("ack", "auto");


        newConn.sendFrame(subFrame);


        frame = newConn.receiveFrame();


        System.out.println("received " + frame);


        assertEquals("MESSAGE", frame.getCommand());
        assertEquals("ID:MYMACHINE-50616-635482262727823605-1:1:1:1", frame.getHeader("subscription"));
        assertNotNull(frame.getHeader("message-id"));
        assertEquals(getQueuePrefix() + getQueueName(), frame.getHeader("destination"));
        assertEquals("Hello World 1!", frame.getBody());


        //unsub
        ClientStompFrame unsubFrame = newConn.createFrame("UNSUBSCRIBE");
        unsubFrame.addHeader("id", "ID\\cMYMACHINE-50616-635482262727823605-1\\c1\\c1\\c1");
        newConn.sendFrame(unsubFrame);


        newConn.disconnect();
    }