runtime/org.argeo.slc.launcher/src/main/java/org/argeo/slc/ws/test/tree/WebServiceTreeTestResultNotifier.java

   1 package org.argeo.slc.ws.test.tree;
   2
   3 import org.apache.commons.logging.Log;
   4 import org.apache.commons.logging.LogFactory;
   5 import org.argeo.slc.core.test.TestResultListener;
   6 import org.argeo.slc.core.test.TestResultPart;
   7 import org.argeo.slc.core.test.tree.TreeTestResult;
   8 import org.argeo.slc.msg.test.tree.CloseTreeTestResultRequest;
   9 import org.argeo.slc.msg.test.tree.CreateTreeTestResultRequest;
  10 import org.argeo.slc.msg.test.tree.ResultPartRequest;
  11 import org.argeo.slc.ws.client.WebServiceUtils;
  12 import org.springframework.ws.client.WebServiceIOException;
  13 import org.springframework.ws.client.core.WebServiceTemplate;
  14 import org.springframework.ws.soap.client.SoapFaultClientException;
  15
  16 public class WebServiceTreeTestResultNotifier implements
  17                 TestResultListener<TreeTestResult> {
  18         private WebServiceTemplate template;
  19         private Boolean onlyOnClose = false;
  20
  21         private Log log = LogFactory.getLog(getClass());
  22
  23         private Boolean cannotConnect = false;
  24
  25         public void resultPartAdded(TreeTestResult testResult,
  26                         TestResultPart testResultPart) {
  27                 if (onlyOnClose)
  28                         return;
  29
  30                 if (cannotConnect)
  31                         return;
  32
  33                 try {
  34                         if (testResult.getResultParts().size() == 1
  35                                         && testResult.getResultParts().values().iterator().next()
  36                                                         .getParts().size() == 1) {
  37                                 CreateTreeTestResultRequest req = new CreateTreeTestResultRequest(
  38                                                 testResult);
  39
  40                                 if (log.isDebugEnabled())
  41                                         log.debug("Send create result request for result "
  42                                                         + testResult.getUuid());
  43
  44                                 WebServiceUtils.marshalSendAndReceive(template, req);
  45                         } else {
  46                                 ResultPartRequest req = new ResultPartRequest(testResult);
  47
  48                                 if (log.isDebugEnabled())
  49                                         log.debug("Send result parts for result "
  50                                                         + testResult.getUuid());
  51
  52                                 WebServiceUtils.marshalSendAndReceive(template, req);
  53                         }
  54                 } catch (SoapFaultClientException e) {
  55                         WebServiceUtils.manageSoapException(e);
  56
  57                 } catch (WebServiceIOException e) {
  58                         manageIoException(e);
  59                 }
  60         }
  61
  62         public void close(TreeTestResult testResult) {
  63                 if (cannotConnect)
  64                         return;
  65
  66                 try {
  67                         if (onlyOnClose) {
  68                                 CreateTreeTestResultRequest req = new CreateTreeTestResultRequest(
  69                                                 testResult);
  70
  71                                 if (log.isDebugEnabled())
  72                                         log.debug("Send create result request for result "
  73                                                         + testResult.getUuid());
  74
  75                                 WebServiceUtils.marshalSendAndReceive(template, req);
  76                         } else {
  77                                 CloseTreeTestResultRequest req = new CloseTreeTestResultRequest(
  78                                                 testResult);
  79
  80                                 if (log.isDebugEnabled())
  81                                         log.debug("Send close result request for result "
  82                                                         + testResult.getUuid());
  83
  84                                 WebServiceUtils.marshalSendAndReceive(template, req);
  85
  86                         }
  87                 } catch (SoapFaultClientException e) {
  88                         WebServiceUtils.manageSoapException(e);
  89                 } catch (WebServiceIOException e) {
  90                         manageIoException(e);
  91                 }
  92         }
  93
  94         public void setTemplate(WebServiceTemplate template) {
  95                 this.template = template;
  96         }
  97
  98         public void setOnlyOnClose(Boolean onlyOnClose) {
  99                 this.onlyOnClose = onlyOnClose;
 100         }
 101
 102         protected void manageIoException(WebServiceIOException e) {
 103                 if (!cannotConnect) {
 104                         log.error("Cannot connect to " + template.getDefaultUri()
 105                                         + ". Won't try again.", e);
 106                         cannotConnect = true;
 107                 }
 108         }
 109 }