Hello all,

Saw that the code moved over to Apache, and thought I would submit my first of possibly many patches.

I am using the STOMP transport with a bunch of Python code, and it seems that priority support was mis-coded.

Attached is the patch.

Thanks
Scott Sanders
-   jjmatchedKind = kind;
-   jjmatchedPos = pos;
-   return pos + 1;
-}
-private final int jjMoveStringLiteralDfa0_0()
-{
-   switch(curChar)
-   {
-      case 9:
-         jjmatchedKind = 2;
-         return jjMoveNfa_0(5, 0);
-      case 10:
-         jjmatchedKind = 3;
-         return jjMoveNfa_0(5, 0);
-      case 12:
-         jjmatchedKind = 5;
-         return jjMoveNfa_0(5, 0);
-      case 13:
-         jjmatchedKind = 4;
-         return jjMoveNfa_0(5, 0);
-      case 32:
-         jjmatchedKind = 1;
-         return jjMoveNfa_0(5, 0);
-      case 37:
-         jjmatchedKind = 41;
-         return jjMoveNfa_0(5, 0);
-      case 40:
-         jjmatchedKind = 34;
-         return jjMoveNfa_0(5, 0);
-      case 41:
-         jjmatchedKind = 36;
-         return jjMoveNfa_0(5, 0);
-      case 42:
-         jjmatchedKind = 39;
-         return jjMoveNfa_0(5, 0);
-      case 43:
-         jjmatchedKind = 37;
-         return jjMoveNfa_0(5, 0);
-      case 44:
-         jjmatchedKind = 35;
-         return jjMoveNfa_0(5, 0);
-      case 45:
-         jjmatchedKind = 38;
-         return jjMoveNfa_0(5, 0);
-      case 47:
-         jjmatchedKind = 40;
-         return jjMoveNfa_0(5, 0);
-      case 60:
-         jjmatchedKind = 32;
-         return jjMoveStringLiteralDfa1_0(0x220000000L);
-      case 61:
-         jjmatchedKind = 28;
-         return jjMoveNfa_0(5, 0);
-      case 62:
-         jjmatchedKind = 30;
-         return jjMoveStringLiteralDfa1_0(0x80000000L);
-      case 65:
-         return jjMoveStringLiteralDfa1_0(0x200L);
-      case 66:
-         return jjMoveStringLiteralDfa1_0(0x800L);
-      case 69:
-         return jjMoveStringLiteralDfa1_0(0x2000L);
-      case 70:
-         return jjMoveStringLiteralDfa1_0(0x20000L);
-      case 73:
-         return jjMoveStringLiteralDfa1_0(0xc000L);
-      case 76:
-         return jjMoveStringLiteralDfa1_0(0x1000L);
-      case 78:
-         return jjMoveStringLiteralDfa1_0(0x40100L);
-      case 79:
-         return jjMoveStringLiteralDfa1_0(0x400L);
-      case 84:
-         return jjMoveStringLiteralDfa1_0(0x10000L);
-      case 88:
-         return jjMoveStringLiteralDfa1_0(0x180000L);
-      case 97:
-         return jjMoveStringLiteralDfa1_0(0x200L);
-      case 98:
-         return jjMoveStringLiteralDfa1_0(0x800L);
-      case 101:
-         return jjMoveStringLiteralDfa1_0(0x2000L);
-      case 102:
-         return jjMoveStringLiteralDfa1_0(0x20000L);
-      case 105:
-         return jjMoveStringLiteralDfa1_0(0xc000L);
-      case 108:
-         return jjMoveStringLiteralDfa1_0(0x1000L);
-      case 110:
-         return jjMoveStringLiteralDfa1_0(0x40100L);
-      case 111:
-         return jjMoveStringLiteralDfa1_0(0x400L);
-      case 116:
-         return jjMoveStringLiteralDfa1_0(0x10000L);
-      case 120:
-         return jjMoveStringLiteralDfa1_0(0x180000L);
-      default :
-         return jjMoveNfa_0(5, 0);
Index: org/activemq/transport/stomp/Stomp.java
===================================================================
--- org/activemq/transport/stomp/Stomp.java     (revision 359171)
+++ org/activemq/transport/stomp/Stomp.java     (working copy)
@@ -58,7 +58,7 @@
             String CORRELATION_ID = "correlation-id";
             String REPLY_TO = "reply-to";
             String EXPIRATION_TIME = "expires";
-            String PRORITY = "priority";
+            String PRIORITY = "priority";
             String TYPE = "type";
         }
 
Index: org/activemq/transport/stomp/Send.java
===================================================================
--- org/activemq/transport/stomp/Send.java      (revision 359171)
+++ org/activemq/transport/stomp/Send.java      (working copy)
@@ -96,9 +96,9 @@
         if (expiration != null) {
             msg.setJMSExpiration(asLong(expiration));
         }
-        Object priority = headers.remove(Stomp.Headers.Send.PRORITY);
+        Object priority = headers.remove(Stomp.Headers.Send.PRIORITY);
         if (priority != null) {
-            msg.setJMSExpiration(asInt(priority));
+            msg.setJMSPriority(asInt(priority));
         }
 
         msg.setJMSReplyTo(DestinationNamer.convert((String) 
headers.remove(Stomp.Headers.Send.REPLY_TO)));

Reply via email to