activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [2/3] activemq-artemis git commit: Add "persistent" header to outbound STOMP messages
Date Wed, 27 Jan 2016 18:21:10 GMT
Add "persistent" header to outbound STOMP messages


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/51f12538
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/51f12538
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/51f12538

Branch: refs/heads/master
Commit: 51f125387bbcb4b6b68276450c0e87385b17298f
Parents: bdea213
Author: Ville Skyttä <ville.skytta@iki.fi>
Authored: Wed Jan 27 19:09:19 2016 +0200
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Wed Jan 27 13:20:55 2016 -0500

----------------------------------------------------------------------
 .../org/apache/activemq/artemis/core/protocol/stomp/Stomp.java     | 2 ++
 .../apache/activemq/artemis/core/protocol/stomp/StompUtils.java    | 1 +
 2 files changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/51f12538/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/Stomp.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/Stomp.java
b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/Stomp.java
index 59a6916..1607666 100644
--- a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/Stomp.java
+++ b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/Stomp.java
@@ -123,6 +123,8 @@ public interface Stomp {
          String SUBSCRIPTION = "subscription";
 
          String ACK = "ack";
+
+         String PERSISTENT = "persistent";
       }
 
       public interface Subscribe {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/51f12538/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompUtils.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompUtils.java
b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompUtils.java
index 2acd74f..d27a4bc 100644
--- a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompUtils.java
+++ b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompUtils.java
@@ -92,6 +92,7 @@ public class StompUtils {
       command.addHeader(Stomp.Headers.Message.EXPIRATION_TIME, "" + message.getExpiration());
       command.addHeader(Stomp.Headers.Message.REDELIVERED, String.valueOf(deliveryCount >
1));
       command.addHeader(Stomp.Headers.Message.PRIORITY, "" + message.getPriority());
+      command.addHeader(Stomp.Headers.Message.PERSISTENT, "" + message.isDurable());
       if (message.getStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME) != null) {
          command.addHeader(Stomp.Headers.Message.REPLY_TO, message.getStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME));
       }


Mime
View raw message