610070e3df5b4a78f20dfa53f82bf58c12a10b76
[policy/common.git] /
1 /*
2  * ============LICENSE_START=======================================================
3  * policy-endpoints
4  * ================================================================================
5  * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20
21 package org.onap.policy.common.endpoints.event.comm.bus.internal;
22
23 import static org.junit.Assert.assertEquals;
24 import static org.junit.Assert.assertTrue;
25
26 import org.junit.After;
27 import org.junit.Before;
28 import org.junit.Test;
29 import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure;
30 import org.onap.policy.common.endpoints.event.comm.bus.TopicTestBase;
31
32 public class InlineUebTopicSinkTest extends TopicTestBase {
33     private InlineUebTopicSink sink;
34
35     /**
36      * Creates the object to be tested.
37      */
38     @Before
39     public void setUp() {
40         super.setUp();
41
42         sink = new InlineUebTopicSink(makeBuilder().build());
43     }
44
45     @After
46     public void tearDown() {
47         sink.shutdown();
48     }
49
50     @Test
51     public void testToString() {
52         assertTrue(sink.toString().startsWith("InlineUebTopicSink ["));
53     }
54
55     @Test
56     public void testInit() {
57         sink.init();
58     }
59
60     @Test
61     public void testGetTopicCommInfrastructure() {
62         assertEquals(CommInfrastructure.UEB, sink.getTopicCommInfrastructure());
63     }
64
65 }