| commit | 92be695af4132b11eccd7b9ce3010747e0812765 | [log] [tgz] |
|---|---|---|
| author | Sundar Ramamoorthy <sramamoorthy@apigee.com> | Wed Nov 09 16:22:23 2016 -0800 |
| committer | Sundar Ramamoorthy <sramamoorthy@apigee.com> | Wed Nov 09 16:22:23 2016 -0800 |
| tree | 218c67b7de35d538df7341deb89fc38c3006a3c7 | |
| parent | e4517c3de6f90e68f1e80f888e34e00c2e0456ef [diff] |
Missed check for status
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!") }