Fix Cast one of the operands of multiplication operation to a "long"
Fix Either re-interrupt method or rethrow the "InterruptedException"
Issue-ID: DMAAP-894
Change-Id: I150cdc8ac96a05799196ca27d683c0921a76fe92
Signed-off-by: Parshad Patel <pars.patel@samsung.com>
}
} catch (InterruptedException e) {
log.error("Exception "+ e);
}
} catch (InterruptedException e) {
log.error("Exception "+ e);
+ Thread.currentThread().interrupt();
}
} catch (InterruptedException e) {
getLog().warn("Possible message loss. " + e.getMessage(), e);
}
} catch (InterruptedException e) {
getLog().warn("Possible message loss. " + e.getMessage(), e);
+ Thread.currentThread().interrupt();
} catch (IOException e) {
getLog().warn("Possible message loss. " + e.getMessage(), e);
}
} catch (IOException e) {
getLog().warn("Possible message loss. " + e.getMessage(), e);
}
// FIXME: would be good to wait/signal
Thread.sleep(100);
} catch (InterruptedException e) {
// FIXME: would be good to wait/signal
Thread.sleep(100);
} catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
// Setting timeout to a large value for testing purpose.
// 10 minutes
// Setting timeout to a large value for testing purpose.
// 10 minutes
- private static final long kDefaultRequestTimeWindow = 1000 * 60 * 10 * 10 * 10 * 10 * 10;
+ private static final long kDefaultRequestTimeWindow = 1000L * 60 * 10 * 10 * 10 * 10 * 10;
/**
* Construct the security manager against an API key database
/**
* Construct the security manager against an API key database
final long startMs = System.currentTimeMillis();
long count = 0;
final long startMs = System.currentTimeMillis();
long count = 0;
- long maxEventBatch = 1024 * 16;
+ long maxEventBatch = 1024L * 16;
String batchlen = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, BATCH_LENGTH);
if (null != batchlen)
maxEventBatch = Long.parseLong(batchlen);
String batchlen = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, BATCH_LENGTH);
if (null != batchlen)
maxEventBatch = Long.parseLong(batchlen);