Support retry in DCAE-SDK DMaaP-Client
[dcaegen2/services/sdk.git] / rest-services / dmaap-client / src / test / java / org / onap / dcaegen2 / services / sdk / rest / services / dmaap / client / model / config / DmaapRetryConfigTest.java
1 /*
2  * ============LICENSE_START====================================
3  * DCAEGEN2-SERVICES-SDK
4  * =========================================================
5  * Copyright (C) 2021 Nokia. 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.dcaegen2.services.sdk.rest.services.dmaap.client.model.config;
22
23 import org.junit.jupiter.api.Test;
24
25 import static org.assertj.core.api.Assertions.assertThat;
26 import static org.junit.jupiter.api.Assertions.assertThrows;
27
28 class DmaapRetryConfigTest {
29     @Test
30     void shouldSuccessfullyCreateObject() {
31         DmaapRetryConfig retryConfig = ImmutableDmaapRetryConfig.builder()
32                 .retryIntervalInSeconds(1)
33                 .retryCount(0)
34                 .build();
35
36         assertThat(retryConfig.retryIntervalInSeconds()).isOne();
37         assertThat(retryConfig.retryCount()).isZero();
38     }
39
40     @Test
41     void shouldSuccessfullyCreateObjectForDefaults() {
42         DmaapRetryConfig retryConfig = ImmutableDmaapRetryConfig.builder().build();
43
44         assertThat(retryConfig.retryIntervalInSeconds()).isOne();
45         assertThat(retryConfig.retryCount()).isEqualTo(3);
46     }
47
48     @Test
49     void shouldThrowInvalidArgumentExceptionForInvalidRetryInterval() {
50         assertThrows(IllegalArgumentException.class, () -> withRetryInterval(0));
51         assertThrows(IllegalArgumentException.class, () -> withRetryInterval(-3));
52     }
53
54     @Test
55     void shouldThrowInvalidArgumentExceptionForInvalidRetryCount() {
56         assertThrows(IllegalArgumentException.class, () -> withRetryCount(-1));
57         assertThrows(IllegalArgumentException.class, () -> withRetryCount(-3));
58     }
59
60     private void withRetryInterval(int ri) {
61         ImmutableDmaapRetryConfig.builder()
62                 .retryIntervalInSeconds(ri)
63                 .build();
64     }
65
66     private void withRetryCount(int rc) {
67         ImmutableDmaapRetryConfig.builder()
68                 .retryCount(rc)
69                 .build();
70     }
71 }