diff --git a/lib/transaction.js b/lib/transaction.js
index dfb9926..9c72d83 100644
--- a/lib/transaction.js
+++ b/lib/transaction.js
@@ -85,7 +85,7 @@ Transaction.begin = function(connector, options, cb) {
       return cb(err);
     }
     var tx = connection;
-    if (!(connection instanceof Transaction)) {
+    if (!(connection instanceof Transaction) && !(typeof connection.txId === 'string')) {
       tx = new Transaction(connector, connection);
     }
     cb(err, tx);