svn commit: r940219 - /jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/Utils.java

[se...@apache.org]

Author: sebb
Date: Sun May  2 13:38:08 2010
New Revision: 940219

URL: http://svn.apache.org/viewvc?rev=940219&view=rev
Log:
Initial checkin of utils class

Added:
    jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/Utils.java   (with props)

Added: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/Utils.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/Utils.java?rev=940219&view=auto
==============================================================================
--- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/Utils.java (added)
+++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/Utils.java Sun May  2 13:38:08 2010
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * 
+ */
+
+package org.apache.jmeter.protocol.jms;
+
+import java.util.Enumeration;
+
+import javax.jms.JMSException;
+import javax.jms.Message;
+
+/**
+ * Utility methods for JMS protocol.
+ * WARNING - the API for this class is likely to change!
+ */
+public final class Utils {
+
+    public static final String messageProperties(Message msg){
+        return messageProperties(new StringBuilder(), msg).toString();
+    }
+
+    public static final StringBuilder messageProperties(StringBuilder sb, Message msg){
+        sb.append("Properties:\n");
+        Enumeration<?> rme;
+        try {
+            rme = msg.getPropertyNames();
+            while(rme.hasMoreElements()){
+                String name=(String) rme.nextElement();
+                sb.append(name).append('\t');
+                String value=msg.getStringProperty(name);
+                sb.append(value).append('\n');
+            }
+            requestHeaders(sb, msg);
+        } catch (JMSException e) {
+            sb.append("\nError: "+e.toString());
+        }
+        return sb;
+    }
+    
+    public static final StringBuilder requestHeaders(StringBuilder sb, Message msg){
+        try {
+            sb.append("JMSCorrelationId ").append(msg.getJMSCorrelationID()).append('\n');
+            sb.append("JMSMessageId     ").append(msg.getJMSMessageID()).append('\n');
+            sb.append("JMSTimestamp     ").append(msg.getJMSTimestamp()).append('\n');
+            sb.append("JMSType          ").append(msg.getJMSType()).append('\n');
+            sb.append("JMSExpiration    ").append(msg.getJMSExpiration()).append('\n');
+            sb.append("JMSPriority      ").append(msg.getJMSPriority()).append('\n');
+            sb.append("JMSDestination   ").append(msg.getJMSDestination()).append('\n');
+        } catch (JMSException e) {
+            sb.append("\nError: "+e.toString());
+        }
+        return sb;
+    }
+}

Propchange: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/Utils.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/Utils.java
------------------------------------------------------------------------------
    svn:keywords = Author Date Id Revision