| /** |
| * 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.cxf.dosgi.discovery.zookeeper; |
| |
| import junit.framework.TestCase; |
| |
| public class InterfaceDataMonitorListenerImplTest extends TestCase { |
| |
| public void testDUMMY() { |
| assertTrue(true); |
| } |
| |
| // public void testChange() throws Exception { |
| // final List<DiscoveredServiceNotification> dsnCallbacks = new ArrayList<DiscoveredServiceNotification>(); |
| // DiscoveredServiceTracker dst = new DiscoveredServiceTracker() { |
| // public void serviceChanged(DiscoveredServiceNotification dsn) { |
| // dsnCallbacks.add(dsn); |
| // } |
| // }; |
| // |
| // //---------------------------------------------------------------- |
| // // Test DiscoveredServiceNotification.AVAILABLE |
| // //---------------------------------------------------------------- |
| // Properties initial = new Properties(); |
| // initial.put("a", "b"); |
| // initial.put(ServicePublication.ENDPOINT_LOCATION, "http://somehost:12345/some/context"); |
| // ByteArrayOutputStream propBytes = new ByteArrayOutputStream(); |
| // initial.store(propBytes, ""); |
| // |
| // ZooKeeper zk = EasyMock.createMock(ZooKeeper.class); |
| // EasyMock.expect(zk.getChildren(Utils.getZooKeeperPath(String.class.getName()), false)) |
| // .andReturn(Arrays.asList("x#y#z")); |
| // EasyMock.expect(zk.getData(Utils.getZooKeeperPath(String.class.getName()) + "/x#y#z", false, null)) |
| // .andReturn(propBytes.toByteArray()); |
| // EasyMock.replay(zk); |
| // |
| // InterfaceDataMonitorListenerImpl dml = new InterfaceDataMonitorListenerImpl(zk, String.class.getName(), dst); |
| // |
| // assertEquals("Precondition failed", 0, dsnCallbacks.size()); |
| // dml.change(); |
| // assertEquals(1, dsnCallbacks.size()); |
| // DiscoveredServiceNotification dsn = dsnCallbacks.iterator().next(); |
| // assertEquals(Collections.singleton(String.class.getName()), dsn.getInterfaces()); |
| // assertEquals(DiscoveredServiceNotification.AVAILABLE, dsn.getType()); |
| // assertEquals(0, dsn.getFilters().size()); |
| // ServiceEndpointDescription sed = dsn.getServiceEndpointDescription(); |
| // assertEquals(Collections.singleton(String.class.getName()), sed.getProvidedInterfaces()); |
| // |
| // Properties expected = new Properties(); |
| // expected.load(new ByteArrayInputStream(propBytes.toByteArray())); |
| // expected.put("service.exported.configs", "org.apache.cxf.ws"); |
| // expected.put("org.apache.cxf.ws.address", "http://somehost:12345/some/context"); |
| // |
| // assertEquals(expected, sed.getProperties()); |
| // EasyMock.verify(zk); |
| // |
| // // Again with the same data |
| // EasyMock.reset(zk); |
| // EasyMock.expect(zk.getChildren(Utils.getZooKeeperPath(String.class.getName()), false)) |
| // .andReturn(Arrays.asList("x#y#z")); |
| // EasyMock.expect(zk.getData(Utils.getZooKeeperPath(String.class.getName()) + "/x#y#z", false, null)) |
| // .andReturn(propBytes.toByteArray()); |
| // EasyMock.replay(zk); |
| // |
| // dsnCallbacks.clear(); |
| // assertEquals("Precondition failed", 0, dsnCallbacks.size()); |
| // dml.change(); |
| // assertEquals(0, dsnCallbacks.size()); |
| // |
| // EasyMock.verify(zk); |
| // //---------------------------------------------------------------- |
| // // Test DiscoveredServiceNotification.MODIFIED |
| // //---------------------------------------------------------------- |
| // Properties modified = new Properties(); |
| // modified.put("c", "d"); |
| // modified.put(ServicePublication.ENDPOINT_LOCATION, "http://somehost:999/some/context"); |
| // modified.put("service.exported.configs", "org.apache.cxf.rs"); |
| // ByteArrayOutputStream modBytes = new ByteArrayOutputStream(); |
| // modified.store(modBytes, ""); |
| // |
| // EasyMock.reset(zk); |
| // EasyMock.expect(zk.getChildren(Utils.getZooKeeperPath(String.class.getName()), false)) |
| // .andReturn(Arrays.asList("x#y#z")); |
| // EasyMock.expect(zk.getData(Utils.getZooKeeperPath(String.class.getName()) + "/x#y#z", false, null)) |
| // .andReturn(modBytes.toByteArray()); |
| // EasyMock.replay(zk); |
| // |
| // dsnCallbacks.clear(); |
| // assertEquals("Precondition failed", 0, dsnCallbacks.size()); |
| // dml.change(); |
| // assertEquals(1, dsnCallbacks.size()); |
| // DiscoveredServiceNotification dsn2 = dsnCallbacks.iterator().next(); |
| // assertEquals(Collections.singleton(String.class.getName()), dsn2.getInterfaces()); |
| // assertEquals(DiscoveredServiceNotification.MODIFIED, dsn2.getType()); |
| // assertEquals(0, dsn2.getFilters().size()); |
| // ServiceEndpointDescription sed2 = dsn2.getServiceEndpointDescription(); |
| // assertEquals(Collections.singleton(String.class.getName()), sed2.getProvidedInterfaces()); |
| // assertEquals(modified, sed2.getProperties()); |
| // |
| // EasyMock.verify(zk); |
| // |
| // //---------------------------------------------------------------- |
| // // Test DiscoveredServiceNotification.MODIFIED2 |
| // //---------------------------------------------------------------- |
| // Properties modified2 = new Properties(); |
| // modified2.put("c", "d2"); |
| // modified2.put(ServicePublication.ENDPOINT_LOCATION, "http://somehost:112/some/context"); |
| // modified2.put("service.exported.configs", "org.apache.cxf.ws"); |
| // modified2.put("org.apache.cxf.ws.address", "http://somewhereelse/123"); |
| // ByteArrayOutputStream modBytes2 = new ByteArrayOutputStream(); |
| // modified2.store(modBytes2, ""); |
| // |
| // EasyMock.reset(zk); |
| // EasyMock.expect(zk.getChildren(Utils.getZooKeeperPath(String.class.getName()), false)) |
| // .andReturn(Arrays.asList("x#y#z")); |
| // EasyMock.expect(zk.getData(Utils.getZooKeeperPath(String.class.getName()) + "/x#y#z", false, null)) |
| // .andReturn(modBytes2.toByteArray()); |
| // EasyMock.replay(zk); |
| // |
| // dsnCallbacks.clear(); |
| // assertEquals("Precondition failed", 0, dsnCallbacks.size()); |
| // dml.change(); |
| // assertEquals(1, dsnCallbacks.size()); |
| // DiscoveredServiceNotification dsn3 = dsnCallbacks.iterator().next(); |
| // assertEquals(Collections.singleton(String.class.getName()), dsn3.getInterfaces()); |
| // assertEquals(DiscoveredServiceNotification.MODIFIED, dsn3.getType()); |
| // assertEquals(0, dsn3.getFilters().size()); |
| // ServiceEndpointDescription sed3 = dsn3.getServiceEndpointDescription(); |
| // assertEquals(Collections.singleton(String.class.getName()), sed3.getProvidedInterfaces()); |
| // assertEquals(modified2, sed3.getProperties()); |
| // |
| // EasyMock.verify(zk); |
| // //---------------------------------------------------------------- |
| // // Test DiscoveredServiceNotification.UNAVAILABLE |
| // //---------------------------------------------------------------- |
| // EasyMock.reset(zk); |
| // EasyMock.expect(zk.getChildren(Utils.getZooKeeperPath(String.class.getName()), false)) |
| // .andReturn(Collections.<String>emptyList()); |
| // EasyMock.replay(zk); |
| // |
| // dsnCallbacks.clear(); |
| // assertEquals("Precondition failed", 0, dsnCallbacks.size()); |
| // dml.change(); |
| // assertEquals(1, dsnCallbacks.size()); |
| // DiscoveredServiceNotification dsn4 = dsnCallbacks.iterator().next(); |
| // assertEquals(Collections.singleton(String.class.getName()), dsn4.getInterfaces()); |
| // assertEquals(DiscoveredServiceNotification.UNAVAILABLE, dsn4.getType()); |
| // assertEquals(0, dsn4.getFilters().size()); |
| // ServiceEndpointDescription sed4 = dsn4.getServiceEndpointDescription(); |
| // assertEquals(Collections.singleton(String.class.getName()), sed4.getProvidedInterfaces()); |
| // assertEquals(modified2, sed4.getProperties()); |
| // |
| // EasyMock.verify(zk); |
| // |
| // // Try the same again... |
| // EasyMock.reset(zk); |
| // EasyMock.expect(zk.getChildren(Utils.getZooKeeperPath(String.class.getName()), false)) |
| // .andReturn(Collections.<String>emptyList()); |
| // EasyMock.replay(zk); |
| // |
| // dsnCallbacks.clear(); |
| // assertEquals("Precondition failed", 0, dsnCallbacks.size()); |
| // dml.change(); |
| // assertEquals("Should not receive a callback again...", 0, dsnCallbacks.size()); |
| // EasyMock.verify(zk); |
| // } |
| } |
