aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDaniel Silverthorn <daniel.silverthorn@amdocs.com>2018-06-06 16:46:28 -0400
committerDaniel Silverthorn <daniel.silverthorn@amdocs.com>2018-06-06 16:46:58 -0400
commit9f43c23e7fbb4531fd045d081ddb59b5a547833c (patch)
tree2c59ccdbedd5cbc234f9ed9b6dbe5f9a5c9a2b70
parent1d3498968a4b1492f0d31fe9a4304b2f3407718e (diff)
Assume the username will not be obfuscated
Change-Id: Ib6ce138340e520c02cb1e2e9922accfb6b4d5e8b Issue-ID: AAI-1182 Signed-off-by: Daniel Silverthorn <daniel.silverthorn@amdocs.com>
-rw-r--r--src/main/java/org/onap/aai/event/DMaaPEventBusEndpoint.java4
1 files 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