activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: ARTEMIS-720 Add JMSX properties in AMQP<->JMS converter
Date Thu, 08 Sep 2016 13:31:51 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master a7cac9ba5 -> bbb962045


ARTEMIS-720 Add JMSX properties in AMQP<->JMS converter


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

Branch: refs/heads/master
Commit: db7dfba6079c2f46bed5965b85510c7fcc91bd2e
Parents: a7cac9b
Author: Martyn Taylor <mtaylor@redhat.com>
Authored: Thu Sep 8 11:56:38 2016 +0100
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Thu Sep 8 09:31:43 2016 -0400

----------------------------------------------------------------------
 .../proton/converter/ActiveMQJMSVendor.java      | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/db7dfba6/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/proton/converter/ActiveMQJMSVendor.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/proton/converter/ActiveMQJMSVendor.java
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/proton/converter/ActiveMQJMSVendor.java
index 3cfb0a5..9265abe 100644
--- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/proton/converter/ActiveMQJMSVendor.java
+++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/proton/converter/ActiveMQJMSVendor.java
@@ -18,6 +18,7 @@ package org.apache.activemq.artemis.core.protocol.proton.converter;
 
 import javax.jms.BytesMessage;
 import javax.jms.Destination;
+import javax.jms.JMSException;
 import javax.jms.MapMessage;
 import javax.jms.Message;
 import javax.jms.ObjectMessage;
@@ -90,19 +91,29 @@ public class ActiveMQJMSVendor implements JMSVendor {
       try {
          message.setStringProperty("_AMQ_GROUP_ID", s);
       }
-      catch (Exception e) {
-         e.printStackTrace();
-
+      catch (JMSException e) {
+         throw new RuntimeException(e);
       }
    }
 
    @Override
    public void setJMSXGroupSequence(Message message, int i) {
-
+      try {
+         message.setIntProperty("JMSXGroupSeq", i);
+      }
+      catch (JMSException e) {
+         throw new RuntimeException(e);
+      }
    }
 
    @Override
    public void setJMSXDeliveryCount(Message message, long l) {
+      try {
+         message.setLongProperty("JMSXDeliveryCount", l);
+      }
+      catch (JMSException e) {
+         throw new RuntimeException(e);
+      }
    }
 
    public ServerJMSMessage wrapMessage(int messageType, ServerMessage wrapped, int deliveryCount)
{


Mime
View raw message