Author: jstrachan
Date: Fri Feb 17 10:57:05 2006
New Revision: 378590
URL: http://svn.apache.org/viewcvs?rev=378590&view=rev
Log:
allow a message to be marked as being persistent or not
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java?rev=378590&r1=378589&r2=378590&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java
Fri Feb 17 10:57:05 2006
@@ -103,6 +103,11 @@
msg.setJMSReplyTo(DestinationNamer.convert((String)
headers.remove(Stomp.Headers.Send.REPLY_TO)));
+ Object persistent = headers.remove(Stomp.Headers.Send.PERSISTENT);
+ if (persistent != null) {
+ msg.setPersistent(asBool(persistent));
+ }
+
// now the general headers
msg.setProperties(headers);
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java?rev=378590&r1=378589&r2=378590&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java
Fri Feb 17 10:57:05 2006
@@ -60,6 +60,7 @@
String EXPIRATION_TIME = "expires";
String PRIORITY = "priority";
String TYPE = "type";
+ Object PERSISTENT = "persistent";
}
public interface Message {
