| 2010-07-06 11:09:37 |
Stelios Tzivakis |
description |
In GearmanClientImpl in method " public <T> Future<T> submit(Callable<T> task) " - subitting a backgroynd job
the code does not throw an error when gearman is down, It return a (Future<T> job) instead and just logs the IOException occured.
So there is no way to tell if gearman is up or down because this always succeds.
Reproducing the situation
---------------
Gearm is up
Client connects to Gearman
We Shitdown gearman
Client submits a background job
try {
GearmanJob job = GearmanJobImpl.createBackgroundJob (
functionToCall,
requestPayload.getBytes(),
uniqueId);
f = client.submit(job);
} catch (Exception e) {
comResponse.setErrNo(ComResponse.ERR_SYSTEM_FAIL);
comResponse.setErrMessage(e.getMessage());
return comResponse;
}
Code does not reach the catch statement |
In GearmanClientImpl in method " public <T> Future<T> submit(Callable<T> task) " - subitting a backgroynd job
the code does not throw an error when gearman is down, It return a (Future<T> job) instead and just logs the IOException occured.
So there is no way to tell if gearman is up or down because this always succeds.
Reproducing the situation
---------------
Gearm is up
Client connects to Gearman
We Shitdown gearman
Client submits a background job
try {
GearmanJob job = GearmanJobImpl.createBackgroundJob (
functionToCall,
requestPayload.getBytes(),
uniqueId);
f = client.submit(job);
} catch (Exception e) {
comResponse.setErrNo(ComResponse.ERR_SYSTEM_FAIL);
comResponse.setErrMessage(e.getMessage());
return comResponse;
}
Code does not reach the catch statement
|
|
