[hornetq-commits] JBoss hornetq SVN: r9271 - trunk/src/main/org/hornetq/core/protocol/stomp.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-05-27 03:46:08 -0400 (Thu, 27 May 2010)
New Revision: 9271

Modified:
   trunk/src/main/org/hornetq/core/protocol/stomp/StompUtils.java
Log:
https://jira.jboss.org/browse/HORNETQ-395: Stomp expiration header is not supported

* use correct Stomp Expiration header to set HornetQ's core message expiration time

Modified: trunk/src/main/org/hornetq/core/protocol/stomp/StompUtils.java
===================================================================
--- trunk/src/main/org/hornetq/core/protocol/stomp/StompUtils.java	2010-05-27 02:49:34 UTC (rev 9270)
+++ trunk/src/main/org/hornetq/core/protocol/stomp/StompUtils.java	2010-05-27 07:46:08 UTC (rev 9271)
@@ -67,7 +67,7 @@
       {
          msg.putStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME, SimpleString.toSimpleString((String)replyTo));
       }
-      String expiration = (String)headers.remove(Stomp.Headers.Send.REPLY_TO);
+      String expiration = (String)headers.remove(Stomp.Headers.Send.EXPIRATION_TIME);
       if (expiration != null)
       {
          msg.setExpiration(Long.parseLong(expiration));