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 2014/01/18 08:18:26 UTC
git commit: [KARAF-2692] Add file name completer for jms:delete
command
Updated Branches:
refs/heads/master d5dbcaa5c -> f08a5c4d7
[KARAF-2692] Add file name completer for jms:delete command
Project: http://git-wip-us.apache.org/repos/asf/karaf/repo
Commit: http://git-wip-us.apache.org/repos/asf/karaf/commit/f08a5c4d
Tree: http://git-wip-us.apache.org/repos/asf/karaf/tree/f08a5c4d
Diff: http://git-wip-us.apache.org/repos/asf/karaf/diff/f08a5c4d
Branch: refs/heads/master
Commit: f08a5c4d79b56c3ec462e337f760b40f81aaea7e
Parents: d5dbcaa
Author: Jean-Baptiste Onofré <jb...@apache.org>
Authored: Sat Jan 18 08:17:59 2014 +0100
Committer: Jean-Baptiste Onofré <jb...@apache.org>
Committed: Sat Jan 18 08:17:59 2014 +0100
----------------------------------------------------------------------
.../karaf/jdbc/command/DataSourcesCommand.java | 2 +-
.../DataSourcesJNDINameCompleter.java | 53 --------------------
.../completers/DataSourcesNameCompleter.java | 53 ++++++++++++++++++++
.../OSGI-INF/blueprint/jdbc-command.xml | 10 ++--
.../karaf/jdbc/internal/JdbcMBeanImpl.java | 2 +-
.../ConnectionFactoriesCompleter.java | 53 --------------------
.../ConnectionFactoriesFileNameCompleter.java | 53 ++++++++++++++++++++
.../ConnectionFactoriesNameCompleter.java | 53 ++++++++++++++++++++
.../OSGI-INF/blueprint/jms-command.xml | 23 +++++----
.../java/org/apache/karaf/jms/JmsService.java | 8 +++
.../karaf/jms/internal/JmsServiceImpl.java | 16 ++++++
11 files changed, 203 insertions(+), 123 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/DataSourcesCommand.java
----------------------------------------------------------------------
diff --git a/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/DataSourcesCommand.java b/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/DataSourcesCommand.java
index 228b22a..36df691 100644
--- a/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/DataSourcesCommand.java
+++ b/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/DataSourcesCommand.java
@@ -28,7 +28,7 @@ public class DataSourcesCommand extends JdbcCommandSupport {
public Object doExecute() throws Exception {
ShellTable table = new ShellTable();
- table.column("JNDI Name");
+ table.column("Name");
table.column("Product");
table.column("Version");
table.column("URL");
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/completers/DataSourcesJNDINameCompleter.java
----------------------------------------------------------------------
diff --git a/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/completers/DataSourcesJNDINameCompleter.java b/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/completers/DataSourcesJNDINameCompleter.java
deleted file mode 100644
index c5882a6..0000000
--- a/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/completers/DataSourcesJNDINameCompleter.java
+++ /dev/null
@@ -1,53 +0,0 @@
-/*
- * 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.karaf.jdbc.command.completers;
-
-import org.apache.karaf.jdbc.JdbcService;
-import org.apache.karaf.shell.console.Completer;
-import org.apache.karaf.shell.console.completer.StringsCompleter;
-
-import java.util.List;
-
-/**
- * Completer on the JDBC datasources JNDI name (identifier).
- */
-public class DataSourcesJNDINameCompleter implements Completer {
-
- private JdbcService jdbcService;
-
- @Override
- public int complete(String buffer, int cursor, List<String> candidates) {
- StringsCompleter delegate = new StringsCompleter();
- try {
- for (String datasource : jdbcService.datasources()) {
- delegate.getStrings().add(datasource);
- }
- } catch (Exception e) {
- // nothing to do
- }
- return delegate.complete(buffer, cursor, candidates);
- }
-
- public JdbcService getJdbcService() {
- return jdbcService;
- }
-
- public void setJdbcService(JdbcService jdbcService) {
- this.jdbcService = jdbcService;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/completers/DataSourcesNameCompleter.java
----------------------------------------------------------------------
diff --git a/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/completers/DataSourcesNameCompleter.java b/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/completers/DataSourcesNameCompleter.java
new file mode 100644
index 0000000..e0adb31
--- /dev/null
+++ b/jdbc/command/src/main/java/org/apache/karaf/jdbc/command/completers/DataSourcesNameCompleter.java
@@ -0,0 +1,53 @@
+/*
+ * 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.karaf.jdbc.command.completers;
+
+import org.apache.karaf.jdbc.JdbcService;
+import org.apache.karaf.shell.console.Completer;
+import org.apache.karaf.shell.console.completer.StringsCompleter;
+
+import java.util.List;
+
+/**
+ * Completer on the JDBC datasources name (JNDI or OSGi service property).
+ */
+public class DataSourcesNameCompleter implements Completer {
+
+ private JdbcService jdbcService;
+
+ @Override
+ public int complete(String buffer, int cursor, List<String> candidates) {
+ StringsCompleter delegate = new StringsCompleter();
+ try {
+ for (String datasource : jdbcService.datasources()) {
+ delegate.getStrings().add(datasource);
+ }
+ } catch (Exception e) {
+ // nothing to do
+ }
+ return delegate.complete(buffer, cursor, candidates);
+ }
+
+ public JdbcService getJdbcService() {
+ return jdbcService;
+ }
+
+ public void setJdbcService(JdbcService jdbcService) {
+ this.jdbcService = jdbcService;
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jdbc/command/src/main/resources/OSGI-INF/blueprint/jdbc-command.xml
----------------------------------------------------------------------
diff --git a/jdbc/command/src/main/resources/OSGI-INF/blueprint/jdbc-command.xml b/jdbc/command/src/main/resources/OSGI-INF/blueprint/jdbc-command.xml
index a6dd978..fe501f4 100644
--- a/jdbc/command/src/main/resources/OSGI-INF/blueprint/jdbc-command.xml
+++ b/jdbc/command/src/main/resources/OSGI-INF/blueprint/jdbc-command.xml
@@ -44,7 +44,7 @@
<property name="jdbcService" ref="jdbcService"/>
</action>
<completers>
- <ref component-id="datasourcesJNDINameCompleter"/>
+ <ref component-id="datasourcesNameCompleter"/>
<null/>
</completers>
</command>
@@ -53,7 +53,7 @@
<property name="jdbcService" ref="jdbcService"/>
</action>
<completers>
- <ref component-id="datasourcesJNDINameCompleter"/>
+ <ref component-id="datasourcesNameCompleter"/>
<null/>
</completers>
</command>
@@ -62,7 +62,7 @@
<property name="jdbcService" ref="jdbcService"/>
</action>
<completers>
- <ref component-id="datasourcesJNDINameCompleter"/>
+ <ref component-id="datasourcesNameCompleter"/>
<null/>
</completers>
</command>
@@ -71,13 +71,13 @@
<property name="jdbcService" ref="jdbcService"/>
</action>
<completers>
- <ref component-id="datasourcesJNDINameCompleter"/>
+ <ref component-id="datasourcesNameCompleter"/>
<null/>
</completers>
</command>
</command-bundle>
- <bean id="datasourcesJNDINameCompleter" class="org.apache.karaf.jdbc.command.completers.DataSourcesJNDINameCompleter">
+ <bean id="datasourcesNameCompleter" class="org.apache.karaf.jdbc.command.completers.DataSourcesNameCompleter">
<property name="jdbcService" ref="jdbcService" />
</bean>
<bean id="datasourcesFileNameCompleter" class="org.apache.karaf.jdbc.command.completers.DataSourcesFileNameCompleter">
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jdbc/core/src/main/java/org/apache/karaf/jdbc/internal/JdbcMBeanImpl.java
----------------------------------------------------------------------
diff --git a/jdbc/core/src/main/java/org/apache/karaf/jdbc/internal/JdbcMBeanImpl.java b/jdbc/core/src/main/java/org/apache/karaf/jdbc/internal/JdbcMBeanImpl.java
index f87eafa..92bbba8 100644
--- a/jdbc/core/src/main/java/org/apache/karaf/jdbc/internal/JdbcMBeanImpl.java
+++ b/jdbc/core/src/main/java/org/apache/karaf/jdbc/internal/JdbcMBeanImpl.java
@@ -36,7 +36,7 @@ public class JdbcMBeanImpl implements JdbcMBean {
try {
CompositeType type = new CompositeType("DataSource", "JDBC DataSource",
new String[]{ "name", "product", "version", "url "},
- new String[]{ "JNDI Name", "Database product", "Database version", "JDBC URL" },
+ new String[]{ "Name", "Database product", "Database version", "JDBC URL" },
new OpenType[]{ SimpleType.STRING, SimpleType.STRING, SimpleType.STRING, SimpleType.STRING });
TabularType tableType = new TabularType("JDBC DataSources", "Table of the JDBC DataSources",
type, new String[]{ "name" });
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesCompleter.java
----------------------------------------------------------------------
diff --git a/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesCompleter.java b/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesCompleter.java
deleted file mode 100644
index d88c230..0000000
--- a/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesCompleter.java
+++ /dev/null
@@ -1,53 +0,0 @@
-/*
- * 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.karaf.jms.command.completers;
-
-import org.apache.karaf.jms.JmsService;
-import org.apache.karaf.shell.console.Completer;
-import org.apache.karaf.shell.console.completer.StringsCompleter;
-
-import java.util.List;
-
-/**
- * Completer on the JMS connection factories.
- */
-public class ConnectionFactoriesCompleter implements Completer {
-
- private JmsService jmsService;
-
- @Override
- public int complete(String buffer, int cursor, List<String> candidates) {
- StringsCompleter delegate = new StringsCompleter();
- try {
- for (String connectionFactory : jmsService.connectionFactories()) {
- delegate.getStrings().add(connectionFactory);
- }
- } catch (Exception e) {
- // nothing to do
- }
- return delegate.complete(buffer, cursor, candidates);
- }
-
- public JmsService getJmsService() {
- return jmsService;
- }
-
- public void setJmsService(JmsService jmsService) {
- this.jmsService = jmsService;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesFileNameCompleter.java
----------------------------------------------------------------------
diff --git a/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesFileNameCompleter.java b/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesFileNameCompleter.java
new file mode 100644
index 0000000..e5cfabf
--- /dev/null
+++ b/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesFileNameCompleter.java
@@ -0,0 +1,53 @@
+/*
+ * 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.karaf.jms.command.completers;
+
+import org.apache.karaf.jms.JmsService;
+import org.apache.karaf.shell.console.Completer;
+import org.apache.karaf.shell.console.completer.StringsCompleter;
+
+import java.util.List;
+
+/**
+ * Completer on the JMS connection factory file names.
+ */
+public class ConnectionFactoriesFileNameCompleter implements Completer {
+
+ private JmsService jmsService;
+
+ @Override
+ public int complete(String buffer, int cursor, List<String> candidates) {
+ StringsCompleter delegate = new StringsCompleter();
+ try {
+ for (String connectionFactory : jmsService.connectionFactoryFileNames()) {
+ delegate.getStrings().add(connectionFactory.replace("connectionfactory-", "").replace(".xml", ""));
+ }
+ } catch (Exception e) {
+ // nothing to do
+ }
+ return delegate.complete(buffer, cursor, candidates);
+ }
+
+ public JmsService getJmsService() {
+ return jmsService;
+ }
+
+ public void setJmsService(JmsService jmsService) {
+ this.jmsService = jmsService;
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesNameCompleter.java
----------------------------------------------------------------------
diff --git a/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesNameCompleter.java b/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesNameCompleter.java
new file mode 100644
index 0000000..2d19e76
--- /dev/null
+++ b/jms/command/src/main/java/org/apache/karaf/jms/command/completers/ConnectionFactoriesNameCompleter.java
@@ -0,0 +1,53 @@
+/*
+ * 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.karaf.jms.command.completers;
+
+import org.apache.karaf.jms.JmsService;
+import org.apache.karaf.shell.console.Completer;
+import org.apache.karaf.shell.console.completer.StringsCompleter;
+
+import java.util.List;
+
+/**
+ * Completer on the JMS connection factories name.
+ */
+public class ConnectionFactoriesNameCompleter implements Completer {
+
+ private JmsService jmsService;
+
+ @Override
+ public int complete(String buffer, int cursor, List<String> candidates) {
+ StringsCompleter delegate = new StringsCompleter();
+ try {
+ for (String connectionFactory : jmsService.connectionFactories()) {
+ delegate.getStrings().add(connectionFactory);
+ }
+ } catch (Exception e) {
+ // nothing to do
+ }
+ return delegate.complete(buffer, cursor, candidates);
+ }
+
+ public JmsService getJmsService() {
+ return jmsService;
+ }
+
+ public void setJmsService(JmsService jmsService) {
+ this.jmsService = jmsService;
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jms/command/src/main/resources/OSGI-INF/blueprint/jms-command.xml
----------------------------------------------------------------------
diff --git a/jms/command/src/main/resources/OSGI-INF/blueprint/jms-command.xml b/jms/command/src/main/resources/OSGI-INF/blueprint/jms-command.xml
index afa6c00..008fa6e 100644
--- a/jms/command/src/main/resources/OSGI-INF/blueprint/jms-command.xml
+++ b/jms/command/src/main/resources/OSGI-INF/blueprint/jms-command.xml
@@ -25,7 +25,7 @@
<property name="jmsService" ref="jmsService"/>
</action>
<completers>
- <ref component-id="connectionFactoriesCompleter"/>
+ <ref component-id="connectionFactoriesNameCompleter"/>
<null/>
</completers>
</command>
@@ -39,7 +39,7 @@
<property name="jmsService" ref="jmsService"/>
</action>
<completers>
- <ref component-id="connectionFactoriesCompleter"/>
+ <ref component-id="connectionFactoriesNameCompleter"/>
<null/>
</completers>
</command>
@@ -48,7 +48,7 @@
<property name="jmsService" ref="jmsService"/>
</action>
<completers>
- <ref component-id="connectionFactoriesCompleter"/>
+ <ref component-id="connectionFactoriesNameCompleter"/>
<null/>
</completers>
</command>
@@ -62,7 +62,7 @@
<property name="jmsService" ref="jmsService"/>
</action>
<completers>
- <ref component-id="connectionFactoriesCompleter"/>
+ <ref component-id="connectionFactoriesFileNameCompleter"/>
<null/>
</completers>
</command>
@@ -71,7 +71,7 @@
<property name="jmsService" ref="jmsService"/>
</action>
<completers>
- <ref component-id="connectionFactoriesCompleter"/>
+ <ref component-id="connectionFactoriesNameCompleter"/>
<null/>
</completers>
</command>
@@ -80,7 +80,7 @@
<property name="jmsService" ref="jmsService"/>
</action>
<completers>
- <ref component-id="connectionFactoriesCompleter"/>
+ <ref component-id="connectionFactoriesNameCompleter"/>
<null/>
</completers>
</command>
@@ -89,7 +89,7 @@
<property name="jmsService" ref="jmsService"/>
</action>
<completers>
- <ref component-id="connectionFactoriesCompleter"/>
+ <ref component-id="connectionFactoriesNameCompleter"/>
<null/>
</completers>
</command>
@@ -98,7 +98,7 @@
<property name="jmsService" ref="jmsService"/>
</action>
<completers>
- <ref component-id="connectionFactoriesCompleter"/>
+ <ref component-id="connectionFactoriesNameCompleter"/>
<null/>
</completers>
</command>
@@ -107,13 +107,16 @@
<property name="jmsService" ref="jmsService"/>
</action>
<completers>
- <ref component-id="connectionFactoriesCompleter"/>
+ <ref component-id="connectionFactoriesNameCompleter"/>
<null/>
</completers>
</command>
</command-bundle>
- <bean id="connectionFactoriesCompleter" class="org.apache.karaf.jms.command.completers.ConnectionFactoriesCompleter">
+ <bean id="connectionFactoriesNameCompleter" class="org.apache.karaf.jms.command.completers.ConnectionFactoriesNameCompleter">
+ <property name="jmsService" ref="jmsService"/>
+ </bean>
+ <bean id="connectionFactoriesFileNameCompleter" class="org.apache.karaf.jms.command.completers.ConnectionFactoriesFileNameCompleter">
<property name="jmsService" ref="jmsService"/>
</bean>
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jms/core/src/main/java/org/apache/karaf/jms/JmsService.java
----------------------------------------------------------------------
diff --git a/jms/core/src/main/java/org/apache/karaf/jms/JmsService.java b/jms/core/src/main/java/org/apache/karaf/jms/JmsService.java
index fbcd67e..8aa970f 100644
--- a/jms/core/src/main/java/org/apache/karaf/jms/JmsService.java
+++ b/jms/core/src/main/java/org/apache/karaf/jms/JmsService.java
@@ -33,6 +33,14 @@ public interface JmsService {
List<String> connectionFactories() throws Exception;
/**
+ * List the JMS connecion factories file names.
+ *
+ * @return the list of JMS connection factory file names.
+ * @throws Exception
+ */
+ List<String> connectionFactoryFileNames() throws Exception;
+
+ /**
* Create a new JMS connection factory.
*
* @param name the JMS connection factory name.
http://git-wip-us.apache.org/repos/asf/karaf/blob/f08a5c4d/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java
----------------------------------------------------------------------
diff --git a/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java b/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java
index 9be6f6a..c3430ba 100644
--- a/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java
+++ b/jms/core/src/main/java/org/apache/karaf/jms/internal/JmsServiceImpl.java
@@ -101,6 +101,22 @@ public class JmsServiceImpl implements JmsService {
}
@Override
+ public List<String> connectionFactoryFileNames() throws Exception {
+ File karafBase = new File(System.getProperty("karaf.base"));
+ File deployFolder = new File(karafBase, "deploy");
+
+ String[] connectionFactoryFileNames = deployFolder.list(new FilenameFilter() {
+
+ @Override
+ public boolean accept(File dir, String name) {
+ return name.startsWith("connectionfactory-") && name.endsWith(".xml");
+ }
+ });
+
+ return Arrays.asList(connectionFactoryFileNames);
+ }
+
+ @Override
public Map<String, String> info(String connectionFactory, String username, String password) throws Exception {
Map<String, String> map = new HashMap<String, String>();
ServiceReference reference = this.lookupConnectionFactory(connectionFactory);