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
10 * http://www.apache.org/licenses/LICENSE-2.0
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.
18 * SPDX-License-Identifier: Apache-2.0
19 * ============LICENSE_END=========================================================
22 package org.onap.policy.distribution.reception.handling.sdc;
24 import static org.junit.Assert.assertEquals;
26 import org.junit.Test;
27 import org.onap.sdc.utils.DistributionStatusEnum;
29 public class TestComponentDoneStatusMessage {
31 private static final String CONSUMER_ID = "dummyId";
32 private static final String DISTRIBUTION_ID = "dummyDistribution";
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());
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());