public void rollback()

in flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionImpl.java [97:104]

• 8 lines of code
• 2 McCabe index (conditional complexity)

  public void rollback() {
    if (!active) {
      throw new JdbcChannelException("Inactive transaction");
    }
    LOGGER.warn("Marking transaction for rollback");
    rollback = true;
    LOGGER.trace("Tx count-rollback: " + count + ", rollback: " + rollback);
  }