diff --git a/src/main/java/altk/comm/engine/CommEngine.java b/src/main/java/altk/comm/engine/CommEngine.java index 258c738..bcc5c29 100644 --- a/src/main/java/altk/comm/engine/CommEngine.java +++ b/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