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
 		}