}
} catch (InterruptedException e) {
log.error("Exception "+ e);
- // ignore
+ Thread.currentThread().interrupt();
}
}
} 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);
}
// FIXME: would be good to wait/signal
Thread.sleep(100);
} catch (InterruptedException e) {
- // ignore
+ Thread.currentThread().interrupt();
}
}
});
// 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
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);