Просмотр исходного кода

Removed unused and already-commented out do_post_good method.

tags/before_postback_reorg
ymlam 6 лет назад
Родитель
Сommit
1a92409c15
1 измененных файлов: 0 добавлений и 97 удалений
  1. +0
    -97
      src/main/java/altk/comm/engine/CommEngine.java

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

@@ -266,103 +266,6 @@ public abstract class CommEngine extends HttpServlet
broadcast.doPost(request, response, this);
}

//@Override
// TODO Not used - delete
@Deprecated
protected void doPost_good(HttpServletRequest request, HttpServletResponse response)
{
myException = null;
try
{
Broadcast broadcast = mkBroadcast();
broadcast.setServiceThreadPoolsize(serviceThreadPoolSize);
try
{
broadcast.decode(request, notInService);
if (notInService)
{
throw new PlatformException(PlatformError.RUNTIME_ERROR,
"Not in service");
}
if (broadcast.recipientList.size() == 0)
{
CommonLogger.activity.info("Broadcast " + broadcast.getBroadcastId() + ": No recipients");
broadcast.setState(BroadcastState.COMPLETED, "No recipients", null);
return;
}
// Determine postBackUrl
String postBackURL = broadcast.getPostBackURL();
PostBack postBack = null;
if (postBackURL != null)
{
postBack = postBackMap.get(postBackURL);
if (postBack == null)
{
postBack = new PostBack(postBackURL, broadcast.broadcastType + "_status",
postbackMaxQueueSize, postbackSenderPoolSize, postbackMaxBatchSize);
postBackMap.put(postBackURL, postBack);
}
}
broadcast.initSync(resources);
broadcast.init(postBack);
if (broadcast.getState() == BroadcastState.COMPLETED) return;
}
catch (BroadcastException e)
{
myException = e;
broadcast.setState(BroadcastState.ABORTED, e.errorCodeText, e.errorText);
CommonLogger.alarm.error("Broadcast aborted: " + e.getMessage());
myLogger.error("Broadcast aborted", e);
return;
}
catch (Throwable t)
{
// Caught stray unexpected runtime problem
CommonLogger.alarm.error("Broadcast aborted: " + t);
myLogger.error("Broadcast aborted", t);
myException = new BroadcastException(BroadcastError.PLATFORM_ERROR, t.getMessage());
broadcast.setState(BroadcastState.ABORTED, myException.errorCodeText, myException.errorText);
}
finally
{
// Put broadcast in broadcasts map.
String broadcastId = broadcast.getBroadcastId();
if (broadcastId != null && broadcastId.length() != 0)
{
broadcasts.put(broadcastId, broadcast);
}
else
{
String makeUpId = "Unknown" + unknownBroadcastIdNdx++;
broadcasts.put(makeUpId, broadcast);
}
// Return regular or error response
String responseXML = broadcast.getResponseXML(myException);
PrintWriter writer = response.getWriter();
writer.write(responseXML);
writer.close();
}
try
{
broadcast.initAsync();
broadcast.startProcessing();
}
catch (BroadcastException e)
{
broadcast.setState(BroadcastState.ABORTED, e.errorCodeText, e.errorText);
CommonLogger.alarm.error("Broadcast aborted: " + e.getMessage());
myLogger.error("Broadcast aborted", e);
}
}
catch (Throwable t)
{
// Caught stray unexpected runtime problem
CommonLogger.alarm.error("Broadcast aborted: " + t.getMessage());
myLogger.error("Broadcast aborted", t);
}
}

/**
* Functions covered are
* get=status


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