Author: indika
Date: Mon Feb 23 11:02:14 2009
New Revision: 746959
URL: http://svn.apache.org/viewvc?rev=746959&view=rev
Log:
minor improvements ... some null check ..
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConfigurationFactoryAndSerializerFinder.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ExtensionDeployer.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/SynapseCallbackReceiver.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/GetPropertyFunction.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/AnnotatedCommandMediator.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/POJOCommandMediator.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/RegistryEntryImpl.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartzFactory.java
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/ServerManager.java
Mon Feb 23 11:02:14 2009
@@ -110,7 +110,7 @@
for (Object o :
configctx.getAxisConfiguration().getTransportsIn().keySet()) {
String trp = (String) o;
- TransportInDescription trsIn = (TransportInDescription)
+ TransportInDescription trsIn =
configctx.getAxisConfiguration().getTransportsIn().get(trp);
String msg = "Starting transport " + trsIn.getName();
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/Entry.java
Mon Feb 23 11:02:14 2009
@@ -121,8 +121,9 @@
}
/**
+ * Set the mapper
*
- * @param mapper
+ * @param mapper XMLToObjectMapper instance
*/
public void setMapper(XMLToObjectMapper mapper) {
this.mapper = mapper;
@@ -145,11 +146,8 @@
}
public boolean isExpired() {
- if (getType() == REMOTE_ENTRY && getExpiryTime() > 0) {
- return System.currentTimeMillis() > expiryTime;
- } else {
- return false;
- }
+ return getType() == REMOTE_ENTRY && getExpiryTime() > 0
+ && System.currentTimeMillis() > expiryTime;
}
public boolean isCached() {
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConfigurationFactoryAndSerializerFinder.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConfigurationFactoryAndSerializerFinder.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConfigurationFactoryAndSerializerFinder.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConfigurationFactoryAndSerializerFinder.java
Mon Feb 23 11:02:14 2009
@@ -145,7 +145,7 @@
if (log.isDebugEnabled()) {
log.debug("getConfiguration(" + qName + ")");
}
- Class cls = (Class) factoryMap.get(qName);
+ Class cls = factoryMap.get(qName);
if (cls == null) {
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ExtensionDeployer.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ExtensionDeployer.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ExtensionDeployer.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ExtensionDeployer.java
Mon Feb 23 11:02:14 2009
@@ -202,11 +202,4 @@
}
throw new DeploymentException(message, e);
}
-
- private void handleException(String message) throws DeploymentException {
- if (log.isDebugEnabled()) {
- log.debug(message);
- }
- throw new DeploymentException(message);
- }
}
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java
Mon Feb 23 11:02:14 2009
@@ -194,7 +194,7 @@
/**
* Set reference to actual proxy service
- * @param proxy
+ * @param proxy ProxyService instance
*/
public void setProxy(ProxyService proxy) {
this.proxy = proxy;
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/SynapseCallbackReceiver.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/SynapseCallbackReceiver.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/SynapseCallbackReceiver.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/SynapseCallbackReceiver.java
Mon Feb 23 11:02:14 2009
@@ -194,7 +194,8 @@
if (log.isDebugEnabled()) {
log.debug("[Failed Request Message ID : " + messageID +
"]" +
- " [New to be Retried Request Message ID : " +
synapseOutMsgCtx.getMessageID() + "]");
+ " [New to be Retried Request Message ID : " +
+ synapseOutMsgCtx.getMessageID() + "]");
}
((FaultHandler)
faultStack.pop()).handleFault(synapseOutMsgCtx, null);
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseSubscriptionManager.java
Mon Feb 23 11:02:14 2009
@@ -32,7 +32,7 @@
*/
public abstract class SynapseSubscriptionManager implements
SubscriptionManager {
- private Map<String, String> properties = new HashMap<String, String>();
+ private final Map<String, String> properties = new HashMap<String,
String>();
/**
* Return all Active subscriptions
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/managers/DefaultInMemorySubscriptionManager.java
Mon Feb 23 11:02:14 2009
@@ -42,7 +42,7 @@
*/
public class DefaultInMemorySubscriptionManager extends
SynapseSubscriptionManager {
- private Map<String, SynapseSubscription> store =
+ private final Map<String, SynapseSubscription> store =
new ConcurrentHashMap<String, SynapseSubscription>();
private String topicHeaderName;
private String topicHeaderNS;
@@ -91,11 +91,13 @@
}
public List<SynapseSubscription> getMatchingSubscribers(MessageContext mc)
{
- LinkedList<SynapseSubscription> list = new
LinkedList<SynapseSubscription>();
+ final LinkedList<SynapseSubscription> list = new
LinkedList<SynapseSubscription>();
for (Map.Entry<String, SynapseSubscription> stringSubscriptionEntry :
store.entrySet()) {
XPathBasedEventFilter filter =
(XPathBasedEventFilter)
stringSubscriptionEntry.getValue().getSynapseFilter();
- filter.setSourceXpath(topicXPath);
+ if (filter != null) {
+ filter.setSourceXpath(topicXPath);
+ }
if (filter == null || filter.isSatisfied(mc)) {
SynapseSubscription subscription =
stringSubscriptionEntry.getValue();
Calendar current = Calendar.getInstance(); //Get current date
and time
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/GetPropertyFunction.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/GetPropertyFunction.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/GetPropertyFunction.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/GetPropertyFunction.java
Mon Feb 23 11:02:14 2009
@@ -34,7 +34,6 @@
import org.jaxen.Navigator;
import org.jaxen.function.StringFunction;
-import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.text.Format;
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java
Mon Feb 23 11:02:14 2009
@@ -20,7 +20,6 @@
package org.apache.synapse.mediators;
import org.apache.synapse.*;
-import org.apache.synapse.core.axis2.Axis2MessageContext;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/AnnotatedCommandMediator.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/AnnotatedCommandMediator.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/AnnotatedCommandMediator.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/AnnotatedCommandMediator.java
Mon Feb 23 11:02:14 2009
@@ -22,6 +22,7 @@
import org.apache.synapse.Command;
import org.apache.synapse.MessageContext;
import org.apache.synapse.SynapseLog;
+import org.apache.synapse.commons.util.PropertyHelper;
import org.apache.synapse.mediators.annotations.Namespaces;
import org.apache.synapse.mediators.annotations.ReadAndUpdate;
import org.apache.synapse.mediators.annotations.ReadFromMessage;
@@ -72,9 +73,10 @@
synLog.traceOrDebug("Instance created, setting static and dynamic
properties");
// then set the static/constant properties first
- for (Iterator iter = getStaticSetterProperties().keySet().iterator();
iter.hasNext(); ) {
+ for (Iterator iter = getStaticSetterProperties().keySet().iterator();
iter.hasNext();) {
String name = (String) iter.next();
- setInstanceProperty(name, (String)
getStaticSetterProperties().get(name), commandObject, synCtx);
+ PropertyHelper.setInstanceProperty(name,
getStaticSetterProperties().get(name),
+ commandObject);
}
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/POJOCommandMediator.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/POJOCommandMediator.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/POJOCommandMediator.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/ext/POJOCommandMediator.java
Mon Feb 23 11:02:14 2009
@@ -20,11 +20,11 @@
package org.apache.synapse.mediators.ext;
import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMNode;
import org.apache.synapse.Command;
import org.apache.synapse.MessageContext;
import org.apache.synapse.SynapseLog;
+import org.apache.synapse.commons.util.PropertyHelper;
import org.apache.synapse.mediators.AbstractMediator;
import org.apache.synapse.mediators.eip.EIPUtils;
import org.apache.synapse.util.xpath.SynapseXPath;
@@ -118,21 +118,20 @@
// then set the static/constant properties first
for (String name : staticSetterProperties.keySet()) {
- setInstanceProperty(name, staticSetterProperties.get(name),
commandObject, synCtx);
+ PropertyHelper.setInstanceProperty(name,
staticSetterProperties.get(name), commandObject);
}
// now set the any dynamic properties from the message context
properties
for (String name : contextSetterProperties.keySet()) {
- setInstanceProperty(name,
synCtx.getProperty(contextSetterProperties.get(name)),
- commandObject, synCtx);
+ PropertyHelper.setInstanceProperty(name,
synCtx.getProperty(contextSetterProperties.get(name)),
+ commandObject);
}
// now set the any dynamic properties evaluating XPath's on the
current message
for (String name : messageSetterProperties.keySet()) {
SynapseXPath xpath = messageSetterProperties.get(name);
String value = xpath.stringValueOf(synCtx);
-
- setInstanceProperty(name, value, commandObject, synCtx);
+ PropertyHelper.setInstanceProperty(name, value, commandObject);
}
synLog.traceOrDebug("POJO initialized successfully, invoking the
execute() method");
@@ -148,10 +147,9 @@
} else {
- Method exeMethod = null;
try {
- exeMethod = command.getMethod("execute", new Class[]{});
- exeMethod.invoke(commandObject, new Object[]{});
+ Method exeMethod = command.getMethod("execute");
+ exeMethod.invoke(commandObject);
} catch (NoSuchMethodException e) {
handleException("Cannot locate an execute() method on POJO
class : " +
command.getClass(), e, synCtx);
@@ -235,85 +233,6 @@
return null;
}
- /**
- * Find and invoke the setter method with the name of form setXXX passing
in the value given
- * on the POJO object
- *
- * @param name name of the setter field
- * @param value value to be set
- * @param obj POJO instance
- * @param synCtx current message
- */
- protected void setInstanceProperty(
- String name, Object value, Object obj, MessageContext synCtx) {
-
- String mName = "set" + Character.toUpperCase(name.charAt(0)) +
name.substring(1);
- Method method = null;
-
- try {
- Method[] methods = obj.getClass().getMethods();
- boolean invoked = false;
-
- for (int i=0; i<methods.length; i++) {
- if (mName.equals(methods[i].getName())) {
- Class[] params = methods[i].getParameterTypes();
- if (params.length != 1) {
- handleException("Did not find a setter method named :
" + mName +
- "() that takes a single String, int, long, float,
double " +
- "or boolean or OMElement parameter", synCtx);
- } else if (value instanceof String) {
- if (params[0].equals(String.class)) {
- method = obj.getClass().getMethod(mName, new
Class[]{String.class});
- method.invoke(obj, new String[]{(String) value});
- } else if (params[0].equals(int.class)) {
- method = obj.getClass().getMethod(mName, new
Class[]{int.class});
- method.invoke(obj, new Integer[]{new
Integer((String) value)});
- } else if (params[0].equals(long.class)) {
- method = obj.getClass().getMethod(mName, new
Class[]{long.class});
- method.invoke(obj, new Long[]{new Long((String)
value)});
- } else if (params[0].equals(float.class)) {
- method = obj.getClass().getMethod(mName, new
Class[]{float.class});
- method.invoke(obj, new Float[]{new Float((String)
value)});
- } else if (params[0].equals(double.class)) {
- method = obj.getClass().getMethod(mName, new
Class[]{double.class});
- method.invoke(obj, new Double[]{new
Double((String) value)});
- } else if (params[0].equals(boolean.class)) {
- method = obj.getClass().getMethod(mName, new
Class[]{boolean.class});
- method.invoke(obj, new Boolean[]{new
Boolean((String) value)});
- } else {
- handleException("Did not find a setter method
named : " + mName +
- "() that takes a single String, int, long,
float, double " +
- "or boolean parameter", synCtx);
- }
- } else if (value instanceof OMElement) {
- if (params[0].equals(OMElement.class)) {
- method = obj.getClass().getMethod(mName, new
Class[]{OMElement.class});
- method.invoke(obj, new OMElement[]{(OMElement)
value});
- } else {
- handleException("Did not find a setter method
named : " + mName
- + "() that takes an OMElement as the
parameter", synCtx);
- }
- } else {
- handleException("Can not handle the value type : "
- + value.getClass(), synCtx);
- }
- invoked = true;
- }
- }
-
- if (!invoked) {
- handleException("Did not find a setter method named : " +
mName +
- "() that takes a single String, int, long, float, double "
+
- "or boolean parameter", synCtx);
- }
-
- } catch (Exception e) {
- handleException("Error invoking setter method named : " + mName +
- "() that takes a single String, int, long, float, double " +
- "or boolean parameter", e, synCtx);
- }
- }
-
public Class getCommand() {
return command;
}
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/RegistryEntryImpl.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/RegistryEntryImpl.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/RegistryEntryImpl.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/registry/RegistryEntryImpl.java
Mon Feb 23 11:02:14 2009
@@ -116,15 +116,15 @@
public String toString() {
StringBuffer sb = new StringBuffer();
sb.append("RegistryEntry {")
- .append(" Key : " + key)
- .append(" Name : " + name)
- .append(" Ver : " + version)
- .append(" Type : " + type)
- .append(" Desc : " + description)
- .append(" Created : " + new Date(created))
- .append(" Modified : " + new Date(lastModified))
- .append(" Cacheable for : " + (cachableDuration / 1000) + "sec")
- .append("}");
+ .append(" Key : ").append(key)
+ .append(" Name : ").append(name)
+ .append(" Version : ").append(version)
+ .append(" Type : ").append(type)
+ .append(" Description : ").append(description)
+ .append(" Created : ").append(new Date(created))
+ .append(" Modified : ").append(new Date(lastModified))
+ .append(" Cacheable for : ").append(cachableDuration / 1000)
+ .append("sec").append("}");
return sb.toString();
}
}
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java
Mon Feb 23 11:02:14 2009
@@ -24,6 +24,7 @@
import org.apache.synapse.ServerManager;
import org.apache.synapse.SynapseConstants;
import org.apache.synapse.SynapseException;
+import org.apache.synapse.config.SynapseConfiguration;
import org.apache.synapse.core.SynapseEnvironment;
import org.apache.synapse.startup.AbstractStartup;
import org.apache.synapse.task.TaskDescription;
@@ -85,7 +86,8 @@
handleException("TaskDescription is null");
}
- repository =
synapseEnvironment.getSynapseConfiguration().getTaskDescriptionRepository();
+ SynapseConfiguration synapseConfiguration =
synapseEnvironment.getSynapseConfiguration();
+ repository = synapseConfiguration.getTaskDescriptionRepository();
if (repository == null) {
handleException("Task Description Repository can not found");
@@ -118,7 +120,8 @@
List pinnedServers = taskDescription.getPinnedServers();
if (pinnedServers != null && !pinnedServers.isEmpty()) {
if (!pinnedServers.contains(thisServerName)) {
- log.info("Server name not in pinned servers list. Not starting
Task : " + getName());
+ log.info("Server name not in pinned servers list. Not starting
Task : " +
+ getName());
return;
}
}
@@ -132,7 +135,7 @@
SynapseConstants.SYNAPSE_STARTUP_TASK_SCHEDULER);
if (taskScheduler != null) {
if (!taskScheduler.isInitialized()) {
-
taskScheduler.init(synapseEnvironment.getSynapseConfiguration().getProperties());
+ taskScheduler.init(synapseConfiguration.getProperties());
}
taskScheduler.scheduleTask(taskDescription, map,
SimpleQuartzJob.class);
} else {
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartzFactory.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartzFactory.java?rev=746959&r1=746958&r2=746959&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartzFactory.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartzFactory.java
Mon Feb 23 11:02:14 2009
@@ -59,7 +59,8 @@
SimpleQuartz simpleQuartz = new SimpleQuartz();
TaskDescription taskDescription =
- TaskDescriptionFactory.createTaskDescription(el,
XMLConfigConstants.SYNAPSE_OMNAMESPACE);
+ TaskDescriptionFactory.createTaskDescription(el,
+ XMLConfigConstants.SYNAPSE_OMNAMESPACE);
if(taskDescription == null){
handleException("Invalid task - Task description can not be
created form :"+el);
}
