Method accept

storm-client/src/jvm/org/apache/storm/executor/Executor.java:282–293

(Object event)

    public abstract void tupleActionFn(int taskId, TupleImpl tuple) throws Exception;

    @Override
    public void accept(Object event) {
        AddressedTuple addressedTuple = (AddressedTuple) event;
        int taskId = addressedTuple.getDest();

        TupleImpl tuple = (TupleImpl) addressedTuple.getTuple();
        if (isDebug) {
            LOG.info("Processing received TUPLE: {} for TASK: {} ", tuple, taskId);
        }

        acceptTupleAction(taskId, tuple);
    }

    protected void acceptTupleAction(int taskId, TupleImpl tuple) {
        try {