X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.slc.detached%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fdetached%2Fdrivers%2FAbstractDriver.java;h=6d8e5ac8f8368ba33133fb78873cdd9c3937c521;hb=ea2228c662a90cd28086f281a394fb3a3a0f860f;hp=8ba2de1fad18f60c25ef24d673c6eebcd483106d;hpb=62bca43d2a0ecc773977dbc408644a140d5f5234;p=gpl%2Fargeo-slc.git 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 8ba2de1fa..6d8e5ac8f 100644 --- 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; + } + }