Yuk-Ming Lam 5 лет назад
Родитель
Сommit
6c29b820ae
2 измененных файлов: 3 добавлений и 3 удалений
  1. +1
    -1
      src/main/java/altk/comm/engine/Broadcast.java
  2. +2
    -2
      src/main/java/altk/comm/engine/Postback.java

+ 1
- 1
src/main/java/altk/comm/engine/Broadcast.java Просмотреть файл

@@ -1261,7 +1261,7 @@ public abstract class Broadcast
} }


public PostbackThreadActionOnEmpty getPostbackThreadActionOnEmpty() { public PostbackThreadActionOnEmpty getPostbackThreadActionOnEmpty() {
logJobCount("getPostbackThreadActionOnEmpty");
//logJobCount("getPostbackThreadActionOnEmpty");
if (state==BroadcastState.CANCELED || state==BroadcastState.ALLDONE) return PostbackThreadActionOnEmpty.STOP; if (state==BroadcastState.CANCELED || state==BroadcastState.ALLDONE) return PostbackThreadActionOnEmpty.STOP;
if (setState(BroadcastState.ALLDONE).stateChangeStatus == StateChangeStatus.SUCCESS) return PostbackThreadActionOnEmpty.CONTINUE; if (setState(BroadcastState.ALLDONE).stateChangeStatus == StateChangeStatus.SUCCESS) return PostbackThreadActionOnEmpty.CONTINUE;
return PostbackThreadActionOnEmpty.WAIT; return PostbackThreadActionOnEmpty.WAIT;


+ 2
- 2
src/main/java/altk/comm/engine/Postback.java Просмотреть файл

@@ -195,7 +195,7 @@ public class Postback
private PostbackStatus post(List<String> reportList) private PostbackStatus post(List<String> reportList)
{ {
StringBuffer xml = new StringBuffer(XML_VERSION_1_0_ENCODING_UTF_8); StringBuffer xml = new StringBuffer(XML_VERSION_1_0_ENCODING_UTF_8);
xml.append("<"); xml.append(xmlTopElement); xml.append(">");
xml.append("<" + xmlTopElement + " reports=\"" + reportList.size() + "\">\r\n");
for (String report : reportList) for (String report : reportList)
{ {
xml.append(report + "\r\n"); xml.append(report + "\r\n");
@@ -405,7 +405,7 @@ public class Postback
{ {
if (postQueue.size() < maxQueueSize) if (postQueue.size() < maxQueueSize)
{ {
myLogger.debug("Queueing report" + report);
myLogger.debug("Queueing report " + report);
postQueue.add(report); postQueue.add(report);
postQueue.notify(); postQueue.notify();
return true; return true;


Загрузка…
Отмена
Сохранить