Upgrading event-client to version 1.3.1

[aai/spike.git] / src / main / java / org / onap / aai / spike / service / SpikeEventProcessor.java

diff --git a/src/main/java/org/onap/aai/spike/service/SpikeEventProcessor.java b/src/main/java/org/onap/aai/spike/service/SpikeEventProcessor.java
index c4e1746..88fa716 100644 (file)
--- a/src/main/java/org/onap/aai/spike/service/SpikeEventProcessor.java
+++ b/src/main/java/org/onap/aai/spike/service/SpikeEventProcessor.java
@@ -186,7 +186,7 @@ public class SpikeEventProcessor extends TimerTask {
 
                 // There is no point in continually committing the same offset value, so make sure
                 // that something has actually changed before we do anything...
-                if ((lastCommittedOffset == null) || (lastCommittedOffset != nextOffset)) {
+                if ((lastCommittedOffset == null) || (!lastCommittedOffset.equals(nextOffset))) {
 
                     if (logger.isDebugEnabled()) {
                         logger.debug(