summaryrefslogtreecommitdiffstats
path: root/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java
diff options
context:
space:
mode:
authorLusheng Ji <lji@research.att.com>2018-05-17 09:00:02 +0000
committerGerrit Code Review <gerrit@onap.org>2018-05-17 09:00:02 +0000
commit87387a5954a3c6767e51fa5b28eb1af0109e4c85 (patch)
tree1039ef88f55ae6024dbaae0e87178c77297d491b /prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java
parent7412a22e82ed782c2a783483b80186c2f2fa3065 (diff)
parent96481e0db6db2593299c1e3e630dd8e14b5bab53 (diff)
Merge "Added test for AAIProducerTask"
Diffstat (limited to 'prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java')
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java
index 69911f33..e9f8ec42 100644
--- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java
@@ -51,13 +51,13 @@ public class DmaapConsumerTaskImpl extends DmaapConsumerTask<DmaapConsumerConfig
@Override
protected ConsumerDmaapModel consume(String message) throws DmaapNotFoundException {
- logger.trace("Method %M called with arg {}", message);
+ logger.trace("Method called with arg {}", message);
return DmaapConsumerJsonParser.getJsonObject(message);
}
@Override
public Object execute(Object object) throws PrhTaskException {
- logger.trace("Method %M called with arg {}", object);
+ logger.trace("Method called with arg {}", object);
ExtendedDmaapConsumerHttpClientImpl dmaapConsumerHttpClient = new ExtendedDmaapConsumerHttpClientImpl(
resolveConfiguration());
return consume((dmaapConsumerHttpClient.getHttpConsumerResponse().orElseThrow(() ->