midsuit
/
core-jgi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

IDEMPIERE-4154 ServerPush Adjustments. Make another 2 adjustment as there are still report of slowness due to failure to resume long polling resource.

This commit is contained in:
hengsin 2020-02-04 10:56:33 +08:00
parent fc79f86973
commit a64ccd107e
1 changed files with 16 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
org.adempiere.ui.zk/WEB-INF/src/fi/jawsy/jawwa/zk/atmosphere/AtmosphereServerPush.java
View File

@ -191,19 +191,23 @@ public class AtmosphereServerPush implements ServerPush {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
} }
if (!ok) { if (!ok) {
try { for(int i = 0; i < 3 && !ok; i++) {
Thread.sleep(500);
} catch (InterruptedException e1) {}
if (schedules.size() > 0) {
try { try {
ok = commitResponse(); Thread.sleep(500);
} catch (IOException e) { } catch (InterruptedException e1) {}
log.error(e.getMessage(), e); if (schedules.size() > 0) {
} try {
if (!ok) { ok = commitResponse();
log.warn("Failed to resume long polling resource"); } catch (IOException e) {
} log.error(e.getMessage(), e);
} }
} else {
ok = true;
}
}
if (!ok) {
log.warn("Failed to resume long polling resource");
}
} }
} else { } else {
//in event listener thread, can schedule immediately //in event listener thread, can schedule immediately
@ -252,12 +256,6 @@ public class AtmosphereServerPush implements ServerPush {
log.trace(resource.transport().name()); log.trace(resource.transport().name());
} }
try {
commitResponse();
} catch (IOException e) {
log.error(e.getLocalizedMessage(), e);
}
DesktopCtrl desktopCtrl = (DesktopCtrl) this.desktop.get(); DesktopCtrl desktopCtrl = (DesktopCtrl) this.desktop.get();
if (desktopCtrl == null) { if (desktopCtrl == null) {
log.error("No desktop available"); log.error("No desktop available");