From e30c7d54b34daf855303f32035827ee19555b536 Mon Sep 17 00:00:00 2001 From: wasala Date: Tue, 5 Jun 2018 12:15:44 +0200 Subject: Correction for DmaapJsonParser *Added cases fo uTests *Changed schedule tasks to 5s *Changed batching message to 1 Change-Id: I8daa4f143699488c8a593634ad67452b4a194437 Issue-ID: DCAEGEN2-540 Signed-off-by: wasala --- .../onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) (limited to 'prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java') 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 a78d33b2..01b85a9d 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 @@ -44,16 +44,23 @@ public class DmaapConsumerTaskImpl extends private static final Logger logger = LoggerFactory.getLogger(DmaapConsumerTaskImpl.class); private final Config prhAppConfig; private ExtendedDmaapConsumerHttpClientImpl extendedDmaapConsumerHttpClient; + private DmaapConsumerJsonParser dmaapConsumerJsonParser; @Autowired public DmaapConsumerTaskImpl(AppConfig prhAppConfig) { this.prhAppConfig = prhAppConfig; + this.dmaapConsumerJsonParser = new DmaapConsumerJsonParser(); + } + + DmaapConsumerTaskImpl(AppConfig prhAppConfig, DmaapConsumerJsonParser dmaapConsumerJsonParser) { + this.prhAppConfig = prhAppConfig; + this.dmaapConsumerJsonParser = dmaapConsumerJsonParser; } @Override ConsumerDmaapModel consume(String message) throws DmaapNotFoundException { logger.trace("Method called with arg {}", message); - return DmaapConsumerJsonParser.getJsonObject(message); + return dmaapConsumerJsonParser.getJsonObject(message); } @Override -- cgit 1.2.3-korg