Method execute

storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:176–193

(Tuple input)

    }

    @Override
    public void execute(Tuple input) {
        if (exception != null) {
            throw new RuntimeException(exception);
        }

        //just need an id
        String genId = Long.toString(rand.nextLong());
        inputs.put(genId, input);
        try {
            BoltMsg boltMsg = createBoltMessage(input, genId);

            pendingWrites.putBoltMsg(boltMsg);
        } catch (InterruptedException e) {
            // It's likely that Bolt is shutting down so no need to throw RuntimeException
            // just ignore
        }
    }

    private BoltMsg createBoltMessage(Tuple input, String genId) {
        BoltMsg boltMsg = new BoltMsg();