--- /dev/null
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/J2SE-1.5"/>
+ <classpathentry kind="con" path="org.maven.ide.eclipse.MAVEN2_CLASSPATH_CONTAINER"/>
+ <classpathentry kind="output" path="target/classes"/>
+</classpath>
<projects>
</projects>
<buildSpec>
+ <buildCommand>
+ <name>org.eclipse.jdt.core.javabuilder</name>
+ <arguments>
+ </arguments>
+ </buildCommand>
+ <buildCommand>
+ <name>org.maven.ide.eclipse.maven2Builder</name>
+ <arguments>
+ </arguments>
+ </buildCommand>
</buildSpec>
<natures>
+ <nature>org.eclipse.jdt.core.javanature</nature>
+ <nature>org.maven.ide.eclipse.maven2Nature</nature>
</natures>
</projectDescription>
--- /dev/null
+#Tue Apr 28 16:14:04 CEST 2009
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.5
+org.eclipse.jdt.core.compiler.compliance=1.5
+org.eclipse.jdt.core.compiler.source=1.5
--- /dev/null
+#Tue Apr 28 16:13:53 CEST 2009
+activeProfiles=
+eclipse.preferences.version=1
+fullBuildGoals=process-test-resources
+includeModules=false
+resolveWorkspaceProjects=true
+resourceFilterGoals=process-resources resources\:testResources
+skipCompilerPlugin=true
+version=1
<execDir>target/exec/server</execDir>
<jvmArgs>
<jvmArg>-Xmx256m</jvmArg>
- <!--
- <jvmArg>-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=8000</jvmArg>
- -->
</jvmArgs>
+ <debug>0</debug>
<systemProperties>
<slc.osgi.start>
org.argeo.dep.osgi.catalina.start,
org.argeo.slc.webapp,
org.argeo.slc.ria
</slc.osgi.start>
- <slc.server.services.pingCycle>0</slc.server.services.pingCycle>
- <slc.osgiboot.debug>true</slc.osgiboot.debug>
+ <!-- <slc.osgiboot.debug>true</slc.osgiboot.debug>-->
</systemProperties>
</configuration>
</plugin>
org.springframework.osgi.extender,
org.argeo.slc.support.equinox,
org.argeo.slc.agent,
- org.argeo.slc.demo.basic,
- org.argeo.slc.demo.manager
+ org.argeo.slc.demo.basic
</slc.osgi.start>
</systemProperties>
</configuration>
log4j.logger.org.argeo.slc.execution.ExecutionContext=DEBUG
log4j.logger.org.argeo.slc.execution.SimpleExecutionSpec=DEBUG
+log4j.logger.org.argeo.slc.services=DEBUG
+
log4j.logger.org.springframework=WARN
+log4j.logger.org.springframework.jms=WARN
log4j.logger.org.apache.activemq=WARN
log4j.logger.org.apache.activemq.transport=WARN
-log4j.logger.org.apache.activemq.selector=WARN
+log4j.logger.org.apache.activemq.ActiveMQMessageConsumer=INFO
+log4j.logger.org.apache.activemq.ActiveMQMessageProducer=INFO
log4j.logger.org.apache.catalina=INFO
log4j.logger.org.apache.coyote=INFO
info("SLC OSGi bootstrap starting...");
// installUrls(bundleContext, getDevLocationsUrls());
- installUrls(bundleContext, getLocationsUrls());
-
installUrls(bundleContext, getBundlesUrls());
+ installUrls(bundleContext, getLocationsUrls());
+
installUrls(bundleContext, getMavenUrls());
startBundles(bundleContext);
if (installedBundles.containsKey(url)) {
Bundle bundle = installedBundles.get(url);
// bundle.update();
- info("Bundle " + bundle.getSymbolicName()
- + " already installed from " + url);
+ if (debug)
+ debug("Bundle " + bundle.getSymbolicName()
+ + " already installed from " + url);
} else {
Bundle bundle = bundleContext.installBundle(url);
if (debug)
--- /dev/null
+package org.argeo.slc.services;
+
+import org.argeo.slc.SlcException;
+import org.argeo.slc.msg.MsgHandler;
+import org.argeo.slc.msg.process.SlcExecutionStatusRequest;
+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.process.SlcExecution;
+import org.argeo.slc.services.process.SlcExecutionService;
+import org.argeo.slc.services.test.TestManagerService;
+
+public class ServiceMsgHandler implements MsgHandler {
+ private TestManagerService testManagerService;
+ private SlcExecutionService slcExecutionService;
+
+ public Object handleMsg(Object msg) {
+ if (msg instanceof SlcExecution)
+ slcExecutionService.newExecution((SlcExecution) msg);
+ else if (msg instanceof SlcExecutionStatusRequest)
+ slcExecutionService.updateStatus((SlcExecutionStatusRequest) msg);
+ else if (msg instanceof CreateTreeTestResultRequest)
+ testManagerService
+ .createTreeTestResult((CreateTreeTestResultRequest) msg);
+ else if (msg instanceof ResultPartRequest)
+ testManagerService.addResultPart((ResultPartRequest) msg);
+ else if (msg instanceof CloseTreeTestResultRequest)
+ testManagerService
+ .closeTreeTestResult((CloseTreeTestResultRequest) msg);
+ else
+ throw new SlcException("Unrecognized message type " + msg);
+ return null;
+ }
+
+ public void setTestManagerService(TestManagerService testManagerService) {
+ this.testManagerService = testManagerService;
+ }
+
+ public void setSlcExecutionService(SlcExecutionService slcExecutionService) {
+ this.slcExecutionService = slcExecutionService;
+ }
+
+}
for (SlcAgentDescriptor ad : lst)
agentIds.add(ad.getUuid());
- if (log.isDebugEnabled())
+ if (log.isTraceEnabled())
log.debug("Ping " + agentIds.size() + " agent.");
for (String agentId : agentIds) {
SlcAgent agent = agentFactory.getAgent(agentId);
destinationSend = responseDestination;
}
- new Thread() {
- public void run() {
- // Send response
- jmsTemplate.convertAndSend(destinationSend, response,
- new MessagePostProcessor() {
- public Message postProcessMessage(
- Message messageToSend) throws JMSException {
- messageToSend.setStringProperty(PROPERTY_QUERY,
- query);
- messageToSend.setStringProperty(
- PROPERTY_SLC_AGENT_ID, agentDescriptor
- .getUuid());
- messageToSend
- .setJMSCorrelationID(correlationId);
- return messageToSend;
- }
- });
- if (log.isDebugEnabled())
- log.debug("Sent response to query '" + query
- + "' with correlationId " + correlationId);
- }
- }.start();
-
+ // Send response
+ jmsTemplate.convertAndSend(destinationSend, response,
+ new MessagePostProcessor() {
+ public Message postProcessMessage(Message messageToSend)
+ throws JMSException {
+ messageToSend.setStringProperty(PROPERTY_QUERY, query);
+ messageToSend.setStringProperty(PROPERTY_SLC_AGENT_ID,
+ agentDescriptor.getUuid());
+ messageToSend.setJMSCorrelationID(correlationId);
+ return messageToSend;
+ }
+ });
+ if (log.isTraceEnabled())
+ log.debug("Sent response to query '" + query
+ + "' with correlationId " + correlationId);
}
/** @return response */
agentDescriptorToSend.setModuleDescriptors(lst);
return agentDescriptorToSend;
} else if ("runSlcExecution".equals(query)) {
- SlcExecution slcExecution = (SlcExecution) convertFrom(message);
- runSlcExecution(slcExecution);
+ final SlcExecution slcExecution = (SlcExecution) convertFrom(message);
+ new Thread() {
+ public void run() {
+ runSlcExecution(slcExecution);
+ }
+ }.start();
return ExecutionAnswer.ok("Execution started on agent "
+ agentDescriptor.getUuid());
} else if ("ping".equals(query)) {
protected void send(AgentMC messageCreator) {
jmsTemplate.send(requestDestination, messageCreator);
- if (log.isDebugEnabled())
+ if (log.isTraceEnabled())
log.debug("Sent query '" + messageCreator.getQuery()
+ "' with correlationId "
+ messageCreator.getCorrelationId() + " to agent "
else
return null;
}
- if (log.isDebugEnabled())
+ if (log.isTraceEnabled())
log.debug("Received response for query '" + query
+ "' with correlationId " + correlationId + " from agent "
+ agentUuid);
--- /dev/null
+package org.argeo.slc.jms;
+
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageListener;
+
+import org.argeo.slc.SlcException;
+import org.argeo.slc.msg.MsgHandler;
+import org.springframework.jms.support.converter.MessageConverter;
+
+public class JmsExecutionHandler implements MessageListener {
+
+ private MessageConverter messageConverter;
+ private MsgHandler serviceMsgHandler;
+
+ public void onMessage(Message message) {
+ try {
+ serviceMsgHandler.handleMsg(messageConverter.fromMessage(message));
+ } catch (JMSException e) {
+ throw new SlcException("Could not interpret message " + message, e);
+ }
+ }
+
+ public void setMessageConverter(MessageConverter messageConverter) {
+ this.messageConverter = messageConverter;
+ }
+
+ public void setServiceMsgHandler(MsgHandler serviceMsgHandler) {
+ this.serviceMsgHandler = serviceMsgHandler;
+ }
+
+}
private JmsTemplate jmsTemplate;
- private Destination updateStatusDestination;
+ private Destination executionEventDestination;
+ //private Destination updateStatusDestination;
public void updateStatus(SlcExecution slcExecution, String oldStatus,
String newStatus) {
SlcExecutionStatusRequest req = new SlcExecutionStatusRequest(
slcExecution.getUuid(), newStatus);
- jmsTemplate.convertAndSend(updateStatusDestination, req);
+ jmsTemplate.convertAndSend(executionEventDestination, req);
}
public void addSteps(SlcExecution slcExecution,
this.jmsTemplate = jmsTemplate;
}
- public void setUpdateStatusDestination(Destination updateStatusDestination) {
- this.updateStatusDestination = updateStatusDestination;
+ public void setExecutionEventDestination(Destination executionEventDestination) {
+ this.executionEventDestination = executionEventDestination;
}
+
+
+// public void setUpdateStatusDestination(Destination updateStatusDestination) {
+// this.updateStatusDestination = updateStatusDestination;
+// }
+
}
import javax.jms.MessageListener;
import org.argeo.slc.SlcException;
+import org.argeo.slc.msg.MsgHandler;
import org.argeo.slc.process.SlcExecution;
import org.argeo.slc.runtime.SlcAgent;
import org.argeo.slc.runtime.SlcAgentFactory;
public class JmsTransferNewExecution implements MessageListener {
private MessageConverter messageConverter;
private SlcAgentFactory agentFactory;
+ private MsgHandler serviceMsgHandler;
public void onMessage(final Message message) {
try {
agent.runSlcExecution(slcExecution);
}
}.start();
+ serviceMsgHandler.handleMsg(slcExecution);
} catch (Exception e) {
throw new SlcException("Could not transfer new execution "
+ message, e);
this.agentFactory = agentFactory;
}
+ public void setServiceMsgHandler(MsgHandler serviceMsgHandler) {
+ this.serviceMsgHandler = serviceMsgHandler;
+ }
+
}
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) {
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;
}
+
+
+
+// public void setCreateDestination(Destination createDestination) {
+// this.createDestination = createDestination;
+// }
+//
+// public void setAddResultPartDestination(Destination addResultPartDestination) {
+// this.addResultPartDestination = addResultPartDestination;
+// }
+//
+// public void setCloseDestination(Destination closeDestination) {
+// this.closeDestination = closeDestination;
+// }
}
<bean id="slcJms.destination.agent.newExecution" p:physicalName="agent.newExecution"
parent="slcJms.amTopic" />
<bean id="slcJms.destination.agent.request" p:physicalName="agent.request"
- parent="slcJms.amTopic" />
+ parent="slcJms.amQueue" />
<bean id="slcJms.destination.agent.response" p:physicalName="agent.response"
- parent="slcJms.amTopic" />
+ parent="slcJms.amQueue" />
<bean id="slcJms.destination.agent.pingAll" p:physicalName="agent.pingAll"
parent="slcJms.amTopic" />
- <!-- Test result service -->
+ <bean id="slcJms.destination.execution.event" p:physicalName="execution.event"
+ parent="slcJms.amQueue" />
+
+ <!-- Test result service
<bean id="slcJms.destination.test.create" p:physicalName="test.create"
- parent="slcJms.amTopic" />
+ parent="slcJms.amQueue" />
<bean id="slcJms.destination.test.addResultPart" p:physicalName="test.addResultPart"
- parent="slcJms.amTopic" />
+ parent="slcJms.amQueue" />
<bean id="slcJms.destination.test.close" p:physicalName="test.close"
- parent="slcJms.amTopic" />
-
- <!-- TSLC Execution service -->
+ parent="slcJms.amQueue" />
+ -->
+ <!-- TSLC Execution service
<bean id="slcJms.destination.slcExecution.updateStatus"
- p:physicalName="slcExecution.updateStatus" parent="slcJms.amTopic" />
-
+ p:physicalName="slcExecution.updateStatus" parent="slcJms.amQueue" />
+ -->
<!-- Templates -->
<bean id="slcJms.amQueue" class="org.apache.activemq.command.ActiveMQQueue"
abstract="true" />
--- /dev/null
+package org.argeo.slc.msg;
+
+public interface MsgHandler {
+ public Object handleMsg(Object msg);
+}
<import resource="classpath:org/argeo/slc/activemq/spring.xml" />
-
- <bean id="jmsAgent.listener.request"
- class="org.springframework.jms.listener.DefaultMessageListenerContainer">
- <property name="connectionFactory" ref="jmsConnectionFactory" />
+ <bean id="jmsAgent.listener.request" parent="jmsAgent.listener.template">
<property name="destination" ref="slcJms.destination.agent.request" />
- <property name="messageListener" ref="jmsAgent" />
<property name="messageSelector">
<bean factory-bean="jmsAgent" factory-method="getMessageSelector" />
</property>
- <property name="transactionManager" ref="jmsTransactionManager" />
</bean>
- <bean id="jmsAgent.listener.pingAll"
- class="org.springframework.jms.listener.DefaultMessageListenerContainer">
- <property name="connectionFactory" ref="jmsConnectionFactory" />
+ <bean id="jmsAgent.listener.pingAll" parent="jmsAgent.listener.template">
<property name="destination" ref="slcJms.destination.agent.pingAll" />
<property name="messageListener" ref="jmsAgent" />
- <property name="transactionManager" ref="jmsTransactionManager" />
</bean>
<bean id="jmsAgent" class="org.argeo.slc.jms.JmsAgent">
<!-- TreeTestResult Listener -->
<bean id="resultListener" class="org.argeo.slc.jms.JmsTreeTestResultListener">
- <property name="createDestination" ref="slcJms.destination.test.create" />
+ <!-- <property name="createDestination" ref="slcJms.destination.test.create" />
<property name="addResultPartDestination" ref="slcJms.destination.test.addResultPart" />
- <property name="closeDestination" ref="slcJms.destination.test.close" />
+ <property name="closeDestination" ref="slcJms.destination.test.close" /> -->
+ <property name="executionEventDestination" ref="slcJms.destination.execution.event" />
<property name="jmsTemplate" ref="jmsTemplate" />
</bean>
<!-- SLC Execution Listener -->
<bean id="slcExecutionListener" class="org.argeo.slc.jms.JmsSlcExecutionNotifier">
- <property name="updateStatusDestination" ref="slcJms.destination.slcExecution.updateStatus" />
+ <!-- <property name="updateStatusDestination" ref="slcJms.destination.slcExecution.updateStatus" /> -->
<property name="jmsTemplate" ref="jmsTemplate" />
+ <property name="executionEventDestination" ref="slcJms.destination.execution.event" />
</bean>
<!-- Common -->
class="org.springframework.jms.connection.JmsTransactionManager">
<property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>
+
+ <bean id="jmsAgent.listener.template"
+ class="org.springframework.jms.listener.DefaultMessageListenerContainer"
+ abstract="true">
+ <property name="connectionFactory" ref="jmsConnectionFactory" />
+ <property name="messageListener" ref="jmsAgent" />
+ <property name="transactionManager" ref="jmsTransactionManager" />
+ </bean>
+
+
</beans>
\ No newline at end of file
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"
default-lazy-init="false">
+ <bean id="jmsConnectionFactory"
+ class="org.springframework.jms.connection.CachingConnectionFactory">
+ <property name="targetConnectionFactory">
+ <bean class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL">
+ <value>${slc.server.jms.url}</value>
+ </property>
+ </bean>
+ </property>
+ </bean>
+
<!--
<bean id="jmsConnectionFactory"
class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory">
<bean id="slcDefault.jms.amqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL">
- <value>${slc.server.jmsurl}</value>
+ <value>${slc.server.jms.url}</value>
</property>
</bean>
</property>
</bean>
-->
+ <!--
<bean id="jmsConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
destroy-method="stop">
<property name="connectionFactory">
</bean>
</property>
</bean>
-
+ -->
</beans>
\ No newline at end of file
</amq:broker>
<!-- Connection Factory -->
- <bean id="jmsConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
- destroy-method="stop" depends-on="broker">
- <property name="connectionFactory">
+ <!-- -->
+ <bean id="jmsConnectionFactory"
+ class="org.springframework.jms.connection.CachingConnectionFactory">
+ <property name="targetConnectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL">
<value>vm://localhost</value>
</property>
</bean>
+ <!--
+ <bean id="jmsConnectionFactory"
+ class="org.apache.activemq.pool.PooledConnectionFactory"
+ destroy-method="stop" depends-on="broker"> <property
+ name="connectionFactory"> <bean
+ class="org.apache.activemq.ActiveMQConnectionFactory"> <property
+ name="brokerURL"> <value>vm://localhost</value> </property> </bean>
+ </property> </bean>
+ -->
+
<bean id="jmsTransactionManager"
class="org.springframework.jms.connection.JmsTransactionManager">
<property name="connectionFactory" ref="jmsConnectionFactory" />
<tx:method name="*" propagation="REQUIRED" />
</tx:attributes>
</tx:advice>
-<!--
+
<aop:config>
<aop:pointcut id="pointcut.services.allMethods"
expression="execution(* org.argeo.slc.services.*.*.*(..))" />
</aop:config>
<tx:advice id="advice.allMethodsRequired"
- transaction-manager="transactionManager">
+ transaction-manager="hibernateTransactionManager">
<tx:attributes>
<tx:method name="*" propagation="REQUIRED" />
</tx:attributes>
</tx:advice>
- -->
+
</beans>
\ No newline at end of file
<bean class="org.argeo.slc.jms.JmsTransferNewExecution">
<property name="messageConverter" ref="slcDefault.jms.castorMessageConverter" />
<property name="agentFactory" ref="agentFactory" />
+ <property name="serviceMsgHandler">
+ <bean class="org.argeo.slc.services.ServiceMsgHandler">
+ <property name="slcExecutionService" ref="slcExecutionService" />
+ </bean>
+ </property>
</bean>
</property>
</bean>
- <!-- Test Manager Service -->
<bean parent="listenerContainer">
- <property name="destination" ref="slcJms.destination.test.create" />
+ <property name="destination" ref="slcJms.destination.execution.event" />
<property name="messageListener">
- <bean parent="listenerAdapterCastor">
- <constructor-arg ref="testManagerService" />
- <property name="defaultListenerMethod" value="createTreeTestResult" />
- </bean>
- </property>
- </bean>
-
- <bean parent="listenerContainer">
- <property name="destination" ref="slcJms.destination.test.addResultPart" />
- <property name="messageListener">
- <bean parent="listenerAdapterCastor">
- <constructor-arg ref="testManagerService" />
- <property name="defaultListenerMethod" value="addResultPart" />
- </bean>
- </property>
- </bean>
-
- <bean parent="listenerContainer">
- <property name="destination" ref="slcJms.destination.test.close" />
- <property name="messageListener">
- <bean parent="listenerAdapterCastor">
- <constructor-arg ref="testManagerService" />
- <property name="defaultListenerMethod" value="closeTreeTestResult" />
- </bean>
- </property>
- </bean>
-
- <!-- SLC Execution Service -->
- <bean parent="listenerContainer">
- <property name="destination" ref="slcJms.destination.agent.newExecution" />
- <property name="messageListener">
- <bean parent="listenerAdapterCastor">
- <constructor-arg ref="slcExecutionService" />
- <property name="defaultListenerMethod" value="newExecution" />
+ <bean class="org.argeo.slc.jms.JmsExecutionHandler">
+ <property name="messageConverter" ref="slcDefault.jms.castorMessageConverter" />
+ <property name="serviceMsgHandler">
+ <bean class="org.argeo.slc.services.ServiceMsgHandler">
+ <property name="slcExecutionService" ref="slcExecutionService" />
+ <property name="testManagerService" ref="testManagerService" />
+ </bean>
+ </property>
</bean>
</property>
</bean>
- <bean parent="listenerContainer">
- <property name="destination" ref="slcJms.destination.slcExecution.updateStatus" />
- <property name="messageListener">
- <bean parent="listenerAdapterCastor">
- <constructor-arg ref="slcExecutionService" />
- <property name="defaultListenerMethod" value="updateStatus" />
- </bean>
- </property>
- </bean>
+ <!--
+ Test Manager Service <bean parent="listenerContainer"> <property
+ name="destination" ref="slcJms.destination.test.create" /> <property
+ name="messageListener"> <bean parent="listenerAdapterCastor">
+ <constructor-arg ref="testManagerService" /> <property
+ name="defaultListenerMethod" value="createTreeTestResult" /> </bean>
+ </property> </bean> <bean parent="listenerContainer"> <property
+ name="destination" ref="slcJms.destination.test.addResultPart" />
+ <property name="messageListener"> <bean
+ parent="listenerAdapterCastor"> <constructor-arg
+ ref="testManagerService" /> <property name="defaultListenerMethod"
+ value="addResultPart" /> </bean> </property> </bean> <bean
+ parent="listenerContainer"> <property name="destination"
+ ref="slcJms.destination.test.close" /> <property
+ name="messageListener"> <bean parent="listenerAdapterCastor">
+ <constructor-arg ref="testManagerService" /> <property
+ name="defaultListenerMethod" value="closeTreeTestResult" /> </bean>
+ </property> </bean>
+ -->
+ <!--
+ SLC Execution Service <bean parent="listenerContainer"> <property
+ name="destination" ref="slcJms.destination.agent.newExecution" />
+ <property name="messageListener"> <bean
+ parent="listenerAdapterCastor"> <constructor-arg
+ ref="slcExecutionService" /> <property name="defaultListenerMethod"
+ value="newExecution" /> </bean> </property> </bean> <bean
+ parent="listenerContainer"> <property name="destination"
+ ref="slcJms.destination.slcExecution.updateStatus" /> <property
+ name="messageListener"> <bean parent="listenerAdapterCastor">
+ <constructor-arg ref="slcExecutionService" /> <property
+ name="defaultListenerMethod" value="updateStatus" /> </bean>
+ </property> </bean>
+ -->
<!-- Templates -->
<bean id="listenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer"
abstract="true">
<property name="connectionFactory" ref="jmsConnectionFactory" />
- <property name="transactionManager" ref="jmsTransactionManager" />
+ <!--
+ <property name="transactionManager" ref="jmsTransactionManager" />
+ -->
</bean>
<bean id="listenerAdapterCastor"
-slc.server.services.pingCycle=0
\ No newline at end of file
+slc.server.services.pingCycle=60000
\ No newline at end of file
projects / gpl / argeo-slc.git / commitdiff