You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2016/07/14 16:49:07 UTC
karaf-decanter git commit: [KARAF-4625] Use JMS MapMessage properties
instead of JMS properties
Repository: karaf-decanter
Updated Branches:
refs/heads/master 9f270e96f -> a8a2b2a70
[KARAF-4625] Use JMS MapMessage properties instead of JMS properties
Project: http://git-wip-us.apache.org/repos/asf/karaf-decanter/repo
Commit: http://git-wip-us.apache.org/repos/asf/karaf-decanter/commit/a8a2b2a7
Tree: http://git-wip-us.apache.org/repos/asf/karaf-decanter/tree/a8a2b2a7
Diff: http://git-wip-us.apache.org/repos/asf/karaf-decanter/diff/a8a2b2a7
Branch: refs/heads/master
Commit: a8a2b2a70687c6c3791602c318f71b3a17a0f599
Parents: 9f270e9
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Authored: Thu Jul 14 18:48:38 2016 +0200
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Thu Jul 14 18:48:38 2016 +0200
----------------------------------------------------------------------
.../decanter/appender/jms/JmsAppender.java | 22 +++++++-------------
1 file changed, 8 insertions(+), 14 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/karaf-decanter/blob/a8a2b2a7/appender/jms/src/main/java/org/apache/karaf/decanter/appender/jms/JmsAppender.java
----------------------------------------------------------------------
diff --git a/appender/jms/src/main/java/org/apache/karaf/decanter/appender/jms/JmsAppender.java b/appender/jms/src/main/java/org/apache/karaf/decanter/appender/jms/JmsAppender.java
index 90289fb..0169963 100644
--- a/appender/jms/src/main/java/org/apache/karaf/decanter/appender/jms/JmsAppender.java
+++ b/appender/jms/src/main/java/org/apache/karaf/decanter/appender/jms/JmsAppender.java
@@ -18,13 +18,7 @@ package org.apache.karaf.decanter.appender.jms;
import java.util.Dictionary;
-import javax.jms.Connection;
-import javax.jms.ConnectionFactory;
-import javax.jms.Destination;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageProducer;
-import javax.jms.Session;
+import javax.jms.*;
import org.osgi.service.component.ComponentContext;
import org.osgi.service.component.annotations.Activate;
@@ -74,7 +68,7 @@ public class JmsAppender implements EventHandler {
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = createDestination(session);
MessageProducer producer = session.createProducer(destination);
- Message message = session.createMapMessage();
+ MapMessage message = session.createMapMessage();
for (String name : event.getPropertyNames()) {
Object value = event.getProperty(name);
@@ -92,16 +86,16 @@ public class JmsAppender implements EventHandler {
}
}
- private void setProperty(Message message, String name, Object value) throws JMSException {
+ private void setProperty(MapMessage message, String name, Object value) throws JMSException {
if (value instanceof String)
- message.setStringProperty(name, (String) value);
+ message.setString(name, (String) value);
else if (value instanceof Boolean)
- message.setBooleanProperty(name, (Boolean) value);
+ message.setBoolean(name, (Boolean) value);
else if (value instanceof Double)
- message.setDoubleProperty(name, (Double) value);
+ message.setDouble(name, (Double) value);
else if (value instanceof Integer)
- message.setIntProperty(name, (Integer) value);
- else message.setStringProperty(name, value.toString());
+ message.setInt(name, (Integer) value);
+ else message.setString(name, value.toString());
// we can setObject with List, Map, but they have to contain only primitives
}