Add notifier for generating notifications

Also modified the Publisher class to make it generic so that it
could be used to publish PdpMessage AND PolicyNotification.

Issue-ID: POLICY-1841
Signed-off-by: Jim Hahn <jrh3@att.com>
Change-Id: I305de21a4ef84730f163af63446bafadab11a809

1 files changed, 3 insertions, 3 deletions

diff --git a/main/src/test/java/org/onap/policy/pap/main/comm/PublisherTest.java b/main/src/test/java/org/onap/policy/pap/main/comm/PublisherTest.java
index 4b9bef71..2c0479b1 100644
--- a/main/src/test/java/org/onap/policy/pap/main/comm/PublisherTest.java
+++ b/main/src/test/java/org/onap/policy/pap/main/comm/PublisherTest.java
@@ -75,7 +75,7 @@ public class PublisherTest extends Threaded {
      */
     private static final long MAX_WAIT_MS = 5000;
 
-    private Publisher pub;
+    private Publisher<PdpMessage> pub;
     private MyListener listener;
 
     /**
@@ -108,7 +108,7 @@ public class PublisherTest extends Threaded {
     public void setUp() throws Exception {
         super.setUp();
 
-        pub = new Publisher(PapConstants.TOPIC_POLICY_PDP_PAP);
+        pub = new Publisher<>(PapConstants.TOPIC_POLICY_PDP_PAP);
 
         listener = new MyListener();
         TopicEndpointManager.getManager().getNoopTopicSink(PapConstants.TOPIC_POLICY_PDP_PAP).register(listener);
@@ -146,7 +146,7 @@ public class PublisherTest extends Threaded {
 
     @Test
     public void testPublisher_Ex() throws Exception {
-        assertThatThrownBy(() -> new Publisher("unknwon-topic")).isInstanceOf(PolicyPapException.class);
+        assertThatThrownBy(() -> new Publisher<>("unknwon-topic")).isInstanceOf(PolicyPapException.class);
     }
 
     @Test