X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.support.activemq%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjms%2FJmsTreeTestResultListener.java;fp=runtime%2Forg.argeo.slc.support.activemq%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjms%2FJmsTreeTestResultListener.java;h=0000000000000000000000000000000000000000;hb=868102c0f0220e12eca836b6ec9b3a2b9a3441e4;hp=2cd88c49017570fdacf5005a5afab87d9a226ffc;hpb=a5b25ca3e5efc8de3571993f6bfc1671c0e2f3ba;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTreeTestResultListener.java b/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTreeTestResultListener.java
deleted file mode 100644
index 2cd88c490..000000000
--- a/runtime/org.argeo.slc.support.activemq/src/main/java/org/argeo/slc/jms/JmsTreeTestResultListener.java
+++ /dev/null
@@ -1,148 +0,0 @@
-/*
- * Copyright (C) 2007-2012 Mathieu Baudier
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.argeo.slc.jms;
-
-import javax.jms.Destination;
-
-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.JmsException;
-import org.springframework.jms.core.JmsTemplate;
-
-/** JMS based tree test result listener implementation. */
-public class JmsTreeTestResultListener implements TreeTestResultListener {
-	private final Log log = LogFactory.getLog(getClass());
-
-	private Boolean onlyOnClose = false;
-	private JmsTemplate jmsTemplate;
-
-	private Destination executionEventDestination;
-
-	public void resultPartAdded(TreeTestResult testResult,
-			TestResultPart testResultPart) {
-		if (onlyOnClose)
-			return;
-
-		try {
-			if (testResult.getResultParts().size() == 1
-					&& testResult.getResultParts().values().iterator().next()
-							.getParts().size() == 1) {
-				CreateTreeTestResultRequest req = new CreateTreeTestResultRequest(
-						testResult);
-
-				if (log.isTraceEnabled())
-					log.trace("Send create result request for result "
-							+ testResult.getUuid());
-
-				jmsTemplate.convertAndSend(executionEventDestination, req);
-			} else {
-				ResultPartRequest req = new ResultPartRequest(testResult);
-
-				if (log.isTraceEnabled())
-					log.trace("Send result parts for result "
-							+ testResult.getUuid());
-
-				jmsTemplate.convertAndSend(executionEventDestination, req);
-			}
-		} catch (JmsException e) {
-			log.warn("Could not notify result part to server: "
-					+ e.getMessage());
-			if (log.isTraceEnabled())
-				log.debug("Original error.", e);
-		} catch (Exception e) {
-			throw new SlcException("Could not notify to JMS", e);
-		}
-	}
-
-	public void close(TreeTestResult testResult) {
-		try {
-			if (onlyOnClose) {
-				CreateTreeTestResultRequest req = new CreateTreeTestResultRequest(
-						testResult);
-
-				if (log.isTraceEnabled())
-					log.trace("Send onClose create result request for result "
-							+ testResult.getUuid());
-
-				jmsTemplate.convertAndSend(executionEventDestination, req);
-			} else {
-				CloseTreeTestResultRequest req = new CloseTreeTestResultRequest(
-						testResult);
-
-				if (log.isTraceEnabled())
-					log.trace("Send close result request for result "
-							+ testResult.getUuid());
-
-				jmsTemplate.convertAndSend(executionEventDestination, req);
-
-			}
-		} catch (JmsException e) {
-			log.warn("Could not notify result close to server: "
-					+ e.getMessage());
-			if (log.isTraceEnabled())
-				log.debug("Original error.", e);
-		} catch (Exception e) {
-			throw new SlcException("Could not notify to JMS", e);
-		}
-	}
-
-	public void addAttachment(TreeTestResult testResult, Attachment attachment) {
-		if (onlyOnClose)
-			return;
-
-		try {
-			AddTreeTestResultAttachmentRequest req = new AddTreeTestResultAttachmentRequest();
-			req.setResultUuid(testResult.getUuid());
-			req.setAttachment((SimpleAttachment) attachment);
-			jmsTemplate.convertAndSend(executionEventDestination, req);
-
-		} catch (JmsException e) {
-			log
-					.warn("Could not notify attachment to server: "
-							+ e.getMessage());
-			if (log.isTraceEnabled())
-				log.debug("Original error.", e);
-		} catch (Exception e) {
-			throw new SlcException("Could not notify to JMS", e);
-		}
-
-	}
-
-	/** Publishes the test result only when it gets closed. */
-	public void setOnlyOnClose(Boolean onlyOnClose) {
-		this.onlyOnClose = onlyOnClose;
-	}
-
-	public void setJmsTemplate(JmsTemplate jmsTemplate) {
-		this.jmsTemplate = jmsTemplate;
-	}
-
-	public void setExecutionEventDestination(
-			Destination executionEventDestination) {
-		this.executionEventDestination = executionEventDestination;
-	}
-
-}