You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2008/07/04 19:42:12 UTC
svn commit: r674102 - in /incubator/qpid/trunk/qpid/java/tools: ./ src/
src/main/ src/main/java/ src/main/java/org/ src/main/java/org/apache/
src/main/java/org/apache/qpid/ src/main/java/org/apache/qpid/tools/
Author: ritchiem
Date: Fri Jul 4 10:42:12 2008
New Revision: 674102
URL: http://svn.apache.org/viewvc?rev=674102&view=rev
Log:
Addition of tools directory for various Qpid Java tools
The first too JNDICheck allows the contents of a JNDI properties file to be parsed and presented as JNDI will process it.
Handly for validating the parsing of a ConnectionURL
Added:
incubator/qpid/trunk/qpid/java/tools/
incubator/qpid/trunk/qpid/java/tools/build.xml
incubator/qpid/trunk/qpid/java/tools/src/
incubator/qpid/trunk/qpid/java/tools/src/main/
incubator/qpid/trunk/qpid/java/tools/src/main/java/
incubator/qpid/trunk/qpid/java/tools/src/main/java/org/
incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/
incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/
incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/
incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java
Added: incubator/qpid/trunk/qpid/java/tools/build.xml
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/tools/build.xml?rev=674102&view=auto
==============================================================================
--- incubator/qpid/trunk/qpid/java/tools/build.xml (added)
+++ incubator/qpid/trunk/qpid/java/tools/build.xml Fri Jul 4 10:42:12 2008
@@ -0,0 +1,27 @@
+<!--
+ -
+ - 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.
+ -
+ -->
+<project name="Qpid Tools" default="build">
+
+ <property name="module.depends" value="client"/>
+
+ <import file="../module.xml"/>
+
+</project>
Added: incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java?rev=674102&view=auto
==============================================================================
--- incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java (added)
+++ incubator/qpid/trunk/qpid/java/tools/src/main/java/org/apache/qpid/tools/JNDICheck.java Fri Jul 4 10:42:12 2008
@@ -0,0 +1,200 @@
+/*
+ *
+ * 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.qpid.tools;
+
+import org.apache.qpid.client.AMQDestination;
+import org.apache.qpid.client.AMQConnectionFactory;
+import org.apache.qpid.jms.FailoverPolicy;
+
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+import java.util.Properties;
+import java.util.Hashtable;
+import java.util.Enumeration;
+import java.util.List;
+import java.util.LinkedList;
+import java.io.IOException;
+import java.io.File;
+import java.io.FileReader;
+
+public class JNDICheck
+{
+ private static final String QUEUE = "queue.";
+ private static final String TOPIC = "topic.";
+ private static final String DESTINATION = "destination.";
+ private static final String CONNECTION_FACTORY = "connectionfactory.";
+
+ public static void main(String[] args)
+ {
+
+ if (args.length != 1)
+ {
+ usage();
+ }
+
+ String propertyFile = args[0];
+
+ new JNDICheck(propertyFile);
+ }
+
+ private static void usage()
+ {
+ exit("Usage: JNDICheck <JNDI Config file>", 0);
+ }
+
+ private static void exit(String message, int exitCode)
+ {
+ System.err.println(message);
+ System.exit(exitCode);
+ }
+
+ private static String JAVA_NAMING = "java.naming.factory.initial";
+
+ Context _context = null;
+ Hashtable _environment = null;
+
+ public JNDICheck(String propertyFile)
+ {
+
+ // Load JNDI properties
+ Properties properties = new Properties();
+
+ try
+ {
+ properties.load(new FileReader(new File(propertyFile)));
+ }
+ catch (IOException e)
+ {
+ exit("Unable to open property file:" + propertyFile + ". Due to:" + e.getMessage(), 1);
+ }
+
+ //Create the initial context
+ try
+ {
+
+ System.setProperty(JAVA_NAMING, properties.getProperty(JAVA_NAMING));
+
+ _context = new InitialContext(properties);
+
+ _environment = _context.getEnvironment();
+
+ Enumeration keys = _environment.keys();
+
+ List<String> queues = new LinkedList<String>();
+ List<String> topics = new LinkedList<String>();
+ List<String> destinations = new LinkedList<String>();
+ List<String> connectionFactories = new LinkedList<String>();
+
+ while (keys.hasMoreElements())
+ {
+ String key = keys.nextElement().toString();
+
+ if (key.startsWith(QUEUE))
+ {
+ queues.add(key);
+ }
+ else if (key.startsWith(TOPIC))
+ {
+ topics.add(key);
+ }
+ else if (key.startsWith(DESTINATION))
+ {
+ destinations.add(key);
+ }
+ else if (key.startsWith(CONNECTION_FACTORY))
+ {
+ connectionFactories.add(key);
+ }
+ }
+
+ printHeader(propertyFile);
+ printEntries(QUEUE, queues);
+ printEntries(TOPIC, topics);
+ printEntries(DESTINATION, destinations);
+ printEntries(CONNECTION_FACTORY, connectionFactories);
+
+ }
+ catch (NamingException e)
+ {
+ exit("Unable to load JNDI Context due to:" + e.getMessage(), 1);
+ }
+
+ }
+
+ private void printHeader(String file)
+ {
+ print("JNDI file :" + file);
+ }
+
+ private void printEntries(String type, List<String> list)
+ {
+ if (list.size() > 0)
+ {
+ String name = type.substring(0, 1).toUpperCase() + type.substring(1, type.length() - 1);
+ print(name + " elements in file:");
+ printList(list);
+ print("");
+ }
+ }
+
+ private void printList(List<String> list)
+ {
+ for (String item : list)
+ {
+ String key = item.substring(item.indexOf('.') + 1);
+
+ try
+ {
+ print(key, _context.lookup(key));
+ }
+ catch (NamingException e)
+ {
+ exit("Error: item " + key + " no longer in context.", 1);
+ }
+ }
+ }
+
+ private void print(String key, Object object)
+ {
+ if (object instanceof AMQDestination)
+ {
+ print(key + ":" + object);
+ }
+ else if (object instanceof AMQConnectionFactory)
+ {
+ AMQConnectionFactory factory = (AMQConnectionFactory) object;
+ print(key + ":Connection");
+ print("ConnectionURL:");
+ print(factory.getConnectionURL().toString());
+ print("FailoverPolicy");
+ print(new FailoverPolicy(factory.getConnectionURL()).toString());
+ print("");
+ }
+ }
+
+ private void print(String msg)
+ {
+ System.out.println(msg);
+ }
+
+}