Why isn't there a result on failed jobs?

Hi Khai:

Per the Gearman Protocol, failed jobs dont return a result. Which, when you think about it, is the right thing since the job has failed the job should not have a result. There is a means of communicating of this kind of information and that can be done by setting the exception "field" of the GearmanJobResult. So in your case if you were to do something like

GearmanJobResult gjr = new GearmanJobResultImpl(this.jobHandle, jobResult,
                new byte[0], jobResultMsg.getBytes(), new byte[0], 0, 0);

You should see the result sent to the client should have the exceptions (GearmanJobResult.getExceptions()) set to bytes that make up "job failed!".

Let me know if you have questions

Eric

Thanks Eric Lambert, that solved my question.

Acc

I tried using a modified ReverseFunction example to test but I can't seem to get the exception back from the worker. It doesn't matter what I set the jobResult, only the result is returned to the client. Am I doing something wrong? I'm using with the gearman C server, version 0.27

Here's the worker:

public class ReverseFunction extends AbstractGearmanFunction {
    @Override
    public GearmanJobResult executeFunction() {
        boolean jobResult = true;
        RuntimeException re = new RuntimeException("job Failed!");

        StringBuffer sb = new StringBuffer(ByteUtils.fromUTF8Bytes((byte[]) this.data));

        GearmanJobResult gjr = new GearmanJobResultImpl(this.jobHandle,
                jobResult, sb.reverse().toString().getBytes(),
                new byte[0], re.toString().getBytes(), 0, 0);
        return gjr;
    }
}

here's the client:

    public String reverse(String input) {
        String function = ReverseFunction.class.getCanonicalName();
        String uniqueId = null;
        byte[] data = ByteUtils.toUTF8Bytes(input);
        GearmanJobResult res = null;
        GearmanJob job = GearmanJobImpl.createJob(function, data, uniqueId);
        String value = "";
        client.submit(job);
        try {
            res = job.get();
            value = ByteUtils.fromUTF8Bytes(res.getResults());
        } catch (Exception e) {
            value = ByteUtils.fromUTF8Bytes(res.getExceptions());
            e.printStackTrace(); //NOPMD
        }
        return value;
    }

This has been fixed. I've verified and tested.