public void ack()

in tormenta-core/src/main/java/com/twitter/tormenta/spout/FixedTupleSpout.java [161:166]

• 6 lines of code
• 1 McCabe index (conditional complexity)

  public void ack(Object msgId) {
    synchronized(acked) {
      int curr = get(acked, _id, 0);
      acked.put(_id, curr+1);
    }
  }