handle defer for all cases.
diff --git a/listener.go b/listener.go index 0f6bc35..55492c3 100644 --- a/listener.go +++ b/listener.go
@@ -15,6 +15,7 @@ package apidApigeeSync import ( + "errors" "github.com/30x/apid-core" "github.com/apigee-labs/transicator/common" ) @@ -130,6 +131,7 @@ ok = _delete(change.Table, []common.Row{change.OldRow}, tx) } if !ok { + err = errors.New("Sql Operation error. Operation rollbacked") log.Error("Sql Operation error. Operation rollbacked") return ok }