diff options
Diffstat (limited to 'datafile-app-server/src/main')
| -rw-r--r-- | datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/DmaapConsumerJsonParser.java | 6 | ||||
| -rw-r--r-- | datafile-app-server/src/main/resources/datafile_endpoints.json | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/DmaapConsumerJsonParser.java b/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/DmaapConsumerJsonParser.java index 72e7d497..e4afd3ae 100644 --- a/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/DmaapConsumerJsonParser.java +++ b/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/service/DmaapConsumerJsonParser.java @@ -63,11 +63,11 @@ public class DmaapConsumerJsonParser { /** * Extract info from string and create @see {@link FileData}. * - * @param monoMessage - results from DMaaP + * @param rawMessage - results from DMaaP * @return reactive Mono with an array of FileData */ - public Mono<List<FileData>> getJsonObject(Mono<String> monoMessage) { - return monoMessage.flatMap(this::getJsonParserMessage).flatMap(this::createJsonConsumerModel); + public Mono<List<FileData>> getJsonObject(Mono<String> rawMessage) { + return rawMessage.flatMap(this::getJsonParserMessage).flatMap(this::createJsonConsumerModel); } private Mono<JsonElement> getJsonParserMessage(String message) { diff --git a/datafile-app-server/src/main/resources/datafile_endpoints.json b/datafile-app-server/src/main/resources/datafile_endpoints.json index f6b65fba..188129e8 100644 --- a/datafile-app-server/src/main/resources/datafile_endpoints.json +++ b/datafile-app-server/src/main/resources/datafile_endpoints.json @@ -19,7 +19,7 @@ "dmaapHostName": "localhost", "dmaapPortNumber": 3905, "dmaapProtocol": "http", - "dmaapTopicName": "/events/unauthenticated.VES_NOTIFICATION_OUTPUT", + "dmaapTopicName": "publish", "dmaapUserName": "admin", "dmaapUserPassword": "admin" } |