Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

allow a message to be marked as being persistent or not 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@378590 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-02-17 18:57:05 +00:00
parent c739dba503
commit f82bd11751
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java
View File

@ -103,6 +103,11 @@ class Send implements StompCommand {
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);

1
activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java
View File

@ -60,6 +60,7 @@ public interface Stomp {
String EXPIRATION_TIME = "expires";
String PRIORITY = "priority";
String TYPE = "type";
Object PERSISTENT = "persistent";
}
public interface Message {