Missed check for status

listener.go

diff --git a/listener.go b/listener.go
index 8b35d85..2aafd5b 100644
--- a/listener.go
+++ b/listener.go
@@ -29,11 +29,11 @@
 
 	snapData, ok := e.(*common.Snapshot)
 	if ok {
-		processSnapshot(snapData, db, txn)
+		res = processSnapshot(snapData, db, txn)
 	} else {
 		changeSet, ok := e.(*common.ChangeList)
 		if ok {
-			processChange(changeSet, db, txn)
+			res = processChange(changeSet, db, txn)
 		} else {
 			log.Errorf("Received Invalid event. This shouldn't happen!")
 		}