TaskData input = bus.getNextInput(client, taskId);
TaskData input = null;  input = bus.getNextInput(client, taskId);
    public void run()    {        // Get the next input from the client's queue of inputs for the task.        NodeAddress client = task.getClient();        int taskId = task.getTaskId();        try        {            TaskData input = bus.getNextInput(client, taskId);            TaskRunnable taskInstance = server.instantiateTaskRunnable(task.getTaskClassName());            while (input != null)            {                int inputId = input.getInputId();                Serializable data = taskInstance.run(inputId, input.getData());                TaskData output = new TaskData(inputId, data);                bus.putOutput(client, taskId, output);                input = bus.getNextInput(client, taskId);            }        }        catch (Exception e)        {            //noinspection EmptyCatchBlock            try            {                bus.taskFailed(client,taskId,new GridException(e));            }            catch (Exception ignore)            {            }        }    }