Method handleAck

storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:215–221

(Object id)

    }

    private void handleAck(Object id) {
        Tuple acked = inputs.remove(id);
        if (acked == null) {
            throw new RuntimeException("Acked a non-existent or already acked/failed id: " + id);
        }
        collector.ack(acked);
    }

    private void handleFail(Object id) {
        Tuple failed = inputs.remove(id);