throws ConfigDbException, TopicExistsException, AccessDeniedException, UnavailableException,
CambriaApiException, IOException {
- // final long startTime = System.currentTimeMillis();
+
final HttpServletRequest req = ctx.getRequest();
ByteArrayOutputStream baos = new ByteArrayOutputStream();
limit = Integer.parseInt(req.getParameter("limit"));
}
limit = 1;
- // int timeoutMs = 60000;
+
int timeoutMs = CambriaConstants.kNoTimeout;
String strtimeoutMS = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "timeout");
if (strtimeoutMS != null)
timeoutMs = Integer.parseInt(strtimeoutMS);
// int timeoutMs = ctx.getConfigReader().getSettings().getInt("timeout",
- // CambriaConstants.kNoTimeout);
+
if (req.getParameter("timeout") != null) {
timeoutMs = Integer.parseInt(req.getParameter("timeout"));
}
int status = HttpStatus.SC_NOT_FOUND;
String errorMsg = null;
- if (excp instanceof CambriaApiException) {
+ if (excp.getClass().toString().contains("CambriaApiException")) {
status = ((CambriaApiException) excp).getStatus();
JSONTokener jsonTokener = new JSONTokener(((CambriaApiException) excp).getBody());
JSONObject errObject = new JSONObject(jsonTokener);
int status = HttpStatus.SC_NOT_FOUND;
String errorMsg = null;
- if (excp instanceof CambriaApiException) {
+ if (excp.getClass().toString().contains("CambriaApiException")) {
status = ((CambriaApiException) excp).getStatus();
JSONTokener jsonTokener = new JSONTokener(((CambriaApiException) excp).getBody());
JSONObject errObject = new JSONObject(jsonTokener);
} catch (Exception excp) {
int status = HttpStatus.SC_NOT_FOUND;
String errorMsg = null;
- if (excp instanceof CambriaApiException) {
+ if (excp.getClass().toString().contains("CambriaApiException")) {
status = ((CambriaApiException) excp).getStatus();
JSONTokener jsonTokener = new JSONTokener(((CambriaApiException) excp).getBody());
JSONObject errObject = new JSONObject(jsonTokener);
} catch (Exception excp) {
int status = HttpStatus.SC_NOT_FOUND;
String errorMsg = null;
- if (excp instanceof CambriaApiException) {
+ if (excp.getClass().toString().contains("CambriaApiException")) {
status = ((CambriaApiException) excp).getStatus();
JSONTokener jsonTokener = new JSONTokener(((CambriaApiException) excp).getBody());
JSONObject errObject = new JSONObject(jsonTokener);