Use Equinox and Spring OSGi for SLC Detached

[gpl/argeo-slc.git] / org.argeo.slc.detached / src / main / java / org / argeo / slc / detached / drivers / AbstractDriver.java

diff --git a/org.argeo.slc.detached/src/main/java/org/argeo/slc/detached/drivers/AbstractDriver.java b/org.argeo.slc.detached/src/main/java/org/argeo/slc/detached/drivers/AbstractDriver.java
index ac4851517836dea4d2285298fe1d229b3081a635..6d8e5ac8f8368ba33133fb78873cdd9c3937c521 100644 (file)
--- a/org.argeo.slc.detached/src/main/java/org/argeo/slc/detached/drivers/AbstractDriver.java
+++ b/org.argeo.slc.detached/src/main/java/org/argeo/slc/detached/drivers/AbstractDriver.java
@@ -4,10 +4,14 @@ import org.argeo.slc.detached.DetachedAnswer;
 import org.argeo.slc.detached.DetachedDriver;
 import org.argeo.slc.detached.DetachedExecutionServer;
 import org.argeo.slc.detached.DetachedRequest;
+import org.argeo.slc.detached.DetachedXmlConverter;
 
 public abstract class AbstractDriver implements DetachedDriver {
        private boolean active = true;
        private DetachedExecutionServer executionServer = null;
+       private long receiveAnswerTimeout = 10000l;
+
+       private DetachedXmlConverter xmlConverter = null;
 
        public synchronized void start() {
 
@@ -20,7 +24,7 @@ public abstract class AbstractDriver implements DetachedDriver {
                                                if (!active)
                                                        break;
                                                DetachedAnswer answer = executionServer
-                                                               .executeStep(request);
+                                                               .executeRequest(request);
                                                sendAnswer(answer);
                                        } catch (Exception e) {
                                                if (e instanceof RuntimeException)
@@ -31,7 +35,7 @@ public abstract class AbstractDriver implements DetachedDriver {
                                }
 
                        }
-               }, "driverThread");
+               }, "driverThread ("+getClass()+")");
                driverThread.start();
 
        }
@@ -53,4 +57,20 @@ public abstract class AbstractDriver implements DetachedDriver {
                this.active = active;
        }
 
+       public DetachedXmlConverter getXmlConverter() {
+               return xmlConverter;
+       }
+
+       public void setXmlConverter(DetachedXmlConverter xmlConverter) {
+               this.xmlConverter = xmlConverter;
+       }
+
+       public long getReceiveAnswerTimeout() {
+               return receiveAnswerTimeout;
+       }
+
+       public void setReceiveAnswerTimeout(long reveiveTimeout) {
+               this.receiveAnswerTimeout = reveiveTimeout;
+       }
+
 }