Zwergal
diff --git a/‎src/main/scala/io/vertx/asyncsql/database/ConnectionHandler.scala
Lines changed: 1 addition & 0 deletions b/‎src/main/scala/io/vertx/asyncsql/database/ConnectionHandler.scala
Lines changed: 1 addition & 0 deletions
@@ -62,6 +62,7 @@ trait ConnectionHandler extends ScalaBusMod {
   private def mapRepliesToTransactionReceive(c: Connection): BusModReply => BusModReply = {
     case AsyncReply(receiveEndFuture) => AsyncReply(receiveEndFuture.map(mapRepliesToTransactionReceive(c)))
     case Ok(v, None) => Ok(v, Some(ReceiverWithTimeout(inTransactionReceive(c), transactionTimeout, () => failTransaction(c))))
+    case Error(msg, id, v, None) => Error(msg, id, v, Some(ReceiverWithTimeout(inTransactionReceive(c), transactionTimeout, () => failTransaction(c))))
     case x => x
   }
Original file line number	Diff line number	Diff line change
`@@ -62,6 +62,7 @@ trait ConnectionHandler extends ScalaBusMod {`
`62`	`62`	`private def mapRepliesToTransactionReceive(c: Connection): BusModReply => BusModReply = {`
`63`	`63`	`case AsyncReply(receiveEndFuture) => AsyncReply(receiveEndFuture.map(mapRepliesToTransactionReceive(c)))`
`64`	`64`	`case Ok(v, None) => Ok(v, Some(ReceiverWithTimeout(inTransactionReceive(c), transactionTimeout, () => failTransaction(c))))`
	`65`	`+ case Error(msg, id, v, None) => Error(msg, id, v, Some(ReceiverWithTimeout(inTransactionReceive(c), transactionTimeout, () => failTransaction(c))))`
`65`	`66`	`case x => x`
`66`	`67`	`}`
`67`	`68`