From 9f43c23e7fbb4531fd045d081ddb59b5a547833c Mon Sep 17 00:00:00 2001 From: Daniel Silverthorn Date: Wed, 6 Jun 2018 16:46:28 -0400 Subject: Assume the username will not be obfuscated Change-Id: Ib6ce138340e520c02cb1e2e9922accfb6b4d5e8b Issue-ID: AAI-1182 Signed-off-by: Daniel Silverthorn --- src/main/java/org/onap/aai/event/DMaaPEventBusEndpoint.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/onap/aai/event/DMaaPEventBusEndpoint.java b/src/main/java/org/onap/aai/event/DMaaPEventBusEndpoint.java index 36e930a..3cc37e8 100644 --- a/src/main/java/org/onap/aai/event/DMaaPEventBusEndpoint.java +++ b/src/main/java/org/onap/aai/event/DMaaPEventBusEndpoint.java @@ -65,7 +65,7 @@ public class DMaaPEventBusEndpoint extends AbstractEventBusEndpoint { private int pollingDelay = 30000; @UriParam(label = "transportType") @Metadata(required = "true", defaultValue="HTTPAUTH") - private String transportType; + private String transportType = "HTTPAUTH"; private DMaaPEventConsumer dmaapConsumer; @@ -91,7 +91,7 @@ public class DMaaPEventBusEndpoint extends AbstractEventBusEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { // TODO: other overloads based on filled-in properties - dmaapConsumer = new DMaaPEventConsumer(url, eventTopic, Password.deobfuscate(username), Password.deobfuscate(password), consumerGroup, consumerId, 15000, 1000, transportType); + dmaapConsumer = new DMaaPEventConsumer(url, eventTopic, username, Password.deobfuscate(password), consumerGroup, consumerId, 15000, 1000, transportType); return new EventBusConsumer(this, processor, dmaapConsumer); } @Override -- cgit 1.2.3-korg