test logs
This commit is contained in:
parent
c4da6672f6
commit
d99dc58bc9
2 changed files with 8 additions and 2 deletions
|
@ -97,11 +97,17 @@ public class SEBClientEventBatchService {
|
||||||
initialDelay = 100)
|
initialDelay = 100)
|
||||||
public void processEvents() {
|
public void processEvents() {
|
||||||
|
|
||||||
|
final long start = Utils.getMillisecondsNow();
|
||||||
|
|
||||||
final int size = this.eventDataQueue.size();
|
final int size = this.eventDataQueue.size();
|
||||||
if (size > 1000) {
|
if (size > 1000) {
|
||||||
log.warn("-----> There are more then 1000 SEB client logs in the waiting queue: {}", size);
|
log.warn("-----> There are more then 1000 SEB client logs in the waiting queue: {}", size);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (size == 0) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
|
||||||
this.events.clear();
|
this.events.clear();
|
||||||
|
@ -131,6 +137,8 @@ public class SEBClientEventBatchService {
|
||||||
} 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);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
System.out.println("************ tuck: " + (Utils.getMillisecondsNow() - start));
|
||||||
}
|
}
|
||||||
|
|
||||||
private EventData convertData(final EventData eventData) {
|
private EventData convertData(final EventData eventData) {
|
||||||
|
|
|
@ -52,7 +52,6 @@ public class SEBClientPingBatchService {
|
||||||
}
|
}
|
||||||
|
|
||||||
final int size = this.pings.size();
|
final int size = this.pings.size();
|
||||||
System.out.println("************** size=" + size);
|
|
||||||
if (size > 1000) {
|
if (size > 1000) {
|
||||||
log.warn("----> There are more then 1000 SEB client logs in the waiting queue: {}", size);
|
log.warn("----> There are more then 1000 SEB client logs in the waiting queue: {}", size);
|
||||||
}
|
}
|
||||||
|
@ -89,7 +88,6 @@ public class SEBClientPingBatchService {
|
||||||
final long timestamp) {
|
final long timestamp) {
|
||||||
|
|
||||||
if (connectionToken == null) {
|
if (connectionToken == null) {
|
||||||
System.out.println("************** connectionToken null");
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue