@Test
void shouldRollbackTransaction()
{

    Connection connection = connectionMock( protocol );
    CompletionStage<Void> stage = protocol.rollbackTransaction( connection );
    verify( connection ).writeAndFlush( eq( RollbackMessage.ROLLBACK ), any( RollbackTxResponseHandler.class ) );
    assertNull( await( stage ) );
}