Adds timeout to the seda recurse.

acrepo-exts-ore/src/main/cfg/edu.amherst.acdc.exts.ore.cfg

@@ -5,6 +5,8 @@ rest.prefix=/ore
 
 # Concurrency level (this MUST be > 1)
 ore.concurrency=10
+# seda timeout (milliseconds) (0 = disabled)
+ore.timeout=30000
 
 # Repository Base URL (it MUST start with http:// or https://)
 fcrepo.baseUrl=http://localhost:8080/fcrepo/rest

acrepo-exts-ore/src/main/java/edu/amherst/acdc/exts/ore/OreRouter.java

@@ -75,7 +75,8 @@ public class OreRouter extends RouteBuilder {
           })
           .to("direct:serialize");
 
-        from("seda:recurse?concurrentConsumers={{ore.concurrency}}").routeId("OreBuildRecursive")
+        from("seda:recurse?concurrentConsumers={{ore.concurrency}}&timeout={{ore.timeout}}")
+          .routeId("OreBuildRecursive")
           .setHeader(FCREPO_URI, body())
           .to("direct:getResource")
           .filter(header(HTTP_RESPONSE_CODE).isEqualTo(200))

acrepo-exts-ore/src/main/resources/OSGI-INF/blueprint/blueprint.xml

@@ -14,6 +14,7 @@
        <cm:property name="rest.prefix" value="/ore"/>
        <cm:property name="rest.host" value="localhost"/>
        <cm:property name="ore.concurrency" value="10"/>
+       <cm:property name="ore.timeout" value="30000"/>
        <cm:property name="fcrepo.baseUrl" value="http://localhost:8080/fcrepo/rest"/>
        <cm:property name="fcrepo.authUsername" value=""/>
        <cm:property name="fcrepo.authPassword" value=""/>