diff options
Diffstat (limited to 'policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus')
6 files changed, 113 insertions, 0 deletions
diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/DmaapTopicPropertyBuilder.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/DmaapTopicPropertyBuilder.java index dff3f788..2e9a6cd7 100644 --- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/DmaapTopicPropertyBuilder.java +++ b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/DmaapTopicPropertyBuilder.java @@ -61,6 +61,10 @@ import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperti import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_SOURCE_FETCH_LIMIT_SUFFIX; import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_SOURCE_FETCH_TIMEOUT_SUFFIX; +import java.util.Arrays; +import lombok.Getter; +import org.onap.policy.common.endpoints.parameters.TopicParameters; + public class DmaapTopicPropertyBuilder extends TopicPropertyBuilder { public static final String SERVER = "my-server"; @@ -75,6 +79,9 @@ public class DmaapTopicPropertyBuilder extends TopicPropertyBuilder { public static final String MY_AAF_MECHID = "my-aaf-mechid"; public static final String MY_AAF_PASS = "my-aaf-passwd"; + @Getter + private TopicParameters params = new TopicParameters(); + /** * Constructs the object. * @@ -120,6 +127,28 @@ public class DmaapTopicPropertyBuilder extends TopicPropertyBuilder { setTopicProperty(PROPERTY_DMAAP_DME2_SUB_CONTEXT_PATH_SUFFIX, MY_SUBCONTEXT); setTopicProperty(PROPERTY_DMAAP_DME2_VERSION_SUFFIX, MY_DME_VERSION); + params.setTopicCommInfrastructure("dmaap"); + params.setTopic(topic); + params.setEffectiveTopic(MY_EFFECTIVE_TOPIC); + params.setConsumerGroup(MY_CONS_GROUP); + params.setConsumerInstance(MY_CONS_INST); + params.setManaged(true); + params.setUseHttps(true); + params.setUserName(MY_AAF_MECHID); + params.setPassword(MY_AAF_PASS); + params.setAftEnvironment(MY_AFT_ENV); + params.setAllowSelfSignedCerts(true); + params.setApiKey(MY_API_KEY); + params.setApiSecret(MY_API_SECRET); + params.setFetchLimit(MY_FETCH_LIMIT); + params.setFetchTimeout(MY_FETCH_TIMEOUT); + params.setEnvironment(MY_ENV); + params.setLatitude(MY_LAT); + params.setLongitude(MY_LONG); + params.setPartitionId(MY_PARTITION); + params.setPartner(MY_PARTNER); + params.setServers(Arrays.asList(SERVER)); + return this; } } diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicFactoryTest.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicFactoryTest.java index 1f7506f8..5cb9bcbd 100644 --- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicFactoryTest.java +++ b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicFactoryTest.java @@ -39,6 +39,7 @@ import org.junit.After; import org.junit.Before; import org.junit.Test; import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure; +import org.onap.policy.common.endpoints.event.comm.bus.internal.BusTopicParams; public abstract class NoopTopicFactoryTest<F extends NoopTopicFactory<T>, T extends NoopTopicEndpoint> extends TopicFactoryTestBase<T> { @@ -64,6 +65,17 @@ public abstract class NoopTopicFactoryTest<F extends NoopTopicFactory<T>, T exte } @Test + public void testBuildBusTopicParams() { + initFactory(); + + T item1 = buildTopic(makeParams(servers, MY_TOPIC, true)); + assertNotNull(item1); + + assertEquals(servers, item1.getServers()); + assertEquals(MY_TOPIC, item1.getTopic()); + } + + @Test public void testBuildListOfStringStringBoolean() { initFactory(); @@ -196,6 +208,10 @@ public abstract class NoopTopicFactoryTest<F extends NoopTopicFactory<T>, T exte return factory.build(properties); } + protected T buildTopic(BusTopicParams param) { + return factory.build(param); + } + protected T buildTopic(List<String> servers, String topic, boolean managed) { return factory.build(servers, topic, managed); } @@ -224,4 +240,14 @@ public abstract class NoopTopicFactoryTest<F extends NoopTopicFactory<T>, T exte protected TopicPropertyBuilder makePropBuilder() { return new NoopTopicPropertyBuilder(factory.getTopicsPropertyName()); } + + private BusTopicParams makeParams(List<String> servers, String topic, boolean managed) { + BusTopicParams params = new BusTopicParams(); + + params.setServers(servers); + params.setTopic(topic); + params.setManaged(managed); + + return params; + } } diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicPropertyBuilder.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicPropertyBuilder.java index 529f8b2f..3f0553f8 100644 --- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicPropertyBuilder.java +++ b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicPropertyBuilder.java @@ -27,11 +27,18 @@ import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperti import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_EFFECTIVE_TOPIC_SUFFIX; import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_SERVERS_SUFFIX; +import java.util.Arrays; +import lombok.Getter; +import org.onap.policy.common.endpoints.parameters.TopicParameters; + public class NoopTopicPropertyBuilder extends TopicPropertyBuilder { public static final String SERVER = "my-server"; public static final String TOPIC2 = "my-topic-2"; + @Getter + private TopicParameters params = new TopicParameters(); + /** * Constructs the object. * @@ -56,6 +63,14 @@ public class NoopTopicPropertyBuilder extends TopicPropertyBuilder { setTopicProperty(PROPERTY_ALLOW_SELF_SIGNED_CERTIFICATES_SUFFIX, "true"); setTopicProperty(PROPERTY_TOPIC_SERVERS_SUFFIX, SERVER); + params.setTopicCommInfrastructure("noop"); + params.setTopic(topic); + params.setEffectiveTopic(MY_EFFECTIVE_TOPIC); + params.setManaged(true); + params.setUseHttps(true); + params.setAllowSelfSignedCerts(true); + params.setServers(Arrays.asList(SERVER)); + return this; } } diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactoryTest.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactoryTest.java index cc44716f..b4ab54fa 100644 --- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactoryTest.java +++ b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSinkFactoryTest.java @@ -20,10 +20,19 @@ package org.onap.policy.common.endpoints.event.comm.bus; +import static org.junit.Assert.assertTrue; + +import org.junit.Test; + public class NoopTopicSinkFactoryTest extends NoopTopicFactoryTest<NoopTopicSinkFactory, NoopTopicSink> { @Override protected NoopTopicSinkFactory buildFactory() { return new NoopTopicSinkFactory(); } + + @Test + public void testToString() { + assertTrue(new NoopTopicSinkFactory().toString().startsWith("NoopTopicSinkFactory [")); + } } diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSourceFactoryTest.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSourceFactoryTest.java index c8a44292..e16174fd 100644 --- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSourceFactoryTest.java +++ b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/NoopTopicSourceFactoryTest.java @@ -20,10 +20,19 @@ package org.onap.policy.common.endpoints.event.comm.bus; +import static org.junit.Assert.assertTrue; + +import org.junit.Test; + public class NoopTopicSourceFactoryTest extends NoopTopicFactoryTest<NoopTopicSourceFactory, NoopTopicSource> { @Override protected NoopTopicSourceFactory buildFactory() { return new NoopTopicSourceFactory(); } + + @Test + public void testToString() { + assertTrue(new NoopTopicSourceFactory().toString().startsWith("NoopTopicSourceFactory [")); + } } diff --git a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/UebTopicPropertyBuilder.java b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/UebTopicPropertyBuilder.java index 6119284f..cb5507e5 100644 --- a/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/UebTopicPropertyBuilder.java +++ b/policy-endpoints/src/test/java/org/onap/policy/common/endpoints/event/comm/bus/UebTopicPropertyBuilder.java @@ -45,6 +45,10 @@ import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperti import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_SOURCE_FETCH_LIMIT_SUFFIX; import static org.onap.policy.common.endpoints.properties.PolicyEndPointProperties.PROPERTY_TOPIC_SOURCE_FETCH_TIMEOUT_SUFFIX; +import java.util.Arrays; +import lombok.Getter; +import org.onap.policy.common.endpoints.parameters.TopicParameters; + public class UebTopicPropertyBuilder extends TopicPropertyBuilder { public static final String SERVER = "my-server"; @@ -53,6 +57,9 @@ public class UebTopicPropertyBuilder extends TopicPropertyBuilder { public static final String MY_AAF_MECHID = "my-aaf-mechid"; public static final String MY_AAF_PASS = "my-aaf-passwd"; + @Getter + private TopicParameters params = new TopicParameters(); + /** * Constructs the object. * @@ -87,6 +94,24 @@ public class UebTopicPropertyBuilder extends TopicPropertyBuilder { setTopicProperty(PROPERTY_TOPIC_SINK_PARTITION_KEY_SUFFIX, MY_PARTITION); setTopicProperty(PROPERTY_TOPIC_SERVERS_SUFFIX, SERVER); + params.setTopicCommInfrastructure("ueb"); + params.setTopic(topic); + params.setEffectiveTopic(MY_EFFECTIVE_TOPIC); + params.setConsumerGroup(MY_CONS_GROUP); + params.setConsumerInstance(MY_CONS_INST); + params.setManaged(true); + params.setUseHttps(true); + params.setUserName(MY_AAF_MECHID); + params.setPassword(MY_AAF_PASS); + params.setAftEnvironment(MY_AFT_ENV); + params.setAllowSelfSignedCerts(true); + params.setApiKey(MY_API_KEY); + params.setApiSecret(MY_API_SECRET); + params.setFetchLimit(MY_FETCH_LIMIT); + params.setFetchTimeout(MY_FETCH_TIMEOUT); + params.setPartitionId(MY_PARTITION); + params.setServers(Arrays.asList(SERVER)); + return this; } } |