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));