"must contain the " +
"'transaction' header.");
connection.write(error).close();
return;
}
<BUG>Transaction transaction = connection.handler().getTransaction(connection, txId);
</BUG>
if (transaction == null) {
Frame error = Frames.createErrorFrame("Unknown transaction",
Headers.create(Frame.TRANSACTION, txId),

"must contain the " +
"'transaction' header.");
connection.write(error).close();
return;
}
Transaction transaction = Transactions.INSTANCE.getTransaction(connection, txId);
if (transaction == null) {
Frame error = Frames.createErrorFrame("Unknown transaction",
Headers.create(Frame.TRANSACTION, txId),
