ITQC/gls_docs
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Check cast.

Browse Source
This commit is contained in:
Fabian Märki
2016-06-08 08:46:42 +02:00
parent 91d1b3c142
commit b27b43a6f6
1 changed files with 17 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
src/main/java/ch/psi/daq/queryrest/controller/QueryRestController.java
View File

@ -43,9 +43,8 @@ import ch.psi.daq.domain.reader.Backend;
import ch.psi.daq.domain.request.validate.RequestProviderValidator;
import ch.psi.daq.queryrest.query.QueryManager;
import ch.psi.daq.queryrest.response.AbstractHTTPResponse;
import ch.psi.daq.queryrest.response.csv.CSVResponseStreamWriter;
import ch.psi.daq.queryrest.response.PolymorphicResponseMixIn;
import ch.psi.daq.queryrest.response.json.JSONHTTPResponse;
import ch.psi.daq.queryrest.response.json.JSONResponseStreamWriter;
@RestController
public class QueryRestController {
@ -58,23 +57,17 @@ public class QueryRestController {
@Resource
private ApplicationContext appContext;
@Resource
private Validator queryValidator;
private Validator requestProviderValidator = new RequestProviderValidator();
@Resource
private JSONResponseStreamWriter jsonResponseStreamWriter;
@Resource
private CSVResponseStreamWriter csvResponseStreamWriter;
@Resource
private QueryManager queryManager;
@Resource
private ObjectMapper objectMapper;
private Response defaultResponse = new JSONHTTPResponse();
@InitBinder
@ -179,7 +172,19 @@ public class QueryRestController {
try {
LOGGER.debug("Executing queries '{}'", queries);
((AbstractHTTPResponse)queries.getResponseOrDefault(defaultResponse)).respond(appContext, queries, res);
Response response = queries.getResponseOrDefault(defaultResponse);
if (response instanceof AbstractHTTPResponse) {
((AbstractHTTPResponse) response).respond(appContext, queries, res);
} else {
String message =
String.format(
"Expecting Response of type '%s' but received '%s'. Check JSON deserialization defined in '%s'",
AbstractHTTPResponse.class.getName(), response.getClass().getName(),
PolymorphicResponseMixIn.class.getName());
LOGGER.error(message);
throw new IllegalArgumentException(message);
}
} catch (Exception e) {
LOGGER.error("Failed to execute query '{}'.", queries, e);