activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r378590 - in /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp: Send.java Stomp.java
Date Fri, 17 Feb 2006 18:57:07 GMT
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 {



Mime
View raw message