gerrit.onap Code Review - policy/clamp.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * Copyright (C) 2022-2024 Nordix Foundation.
   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  * ============LICENSE_END=========================================================
  17  */
  18
  19 package org.onap.policy.common.message.bus.event.kafka;
  20
  21 import static org.assertj.core.api.Assertions.assertThatCode;
  22 import static org.junit.jupiter.api.Assertions.assertEquals;
  23 import static org.junit.jupiter.api.Assertions.assertTrue;
  24
  25 import org.junit.jupiter.api.AfterEach;
  26 import org.junit.jupiter.api.BeforeEach;
  27 import org.junit.jupiter.api.Test;
  28 import org.onap.policy.common.message.bus.event.Topic.CommInfrastructure;
  29 import org.onap.policy.common.message.bus.event.base.TopicTestBase;
  30
  31 class InlineKafkaTopicSinkTest extends TopicTestBase {
  32     private InlineKafkaTopicSink sink;
  33
  34     /**
  35      * Creates the object to be tested.
  36      */
  37     @BeforeEach
  38     @Override
  39     public void setUp() {
  40         super.setUp();
  41
  42         sink = new InlineKafkaTopicSink(makeKafkaBuilder().build());
  43     }
  44
  45     @AfterEach
  46     public void tearDown() {
  47         sink.shutdown();
  48     }
  49
  50     @Test
  51     void testToString() {
  52         assertTrue(sink.toString().startsWith("InlineKafkaTopicSink ["));
  53     }
  54
  55     @Test
  56     void testInit() {
  57         // nothing null
  58         sink = new InlineKafkaTopicSink(makeKafkaBuilder().build());
  59         sink.init();
  60         assertThatCode(() -> sink.shutdown()).doesNotThrowAnyException();
  61     }
  62
  63     @Test
  64     void testGetTopicCommInfrastructure() {
  65         assertEquals(CommInfrastructure.KAFKA, sink.getTopicCommInfrastructure());
  66     }
  67
  68 }