diff options
author | Daniel Silverthorn <daniel.silverthorn@amdocs.com> | 2018-06-06 16:46:28 -0400 |
---|---|---|
committer | Daniel Silverthorn <daniel.silverthorn@amdocs.com> | 2018-06-06 16:46:58 -0400 |
commit | 9f43c23e7fbb4531fd045d081ddb59b5a547833c (patch) | |
tree | 2c59ccdbedd5cbc234f9ed9b6dbe5f9a5c9a2b70 /src/main | |
parent | 1d3498968a4b1492f0d31fe9a4304b2f3407718e (diff) |
Assume the username will not be obfuscated
Change-Id: Ib6ce138340e520c02cb1e2e9922accfb6b4d5e8b
Issue-ID: AAI-1182
Signed-off-by: Daniel Silverthorn <daniel.silverthorn@amdocs.com>
Diffstat (limited to 'src/main')
-rw-r--r-- | src/main/java/org/onap/aai/event/DMaaPEventBusEndpoint.java | 4 |
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 |