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=f198cdf84f9c6b5312825672450f92bc8451ede3;hp=ac4851517836dea4d2285298fe1d229b3081a635;hpb=63799a559f90483285001a6807ea2f1df120bf37;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 ac4851517..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 @@ -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; + } + }