bailing out from onApplyEventStruct()

2017-01-04 12:42:21 +02:00 · 2017-01-04 12:42:21 +02:00 · baaa255182
commit baaa255182
parent 645af21d03
1 changed files with 3 additions and 1 deletions
--- a/go/logic/migrator.go
+++ b/go/logic/migrator.go
@ -1074,7 +1074,9 @@ func (this *Migrator) executeWriteFuncs() error {
 		select {
 		case eventStruct := <-this.applyEventsQueue:
 			{
-				this.onApplyEventStruct(eventStruct)
+				if err := this.onApplyEventStruct(eventStruct); err != nil {
+					return err
+				}
 			}
 		default:
 			{