diff options
| author |   Pamela Dragosh <pdragosh@research.att.com> | 2018-09-18 16:15:29 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2018-09-18 16:15:29 +0000 |
| commit | 66179519b26840ac633f520f011baedf9bfbb9dc (patch) | |
| tree | 68b6819c82dce9076422a8784725100bc67c6838 /testsuites | |
| parent | 024a4dd745b2f6ec9f15082d711e61994c95cdad (diff) | |
| parent | a46382dd12b981220243bf11ab3fb115acfabfa0 (diff) | |
Merge "remove license issues"
Diffstat (limited to 'testsuites')
| -rw-r--r-- | testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java index 1c33289b7..54ee9ba92 100644 --- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java +++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java @@ -84,7 +84,7 @@ public class KafkaEventSubscriber implements Runnable { while (subscriberThread.isAlive() && !subscriberThread.isInterrupted()) { try { - final ConsumerRecords<String, String> records = consumer.poll(POLL_DURATION); + final ConsumerRecords<String, String> records = consumer.poll(POLL_DURATION.toMillis()); for (final ConsumerRecord<String, String> record : records) { eventsReceivedCount++; System.out.println("****** Received event No. " + eventsReceivedCount + " ******"); |