Drools support for kafka topics
[policy/drools-pdp.git] / feature-pooling-messages / src / test / java / org / onap / policy / drools / pooling / message / HeartbeatTest.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
26 public class HeartbeatTest extends SupportBasicMessageTester<Heartbeat> {
27     
28     /**
29      * Sequence number to validate time stamps within the heart beat.
30      */
31     private long sequence = 0;
32
33     public HeartbeatTest() {
34         super(Heartbeat.class);
35     }
36
37     @Override
38     public Heartbeat makeValidMessage() {
39         Heartbeat msg = new Heartbeat(VALID_HOST, ++sequence);
40         msg.setChannel(VALID_CHANNEL);
41
42         return msg;
43     }
44
45     @Override
46     public void testDefaultConstructorFields(Heartbeat msg) {
47         super.testDefaultConstructorFields(msg);
48         
49         assertEquals(sequence, msg.getTimestampMs());
50     }
51
52     @Override
53     public void testValidFields(Heartbeat msg) {
54         super.testValidFields(msg);
55         
56         assertEquals(sequence, msg.getTimestampMs());
57     }
58
59 }