Removing deprecated DMAAP library
[policy/drools-pdp.git] / feature-pooling-messages / src / test / java / org / onap / policy / drools / pooling / message / MessageTest.java
1 /*
2  * ============LICENSE_START=======================================================
3  * ONAP
4  * ================================================================================
5  * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
6  * Modifications Copyright (C) 2024 Nordix Foundation.
7  * ================================================================================
8  * Licensed under the Apache License, Version 2.0 (the "License");
9  * you may not use this file except in compliance with the License.
10  * You may obtain a copy of the License at
11  * 
12  *      http://www.apache.org/licenses/LICENSE-2.0
13  * 
14  * Unless required by applicable law or agreed to in writing, software
15  * distributed under the License is distributed on an "AS IS" BASIS,
16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17  * See the License for the specific language governing permissions and
18  * limitations under the License.
19  * ============LICENSE_END=========================================================
20  */
21
22 package org.onap.policy.drools.pooling.message;
23
24 import static org.junit.jupiter.api.Assertions.assertEquals;
25 import static org.junit.jupiter.api.Assertions.assertNull;
26
27 import org.junit.jupiter.api.Test;
28
29 class MessageTest extends SupportBasicMessageTester<Message> {
30
31     public MessageTest() {
32         super(Message.class);
33     }
34
35     @Test
36     void testGetSource_testSetSource() {
37         Message msg = new Message();
38
39         msg.setSource("hello");
40         assertEquals("hello", msg.getSource());
41         assertNull(msg.getChannel());
42
43         msg.setSource("world");
44         assertEquals("world", msg.getSource());
45         assertNull(msg.getChannel());
46     }
47
48     @Test
49     void testGetChannel_testSetChannel() {
50         Message msg = new Message();
51
52         msg.setChannel("hello");
53         assertEquals("hello", msg.getChannel());
54         assertNull(msg.getSource());
55
56         msg.setChannel("world");
57         assertEquals("world", msg.getChannel());
58         assertNull(msg.getSource());
59     }
60
61     @Test
62     void testCheckValidity_InvalidFields() {
63         // null or empty source
64         expectCheckValidityFailure_NullOrEmpty((msg, value) -> msg.setSource(value));
65
66         // null or empty channel
67         expectCheckValidityFailure_NullOrEmpty((msg, value) -> msg.setChannel(value));
68     }
69
70     /**
71      * Makes a message that will pass the validity check.
72      * 
73      * @return a valid Message
74      */
75     public Message makeValidMessage() {
76         Message msg = new Message(VALID_HOST);
77         msg.setChannel(VALID_CHANNEL);
78
79         return msg;
80     }
81
82 }