seems to work well with 4 workers... consider to add to 1.6
This commit is contained in:
parent
886f457438
commit
6354da0f49
1 changed files with 3 additions and 7 deletions
|
@ -135,9 +135,9 @@ public class SEBClientEventBatchService {
|
||||||
private void processEvents(final String workerName, final Collection<EventData> events) {
|
private void processEvents(final String workerName, final Collection<EventData> events) {
|
||||||
|
|
||||||
long start = 0L;
|
long start = 0L;
|
||||||
//if (log.isDebugEnabled()) {
|
if (log.isDebugEnabled()) {
|
||||||
start = Utils.getMillisecondsNow();
|
start = Utils.getMillisecondsNow();
|
||||||
//}
|
}
|
||||||
|
|
||||||
final int size = this.eventDataQueue.size();
|
final int size = this.eventDataQueue.size();
|
||||||
if (size > 1000) {
|
if (size > 1000) {
|
||||||
|
@ -182,10 +182,6 @@ public class SEBClientEventBatchService {
|
||||||
size,
|
size,
|
||||||
start - Utils.getMillisecondsNow());
|
start - Utils.getMillisecondsNow());
|
||||||
}
|
}
|
||||||
log.info("SEBClientEventBatchService worker {} processes batch of size {} in {} ms",
|
|
||||||
workerName,
|
|
||||||
size,
|
|
||||||
start - Utils.getMillisecondsNow());
|
|
||||||
|
|
||||||
} catch (final Exception e) {
|
} catch (final Exception e) {
|
||||||
log.error("Failed to process SEB events from eventDataQueue: ", e);
|
log.error("Failed to process SEB events from eventDataQueue: ", e);
|
||||||
|
|
Loading…
Reference in a new issue