c59358220cc1e64bff1065965851c10181d7fa95
[policy/distribution.git] /
1 /*-
2  * ============LICENSE_START=======================================================
3  *  Copyright (C) 2018 Intel. All rights reserved.
4  *  Modifications Copyright (C) 2021 Bell Canada. All rights reserved.
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.distribution.reception.handling.sdc;
23
24 import static org.junit.Assert.assertEquals;
25
26 import org.junit.Test;
27 import org.onap.sdc.utils.DistributionStatusEnum;
28
29 public class TestComponentDoneStatusMessage {
30
31     private static final String CONSUMER_ID = "dummyId";
32     private static final String DISTRIBUTION_ID = "dummyDistribution";
33
34     @Test
35     public void testComponentDoneStatusMessage_Success() {
36         final long timestamp = System.currentTimeMillis();
37         final ComponentDoneStatusMessage message = ComponentDoneStatusMessage.builder().consumerId(CONSUMER_ID)
38                         .distributionId(DISTRIBUTION_ID).distributionStatus(DistributionStatusEnum.COMPONENT_DONE_OK)
39                         .timestamp(timestamp).build();
40         assertEquals("POLICY", message.getComponentName());
41         assertEquals(CONSUMER_ID, message.getConsumerID());
42         assertEquals(DISTRIBUTION_ID, message.getDistributionID());
43         assertEquals(DistributionStatusEnum.COMPONENT_DONE_OK, message.getStatus());
44         assertEquals(timestamp, message.getTimestamp());
45     }
46
47     @Test
48     public void testComponentDoneStatusMessage_Failure() {
49         final long timestamp = System.currentTimeMillis();
50         final ComponentDoneStatusMessage message = ComponentDoneStatusMessage.builder().consumerId(CONSUMER_ID)
51                         .distributionId(DISTRIBUTION_ID).distributionStatus(DistributionStatusEnum.COMPONENT_DONE_ERROR)
52                         .timestamp(timestamp).build();
53         assertEquals("POLICY", message.getComponentName());
54         assertEquals(CONSUMER_ID, message.getConsumerID());
55         assertEquals(DISTRIBUTION_ID, message.getDistributionID());
56         assertEquals(DistributionStatusEnum.COMPONENT_DONE_ERROR, message.getStatus());
57         assertEquals(timestamp, message.getTimestamp());
58     }
59 }