public void commit()

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

• 10 lines of code
• 3 McCabe index (conditional complexity)

  public void commit() {
    if (!active) {
      throw new JdbcChannelException("Inactive transaction");
    }
    if (rollback) {
      throw new JdbcChannelException(
          "Cannot commit transaction marked for rollback");
    }
    LOGGER.trace("Tx count-commit: " + count + ", rollback: " + rollback);
  }