From 5bf11a7500944b8b306c5d4f478e4bc45ef1fb51 Mon Sep 17 00:00:00 2001 From: liamfallon Date: Wed, 21 Aug 2019 09:39:44 +0000 Subject: Fix checkstyle warnings in apex-pdp Unit tests introduced some checkstyle warnings, this review resolves those warnings. Issue-ID: POLICY-1942 Change-Id: I16438621c1db0adfbe70bc8b237d05bd7cc72697 Signed-off-by: liamfallon --- .../onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src') diff --git a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumer.java b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumer.java index 787ac4ef5..17738f194 100644 --- a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumer.java +++ b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumer.java @@ -149,7 +149,7 @@ public class ApexKafkaConsumer implements ApexEventConsumer, Runnable { while (consumerThread.isAlive() && !stopOrderedFlag) { try { final ConsumerRecords records = - kafkaConsumer.poll(kafkaConsumerProperties.getConsumerPollDuration().toMillis()); + kafkaConsumer.poll(kafkaConsumerProperties.getConsumerPollDuration()); for (final ConsumerRecord record : records) { traceIfTraceEnabled(record); eventReceiver.receiveEvent(new Properties(), record.value()); -- cgit 1.2.3-korg