Subitting a Background Job does not fail after gearman has been closed

Bug 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 theory this scenario should result in a rejectedExecutionException, will take a look

Thank you very much
Stelios Tzivakis

On Wed, Aug 11, 2010 at 9:43 AM, Eric Lambert <email address hidden> wrote:
> In theory this scenario should result in a rejectedExecutionException,
> will take a look
>
> ** Changed in: gearman-java
> Milestone: None => 0.04
>
> --
> Subitting a Background Job does not fail after gearman has been closed
> https://bugs.launchpad.net/bugs/602230
> You received this bug notification because you are a direct subscriber
> of the bug.
>
> Status in Gearman Java: New
>
> Bug 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
>
>
>
> To unsubscribe from this bug, go to:
> https://bugs.launchpad.net/gearman-java/+bug/602230/+subscribe
>