aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/aai/spike/service/SpikeEventProcessor.java
diff options
context:
space:
mode:
authorShwetank Dave <shwetank.dave@amdocs.com>2018-11-07 16:04:43 -0500
committerShwetank Dave <shwetank.dave@amdocs.com>2018-11-07 16:19:38 -0500
commitb1ea3b6d19de319a283b6284595b0465c9e98030 (patch)
tree60ab835aaa668ce34f0f5f26c88e930b70fe903e /src/main/java/org/onap/aai/spike/service/SpikeEventProcessor.java
parent99159b883ec864955502b76844a79eb8df3bfe3f (diff)
Upgrading event-client to version 1.3.1
- Adding support for rabbit mq (from event-client version 1.3.1) - Fixing issue where the checking offset fails - Adding a fix for fully qualified domain name Change-Id: Ibab1fc48e00df15a8a2b17369d0731fece17061c Issue-ID: AAI-1798 Signed-off-by: Shwetank Dave <shwetank.dave@amdocs.com>
Diffstat (limited to 'src/main/java/org/onap/aai/spike/service/SpikeEventProcessor.java')
-rw-r--r--src/main/java/org/onap/aai/spike/service/SpikeEventProcessor.java2
1 files changed, 1 insertions, 1 deletions
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
--- 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(