| commit | 84a8d88e158e8ab79e759d363f6b2adf3524865c | [log] [tgz] |
|---|---|---|
| author | Sundar Ramamoorthy <ramamoorthy@google.com> | Tue Sep 05 13:36:56 2017 -0700 |
| committer | Sundar Ramamoorthy <ramamoorthy@google.com> | Tue Sep 05 13:36:56 2017 -0700 |
| tree | 2124f8766912246de72834cc252451a446adc246 | |
| parent | d8b3a12172854db2943c84cb74abba5016a5f115 [diff] |
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 }