diff options
Diffstat (limited to 'controlloop/common/eventmanager/src/test/java/org/onap/policy/drools/DroolsPolicyEngineTest.java')
-rw-r--r-- | controlloop/common/eventmanager/src/test/java/org/onap/policy/drools/DroolsPolicyEngineTest.java | 79 |
1 files changed, 0 insertions, 79 deletions
diff --git a/controlloop/common/eventmanager/src/test/java/org/onap/policy/drools/DroolsPolicyEngineTest.java b/controlloop/common/eventmanager/src/test/java/org/onap/policy/drools/DroolsPolicyEngineTest.java deleted file mode 100644 index 3b61faaf2..000000000 --- a/controlloop/common/eventmanager/src/test/java/org/onap/policy/drools/DroolsPolicyEngineTest.java +++ /dev/null @@ -1,79 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * eventmanager - * ================================================================================ - * Copyright (C) 2018 Ericsson. All rights reserved. - * Modifications Copyright (C) 2019 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.drools; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNotNull; - -import org.junit.Test; -import org.onap.policy.appc.CommonHeader; -import org.onap.policy.appc.Request; -import org.onap.policy.appclcm.AppcLcmBody; -import org.onap.policy.appclcm.AppcLcmCommonHeader; -import org.onap.policy.appclcm.AppcLcmDmaapWrapper; -import org.onap.policy.appclcm.AppcLcmInput; -import org.onap.policy.controlloop.ControlLoopNotification; -import org.onap.policy.controlloop.VirtualControlLoopNotification; -import org.onap.policy.drools.impl.PolicyEngineJUnitImpl; - -public class DroolsPolicyEngineTest { - private static final String TOPIC = "TheWizardOfOz"; - private static final String OMNI_BUS = "OmniBus"; - - @Test - public void testDroolsPolicyEngine() { - PolicyEngineJUnitImpl pe = new PolicyEngineJUnitImpl(); - assertNotNull(pe); - - pe.addListener(new TestPolicyEngineListener()); - pe.notifyListeners(TOPIC); - - pe.subscribe(OMNI_BUS, TOPIC); - - pe.deliver(OMNI_BUS, TOPIC, "Dorothy"); - - pe.subscribe(OMNI_BUS, TOPIC); - pe.subscribe(OMNI_BUS, "ThisTopicDoesNotExist"); - - ControlLoopNotification notification = new VirtualControlLoopNotification(); - pe.deliver(OMNI_BUS, TOPIC, notification); - - Request request = new Request(); - request.setCommonHeader(new CommonHeader()); - request.getCommonHeader().setSubRequestId("12321"); - pe.deliver(OMNI_BUS, TOPIC, request); - - AppcLcmDmaapWrapper lcmRw = new AppcLcmDmaapWrapper(); - lcmRw.setBody(new AppcLcmBody()); - lcmRw.getBody().setInput(new AppcLcmInput()); - lcmRw.getBody().getInput().setCommonHeader(new AppcLcmCommonHeader()); - lcmRw.getBody().getInput().getCommonHeader().setSubRequestId("54321"); - pe.deliver(OMNI_BUS, TOPIC, lcmRw); - } - - private class TestPolicyEngineListener implements PolicyEngineListener { - @Override - public void newEventNotification(String topic) { - assertEquals(TOPIC, topic); - } - } -} |