import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.argeo.slc.SlcException;
+import org.argeo.slc.core.attachment.Attachment;
+import org.argeo.slc.core.attachment.SimpleAttachment;
import org.argeo.slc.core.test.tree.TreeTestResult;
+import org.argeo.slc.core.test.tree.TreeTestResultListener;
+import org.argeo.slc.msg.test.tree.AddTreeTestResultAttachmentRequest;
import org.argeo.slc.msg.test.tree.CloseTreeTestResultRequest;
import org.argeo.slc.msg.test.tree.CreateTreeTestResultRequest;
import org.argeo.slc.msg.test.tree.ResultPartRequest;
import org.argeo.slc.test.TestResultPart;
import org.springframework.jms.core.JmsTemplate;
-public class JmsTreeTestResultListener implements
- TestResultListener<TreeTestResult> {
+public class JmsTreeTestResultListener implements TreeTestResultListener {
private final Log log = LogFactory.getLog(getClass());
private Boolean onlyOnClose = false;
private JmsTemplate jmsTemplate;
- private Destination createDestination;
- private Destination addResultPartDestination;
- private Destination closeDestination;
+ private Destination executionEventDestination;
+
+ // private Destination createDestination;
+ // private Destination addResultPartDestination;
+ // private Destination closeDestination;
public void resultPartAdded(TreeTestResult testResult,
TestResultPart testResultPart) {
log.debug("Send create result request for result "
+ testResult.getUuid());
- jmsTemplate.convertAndSend(createDestination, req);
+ jmsTemplate.convertAndSend(executionEventDestination, req);
} else {
ResultPartRequest req = new ResultPartRequest(testResult);
log.debug("Send result parts for result "
+ testResult.getUuid());
- jmsTemplate.convertAndSend(addResultPartDestination, req);
+ jmsTemplate.convertAndSend(executionEventDestination, req);
}
} catch (Exception e) {
throw new SlcException("Could not notify to JMS", e);
log.debug("Send create result request for result "
+ testResult.getUuid());
- jmsTemplate.convertAndSend(createDestination, req);
+ jmsTemplate.convertAndSend(executionEventDestination, req);
} else {
CloseTreeTestResultRequest req = new CloseTreeTestResultRequest(
testResult);
log.debug("Send close result request for result "
+ testResult.getUuid());
- jmsTemplate.convertAndSend(closeDestination, req);
+ jmsTemplate.convertAndSend(executionEventDestination, req);
}
} catch (Exception e) {
}
}
+ public void addAttachment(TreeTestResult testResult, Attachment attachment) {
+ try {
+ AddTreeTestResultAttachmentRequest req = new AddTreeTestResultAttachmentRequest();
+ req.setResultUuid(testResult.getUuid());
+ req.setAttachment((SimpleAttachment) attachment);
+ jmsTemplate.convertAndSend(executionEventDestination, req);
+
+ } catch (Exception e) {
+ throw new SlcException("Could not notify to JMS", e);
+ }
+
+ }
+
public void setOnlyOnClose(Boolean onlyOnClose) {
this.onlyOnClose = onlyOnClose;
}
this.jmsTemplate = jmsTemplate;
}
- public void setCreateDestination(Destination createDestination) {
- this.createDestination = createDestination;
- }
-
- public void setAddResultPartDestination(Destination addResultPartDestination) {
- this.addResultPartDestination = addResultPartDestination;
- }
-
- public void setCloseDestination(Destination closeDestination) {
- this.closeDestination = closeDestination;
+ public void setExecutionEventDestination(
+ Destination executionEventDestination) {
+ this.executionEventDestination = executionEventDestination;
}
}