initial, simple solution to our-of-order applying of DML events

Shlomi Noach · Shlomi Noach · commit 134bf385fdb0 · 2016-05-05T17:14:55.000+03:00
diff --git a/go/logic/migrator.go b/go/logic/migrator.go
@@ -613,7 +613,7 @@ func (this *Migrator) initiateStreaming() error {
 		},
 	)
 	this.eventsStreamer.AddListener(
-		true,
+		false,
 		this.migrationContext.DatabaseName,
 		this.migrationContext.OriginalTableName,
 		func(dmlEvent *binlog.BinlogDMLEvent) error {

Original file line number	Diff line number	Diff line change
`@@ -613,7 +613,7 @@ func (this *Migrator) initiateStreaming() error {`
`613`	`613`	`},`
`614`	`614`	`)`
`615`	`615`	`this.eventsStreamer.AddListener(`
`616`		`- true,`
	`616`	`+ false,`
`617`	`617`	`this.migrationContext.DatabaseName,`
`618`	`618`	`this.migrationContext.OriginalTableName,`
`619`	`619`	`func(dmlEvent *binlog.BinlogDMLEvent) error {`