better exception handling

This commit is contained in:
kimchy 2010-03-20 00:55:24 +02:00
parent d4dc3cacc1
commit d2bf446d9c
2 changed files with 6 additions and 2 deletions

View File

@ -50,7 +50,11 @@ public abstract class BaseAction<Request extends ActionRequest, Response extends
listener.onFailure(validationException);
return;
}
doExecute(request, listener);
try {
doExecute(request, listener);
} catch (Exception e) {
listener.onFailure(e);
}
}
protected abstract void doExecute(Request request, ActionListener<Response> listener);

View File

@ -218,7 +218,7 @@ public abstract class TransportShardReplicationOperationAction<Request extends S
try {
shards = shards(request);
} catch (Exception e) {
listener.onFailure(new ReplicationShardOperationFailedException(shards.shardId(), e));
listener.onFailure(e);
return true;
}