2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2018-2019 AT&T Intellectual Property. 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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 package org.onap.policy.common.endpoints.event.comm.bus;
23 import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
24 import static org.junit.Assert.assertEquals;
25 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_EP_CONN_TIMEOUT_SUFFIX;
26 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_EP_READ_TIMEOUT_MS_SUFFIX;
27 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_ROUNDTRIP_TIMEOUT_MS_SUFFIX;
28 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_ROUTE_OFFER_SUFFIX;
29 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_SESSION_STICKINESS_REQUIRED_SUFFIX;
30 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_SUB_CONTEXT_PATH_SUFFIX;
31 import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_DMAAP_DME2_VERSION_SUFFIX;
34 import org.onap.policy.common.endpoints.event.comm.Topic;
35 import org.onap.policy.common.endpoints.event.comm.bus.internal.BusTopicParams;
38 * Base class for DmaapTopicXxxFactory tests.
40 * @param <T> type of topic managed by the factory
42 public abstract class DmaapTopicFactoryTestBase<T extends Topic> extends BusTopicFactoryTestBase<T> {
44 public static final String MY_CONN_TIMEOUT = "200";
45 public static final String MY_READ_TIMEOUT = "201";
46 public static final String MY_ROUNDTRIP_TIMEOUT = "202";
47 public static final String MY_STICKINESS = "true";
48 public static final String MY_SUBCONTEXT = "my-subcontext";
49 public static final String MY_DME_VERSION = "my-version";
52 public void testBuildProperties() {
54 super.testBuildProperties();
56 // check properties specific to DMaaP/DME2
59 assertEquals(1, buildTopics(makePropBuilder().makeTopic(MY_TOPIC).build()).size());
61 BusTopicParams params = getLastParams();
62 assertEquals(MY_ENV, params.getEnvironment());
63 assertEquals(MY_LAT, params.getLatitude());
64 assertEquals(MY_LONG, params.getLongitude());
65 assertEquals(MY_PARTNER, params.getPartner());
67 Map<String, String> add = params.getAdditionalProps();
68 assertEquals(MY_CONN_TIMEOUT, add.get(DmaapTopicSinkFactory.DME2_EP_CONN_TIMEOUT_PROPERTY));
69 assertEquals(MY_READ_TIMEOUT, add.get(DmaapTopicSinkFactory.DME2_READ_TIMEOUT_PROPERTY));
70 assertEquals(MY_ROUNDTRIP_TIMEOUT, add.get(DmaapTopicSinkFactory.DME2_ROUNDTRIP_TIMEOUT_PROPERTY));
71 assertEquals(MY_ROUTE, add.get(DmaapTopicSinkFactory.DME2_ROUTE_OFFER_PROPERTY));
72 assertEquals(MY_STICKINESS, add.get(DmaapTopicSinkFactory.DME2_SESSION_STICKINESS_REQUIRED_PROPERTY));
73 assertEquals(MY_SUBCONTEXT, add.get(DmaapTopicSinkFactory.DME2_SUBCONTEXT_PATH_PROPERTY));
74 assertEquals(MY_DME_VERSION, add.get(DmaapTopicSinkFactory.DME2_VERSION_PROPERTY));
78 public void testBuildProperties_Variations() {
79 super.testBuildProperties_Variations();
81 // check "additional" properties
82 expectNullAddProp(PROPERTY_DMAAP_DME2_EP_CONN_TIMEOUT_SUFFIX,
83 DmaapTopicSinkFactory.DME2_EP_CONN_TIMEOUT_PROPERTY);
85 expectNullAddProp(PROPERTY_DMAAP_DME2_EP_READ_TIMEOUT_MS_SUFFIX,
86 DmaapTopicSinkFactory.DME2_READ_TIMEOUT_PROPERTY);
88 expectNullAddProp(PROPERTY_DMAAP_DME2_ROUNDTRIP_TIMEOUT_MS_SUFFIX,
89 DmaapTopicSinkFactory.DME2_ROUNDTRIP_TIMEOUT_PROPERTY);
91 expectNullAddProp(PROPERTY_DMAAP_DME2_ROUTE_OFFER_SUFFIX, DmaapTopicSinkFactory.DME2_ROUTE_OFFER_PROPERTY);
93 expectNullAddProp(PROPERTY_DMAAP_DME2_SESSION_STICKINESS_REQUIRED_SUFFIX,
94 DmaapTopicSinkFactory.DME2_SESSION_STICKINESS_REQUIRED_PROPERTY);
96 expectNullAddProp(PROPERTY_DMAAP_DME2_SUB_CONTEXT_PATH_SUFFIX,
97 DmaapTopicSinkFactory.DME2_SUBCONTEXT_PATH_PROPERTY);
99 expectNullAddProp(PROPERTY_DMAAP_DME2_VERSION_SUFFIX, DmaapTopicSinkFactory.DME2_VERSION_PROPERTY);
103 public void testBuildListOfStringString() {
104 super.testBuildListOfStringString();
106 // check parameters that were used
107 BusTopicParams params = getLastParams();
108 assertEquals(false, params.isAllowSelfSignedCerts());
112 * Tests exception cases with get(topic). DMaaP topics are special in that they
113 * throw IllegalArgumentException, even for an unknown topic name; all of the
114 * other Topic Factory classes throw IllegalStateException, thus we override
115 * the default test method.
118 public void testGet_Ex() {
120 assertThatIllegalArgumentException().as("null topic").isThrownBy(() -> getTopic(null));
123 assertThatIllegalArgumentException().as("empty topic").isThrownBy(() -> getTopic(""));
127 buildTopics(makePropBuilder().makeTopic(MY_TOPIC).build());
129 assertThatIllegalArgumentException().as("unknown topic").isThrownBy(() -> getTopic(TOPIC2));