diff options
| -rw-r--r-- | src/main/java/org/onap/aai/event/EventBusConsumer.java | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/main/java/org/onap/aai/event/EventBusConsumer.java b/src/main/java/org/onap/aai/event/EventBusConsumer.java index 2da879d..5e54d3b 100644 --- a/src/main/java/org/onap/aai/event/EventBusConsumer.java +++ b/src/main/java/org/onap/aai/event/EventBusConsumer.java @@ -106,9 +106,7 @@ public class EventBusConsumer extends ScheduledPollConsumer { int processCount = 0; - Iterable<String> messages = null; - - messages = consumer.fetch(); + Iterable<String> messages = consumer.fetch(); String topic = endpoint.getEventTopic(); |