X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-util%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Futil%2FConfigTransactionClientsTest.java;fp=opendaylight%2Fconfig%2Fconfig-util%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Futil%2FConfigTransactionClientsTest.java;h=a6df1e91a5e5188e81137aae8284ab5ad6288d94;hb=9fb64948564e252018f9b1e13e7cea2c92f991aa;hp=0000000000000000000000000000000000000000;hpb=1742b3894614be478c333a1043ced8ef1bc5dc84;p=controller.git

diff --git a/opendaylight/config/config-util/src/test/java/org/opendaylight/controller/config/util/ConfigTransactionClientsTest.java b/opendaylight/config/config-util/src/test/java/org/opendaylight/controller/config/util/ConfigTransactionClientsTest.java
new file mode 100644
index 0000000000..a6df1e91a5
--- /dev/null
+++ b/opendaylight/config/config-util/src/test/java/org/opendaylight/controller/config/util/ConfigTransactionClientsTest.java
@@ -0,0 +1,73 @@
+/*
+ * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+package org.opendaylight.controller.config.util;
+
+import static org.junit.Assert.assertEquals;
+
+import java.lang.management.ManagementFactory;
+import java.util.Set;
+
+import javax.management.MBeanServer;
+import javax.management.ObjectName;
+
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.opendaylight.controller.config.api.jmx.ConfigTransactionControllerMXBean;
+import org.opendaylight.controller.config.api.jmx.ObjectNameUtil;
+import org.opendaylight.controller.config.util.jolokia.ConfigTransactionJolokiaClient;
+
+public class ConfigTransactionClientsTest {
+
+    private final MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
+    private String jolokiaURL;
+    private ConfigTransactionControllerMXBean transactionController;
+    private ObjectName transactionControllerON;
+    private ConfigTransactionClient jmxTransactionClient,
+            jolokiaTransactionClient;
+
+    @Before
+    public void setUp() throws Exception {
+        jolokiaURL = JolokiaHelper.startTestingJolokia();
+        transactionController = new TestingConfigTransactionController();
+        transactionControllerON = new ObjectName(ObjectNameUtil.ON_DOMAIN + ":"
+                + ObjectNameUtil.TYPE_KEY + "=TransactionController");
+        mbs.registerMBean(transactionController, transactionControllerON);
+        jmxTransactionClient = new ConfigTransactionJMXClient(null,
+                transactionControllerON,
+                ManagementFactory.getPlatformMBeanServer());
+        jolokiaTransactionClient = new ConfigTransactionJolokiaClient(
+                jolokiaURL, transactionControllerON, null);
+    }
+
+    @After
+    public void cleanUp() throws Exception {
+        JolokiaHelper.stopJolokia();
+        if (transactionControllerON != null) {
+            mbs.unregisterMBean(transactionControllerON);
+        }
+    }
+
+    @Test
+    public void testLookupConfigBeans() throws Exception {
+        Set<ObjectName> jmxLookup = testClientLookupConfigBeans(jmxTransactionClient);
+        Set<ObjectName> jolokiaLookup = testClientLookupConfigBeans(jolokiaTransactionClient);
+        assertEquals(jmxLookup, jolokiaLookup);
+    }
+
+    private Set<ObjectName> testClientLookupConfigBeans(
+            ConfigTransactionClient client) {
+        Set<ObjectName> beans = client.lookupConfigBeans();
+        for (ObjectName on : beans) {
+            assertEquals("Module", on.getKeyProperty("type"));
+        }
+        assertEquals(3, beans.size());
+        return beans;
+    }
+
+}