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 8ba2de1fad18f60c25ef24d673c6eebcd483106d..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
@@ -9,6 +9,7 @@ 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;
 
@@ -23,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)
@@ -34,7 +35,7 @@ public abstract class AbstractDriver implements DetachedDriver {
                                }
 
                        }
-               }, "driverThread");
+               }, "driverThread ("+getClass()+")");
                driverThread.start();
 
        }
@@ -64,4 +65,12 @@ public abstract class AbstractDriver implements DetachedDriver {
                this.xmlConverter = xmlConverter;
        }
 
+       public long getReceiveAnswerTimeout() {
+               return receiveAnswerTimeout;
+       }
+
+       public void setReceiveAnswerTimeout(long reveiveTimeout) {
+               this.receiveAnswerTimeout = reveiveTimeout;
+       }
+
 }