refresh mgo session when the iter errors (#398)

compose · Aug 15, 2017 · ea2c6c4 · ea2c6c4
1 parent 4f81eba
commit ea2c6c4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -8,6 +8,7 @@
 ### Bugfixes
 - when using MongoDB as a source with tailing enabled and namespace filtering, it was possible for documents
 from others collections to be sent down the pipeline, fixed via [#386](https://github.com/compose/transporter/pull/386)
+- if transporter lost connection to MongoDB while tailing the oplog, the connection never successfully reconnected, fixed via [#398](https://github.com/compose/transporter/pull/398)
 
 ## v0.3.1 [2017-03-24]
 

diff --git a/adaptor/mongodb/reader.go b/adaptor/mongodb/reader.go
@@ -292,7 +292,7 @@ func (r *Reader) tailCollection(c string, mgoSession *mgo.Session, oplogTime bso
 			}
 			if iter.Err() != nil {
 				log.With("path", db).Errorf("error tailing oplog, %s", iter.Err())
-				// return adaptor.NewError(adaptor.CRITICAL, m.path, fmt.Sprintf("MongoDB error (error reading collection %s)", iter.Err()), nil)
+				mgoSession.Refresh()
 			}
 
 			query = bson.M{"ts": bson.M{"$gte": oplogTime}}