From baaa255182fa22452b9a6a33451f3913f6dc367c Mon Sep 17 00:00:00 2001
From: Shlomi Noach <shlomi-noach@github.com>
Date: Wed, 4 Jan 2017 12:42:21 +0200
Subject: [PATCH] bailing out from onApplyEventStruct()

---
 go/logic/migrator.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/go/logic/migrator.go b/go/logic/migrator.go
index 3d83d27..7b3daf3 100644
--- 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:
 			{