gerrit.onap Code Review - policy/apex-pdp.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2019 Samsung. All rights reserved.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20 package org.onap.policy.apex.plugins.event.carrier.jms;
  21
  22 import static org.junit.Assert.assertNotNull;
  23 import static org.junit.Assert.assertNull;
  24
  25 import javax.jms.Session;
  26 import org.junit.Before;
  27 import org.junit.Test;
  28 import org.onap.policy.apex.service.engine.event.ApexEvent;
  29 import org.onap.policy.apex.service.engine.event.ApexEventException;
  30 import org.onap.policy.apex.service.engine.event.ApexEventProducer;
  31 import org.onap.policy.apex.service.engine.event.ApexEventReceiver;
  32 import org.onap.policy.apex.service.engine.event.ApexEventRuntimeException;
  33 import org.onap.policy.apex.service.engine.event.PeeredReference;
  34 import org.onap.policy.apex.service.engine.event.SynchronousEventCache;
  35 import org.onap.policy.apex.service.parameters.carriertechnology.CarrierTechnologyParameters;
  36 import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters;
  37 import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerPeeredMode;
  38
  39 public class ApexJmsProducerTest {
  40
  41     ApexJmsConsumer apexJmsConsumer = null;
  42     EventHandlerParameters producerParameters = null;
  43     ApexEventReceiver incomingEventReceiver = null;
  44     ApexEventProducer apexJmsProducer = null;
  45     Session jmsSession = null;
  46     JmsCarrierTechnologyParameters jmsCarrierTechnologyParameters = null;
  47     SynchronousEventCache synchronousEventCache = null;
  48     private static final long DEFAULT_SYNCHRONOUS_EVENT_TIMEOUT = 1000;
  49
  50     /**
  51      * Set up testing.
  52      *
  53      * @throws Exception on test set up errors.
  54      */
  55     @Before
  56     public void setUp() throws Exception {
  57         apexJmsConsumer = new ApexJmsConsumer();
  58         producerParameters = new EventHandlerParameters();
  59         apexJmsProducer = new ApexJmsProducer();
  60     }
  61
  62     @Test(expected = ApexEventException.class)
  63     public void testInitWithNonJmsCarrierTechnologyParameters() throws ApexEventException {
  64         producerParameters.setCarrierTechnologyParameters(new CarrierTechnologyParameters() {});
  65         apexJmsProducer.init("TestApexJmsProducer", producerParameters);
  66     }
  67
  68     @Test(expected = ApexEventException.class)
  69     public void testInitWithJmsCarrierTechnologyParameters() throws ApexEventException {
  70         jmsCarrierTechnologyParameters = new JmsCarrierTechnologyParameters();
  71         producerParameters.setCarrierTechnologyParameters(jmsCarrierTechnologyParameters);
  72         apexJmsProducer.init("TestApexJmsProducer", producerParameters);
  73     }
  74
  75     @Test
  76     public void testGetName() {
  77         assertNull(apexJmsProducer.getName());
  78     }
  79
  80     @Test
  81     public void testGetPeeredReference() {
  82         assertNull(apexJmsProducer.getPeeredReference(EventHandlerPeeredMode.REQUESTOR));
  83     }
  84
  85     @Test
  86     public void testSetPeeredReference() {
  87         PeeredReference peeredReference = new PeeredReference(EventHandlerPeeredMode.REQUESTOR,
  88                 apexJmsConsumer, apexJmsProducer);
  89         apexJmsProducer.setPeeredReference(EventHandlerPeeredMode.REQUESTOR, peeredReference);
  90         assertNotNull(apexJmsProducer.getPeeredReference(EventHandlerPeeredMode.REQUESTOR));
  91     }
  92
  93     @Test(expected = NullPointerException.class)
  94     public void testSendEvent() throws ApexEventException {
  95         producerParameters.setCarrierTechnologyParameters(new JmsCarrierTechnologyParameters() {});
  96         synchronousEventCache = new SynchronousEventCache(EventHandlerPeeredMode.SYNCHRONOUS,
  97                 apexJmsConsumer, apexJmsProducer, DEFAULT_SYNCHRONOUS_EVENT_TIMEOUT);
  98         apexJmsProducer.setPeeredReference(EventHandlerPeeredMode.SYNCHRONOUS,
  99                 synchronousEventCache);
 100         ApexEvent apexEvent = new ApexEvent("testEvent", "testVersion", "testNameSpace",
 101                 "testSource", "testTarget");
 102         apexJmsProducer.sendEvent(1000L, "TestApexJmsProducer", apexEvent);
 103     }
 104
 105     @Test(expected = ApexEventRuntimeException.class)
 106     public void testSendEventWithNonSerializableObject() throws ApexEventException {
 107         producerParameters.setCarrierTechnologyParameters(new JmsCarrierTechnologyParameters() {});
 108         synchronousEventCache = new SynchronousEventCache(EventHandlerPeeredMode.SYNCHRONOUS,
 109                 apexJmsConsumer, apexJmsProducer, DEFAULT_SYNCHRONOUS_EVENT_TIMEOUT);
 110         apexJmsProducer.setPeeredReference(EventHandlerPeeredMode.SYNCHRONOUS,
 111                 synchronousEventCache);
 112         apexJmsProducer.sendEvent(-1L, "TestApexJmsProducer", new ApexJmsProducerTest());
 113     }
 114
 115     @Test
 116     public void testStop() {
 117         apexJmsProducer.stop();
 118     }
 119 }