summaryrefslogtreecommitdiffstats
path: root/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po
diff options
context:
space:
mode:
Diffstat (limited to 'v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po')
-rw-r--r--v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/HoneycombNotificationCollectorTest.java63
-rw-r--r--v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/NotificationProducerRegistryTest.java98
-rw-r--r--v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/NotificationProducerTrackerTest.java67
3 files changed, 0 insertions, 228 deletions
diff --git a/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/HoneycombNotificationCollectorTest.java b/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/HoneycombNotificationCollectorTest.java
deleted file mode 100644
index f55d3abdf..000000000
--- a/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/HoneycombNotificationCollectorTest.java
+++ /dev/null
@@ -1,63 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * Licensed 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 io.fd.honeycomb.v3po.notification.impl;
-
-import static org.mockito.Mockito.atLeast;
-import static org.mockito.Mockito.verify;
-
-import com.google.common.collect.Lists;
-import io.fd.honeycomb.v3po.notification.ManagedNotificationProducer;
-import org.junit.Before;
-import org.junit.Test;
-import org.mockito.Mock;
-import org.mockito.MockitoAnnotations;
-import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.notifications.rev120206.NetconfSessionStart;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.notifications.rev120206.NetconfSessionStartBuilder;
-
-public class HoneycombNotificationCollectorTest {
-
- private NotificationProducerRegistry notificationRegistry;
- @Mock
- private NotificationPublishService notificationService;
- @Mock
- private ManagedNotificationProducer producer;
-
- @Before
- public void setUp() throws Exception {
- MockitoAnnotations.initMocks(this);
- notificationRegistry = new NotificationProducerRegistry(Lists.newArrayList(producer));
- }
-
- @Test
- public void testNotificationTypes() throws Exception {
- final HoneycombNotificationCollector honeycombNotificationCollector =
- new HoneycombNotificationCollector(notificationService, notificationRegistry);
-
- honeycombNotificationCollector.getNotificationTypes();
- verify(producer, atLeast(1)).getNotificationTypes();
- }
-
- @Test
- public void testCollect() throws Exception {
- final HoneycombNotificationCollector honeycombNotificationCollector =
- new HoneycombNotificationCollector(notificationService, notificationRegistry);
-
- final NetconfSessionStart notif = new NetconfSessionStartBuilder().build();
- honeycombNotificationCollector.onNotification(notif);
- verify(notificationService).putNotification(notif);
- }
-} \ No newline at end of file
diff --git a/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/NotificationProducerRegistryTest.java b/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/NotificationProducerRegistryTest.java
deleted file mode 100644
index 5fdf502b9..000000000
--- a/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/NotificationProducerRegistryTest.java
+++ /dev/null
@@ -1,98 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * Licensed 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 io.fd.honeycomb.v3po.notification.impl;
-
-import static org.hamcrest.CoreMatchers.hasItem;
-import static org.hamcrest.CoreMatchers.is;
-import static org.mockito.Mockito.doReturn;
-
-import com.google.common.collect.Lists;
-import com.google.common.collect.Multimap;
-import io.fd.honeycomb.v3po.notification.ManagedNotificationProducer;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.Map;
-import java.util.Set;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
-import org.mockito.Mock;
-import org.mockito.MockitoAnnotations;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.notifications.rev120206.NetconfCapabilityChange;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.notifications.rev120206.NetconfSessionEnd;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.notifications.rev120206.NetconfSessionStart;
-import org.opendaylight.yangtools.yang.binding.Notification;
-import org.opendaylight.yangtools.yang.common.QName;
-
-public class NotificationProducerRegistryTest {
-
- @Mock
- private ManagedNotificationProducer producer;
- @Mock
- private ManagedNotificationProducer producer2;
-
- @Before
- public void setUp() throws Exception {
- MockitoAnnotations.initMocks(this);
- doReturn(Collections.singleton(NetconfCapabilityChange.class))
- .when(producer).getNotificationTypes();
- final ArrayList<Object> producer2Notifications = Lists.newArrayList();
- producer2Notifications.add(NetconfSessionStart.class);
- producer2Notifications.add(NetconfSessionEnd.class);
- doReturn(producer2Notifications).when(producer2).getNotificationTypes();
- }
-
- @Test
- public void testNotificationTypes() throws Exception {
- final NotificationProducerRegistry notificationRegistry =
- new NotificationProducerRegistry(Lists.newArrayList(producer, producer2));
-
- final Set<Class<? extends Notification>> notificationTypes =
- notificationRegistry.getNotificationTypes();
-
- Assert.assertThat(notificationTypes, hasItem(NetconfSessionEnd.class));
- Assert.assertThat(notificationTypes, hasItem(NetconfSessionStart.class));
- Assert.assertThat(notificationTypes, hasItem(NetconfCapabilityChange.class));
- }
-
- @Test
- public void testNotificationTypesMapped() throws Exception {
- final NotificationProducerRegistry notificationRegistry =
- new NotificationProducerRegistry(Lists.newArrayList(producer, producer2));
-
- final Multimap<ManagedNotificationProducer, QName> notificationTypes =
- notificationRegistry.getNotificationProducerQNames();
-
- Assert.assertThat(notificationTypes.keySet(), hasItem(producer));
- Assert.assertThat(notificationTypes.get(producer), hasItem(NetconfCapabilityChange.QNAME));
- Assert.assertThat(notificationTypes.keySet(), hasItem(producer2));
- Assert.assertThat(notificationTypes.get(producer2), hasItem(NetconfSessionStart.QNAME));
- Assert.assertThat(notificationTypes.get(producer2), hasItem(NetconfSessionEnd.QNAME));
-
- final Map<QName, ManagedNotificationProducer> notificationQNameToProducer =
- notificationRegistry.getNotificationQNameToProducer();
-
- Assert.assertThat(notificationQNameToProducer.keySet(), hasItem(NetconfCapabilityChange.QNAME));
- Assert.assertThat(notificationQNameToProducer.get(NetconfCapabilityChange.QNAME), is(producer));
-
- Assert.assertThat(notificationQNameToProducer.keySet(), hasItem(NetconfSessionStart.QNAME));
- Assert.assertThat(notificationQNameToProducer.keySet(), hasItem(NetconfSessionEnd.QNAME));
- Assert.assertThat(notificationQNameToProducer.get(NetconfSessionStart.QNAME), is(producer2));
- Assert.assertThat(notificationQNameToProducer.get(NetconfSessionEnd.QNAME), is(producer2));
-
-
- }
-} \ No newline at end of file
diff --git a/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/NotificationProducerTrackerTest.java b/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/NotificationProducerTrackerTest.java
deleted file mode 100644
index b62bf0709..000000000
--- a/v3po/notification/impl/src/test/java/io/fd/honeycomb/v3po/notification/impl/NotificationProducerTrackerTest.java
+++ /dev/null
@@ -1,67 +0,0 @@
-/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
- *
- * Licensed 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 io.fd.honeycomb.v3po.notification.impl;
-
-import static org.mockito.Mockito.doReturn;
-import static org.mockito.Mockito.verify;
-
-import com.google.common.collect.Lists;
-import com.google.common.collect.Sets;
-import io.fd.honeycomb.v3po.notification.ManagedNotificationProducer;
-import io.fd.honeycomb.v3po.notification.NotificationCollector;
-import java.util.Collections;
-import java.util.Set;
-import org.junit.Before;
-import org.junit.Test;
-import org.mockito.Mock;
-import org.mockito.MockitoAnnotations;
-import org.opendaylight.controller.md.sal.dom.spi.DOMNotificationSubscriptionListenerRegistry;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.notifications.rev120206.NetconfSessionStart;
-import org.opendaylight.yangtools.yang.model.api.SchemaPath;
-
-public class NotificationProducerTrackerTest {
-
- private NotificationProducerRegistry registry;
- @Mock
- private DOMNotificationSubscriptionListenerRegistry subscriptionRegistry;
- @Mock
- private NotificationCollector collector;
- @Mock
- private ManagedNotificationProducer producer;
-
- @Before
- public void setUp() throws Exception {
- MockitoAnnotations.initMocks(this);
- doReturn(Collections.singleton(NetconfSessionStart.class)).when(producer).getNotificationTypes();
- registry = new NotificationProducerRegistry(Lists.newArrayList(producer));
- }
-
- @Test
- public void name() throws Exception {
- final NotificationProducerTracker notificationProducerTracker =
- new NotificationProducerTracker(registry, collector, subscriptionRegistry);
- verify(subscriptionRegistry).registerSubscriptionListener(notificationProducerTracker);
-
- final Set<SchemaPath> subscriptions = Sets.newHashSet();
- subscriptions.add(SchemaPath.create(true, NetconfSessionStart.QNAME));
- notificationProducerTracker.onSubscriptionChanged(subscriptions);
-
- verify(producer).start(collector);
-
- notificationProducerTracker.onSubscriptionChanged(Sets.newHashSet());
- verify(producer).stop();
- }
-} \ No newline at end of file