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

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