diff --git a/joram/joram/client/jms/src/main/java/org/objectweb/joram/client/jms/admin/RestAcquisitionQueue.java b/joram/joram/client/jms/src/main/java/org/objectweb/joram/client/jms/admin/RestAcquisitionQueue.java index ed38b60fb7dd436d2371e695656786f1de7f514f..01231eb181e932da05f7e89110b67186598f3f6a 100644 --- a/joram/joram/client/jms/src/main/java/org/objectweb/joram/client/jms/admin/RestAcquisitionQueue.java +++ b/joram/joram/client/jms/src/main/java/org/objectweb/joram/client/jms/admin/RestAcquisitionQueue.java @@ -64,7 +64,8 @@ public class RestAcquisitionQueue { private String password = "anonymous"; private boolean mediaTypeJson = true; private long timeout = 10000; - private int acquisitionPeriod = 100; // TODO (AF): Normally not needed with asynchronous acquisition. + // This attribute below is only needed with timed acquisition. + private int acquisitionPeriod = -1; // Normally each consumer resource need to be explicitly closed, this parameter allows to set the idle time // in seconds in which the consumer context will be closed if idle. private long idleTimeout = 60; diff --git a/joram/joram/client/jms/src/main/java/org/objectweb/joram/client/jms/admin/RestDistributionQueue.java b/joram/joram/client/jms/src/main/java/org/objectweb/joram/client/jms/admin/RestDistributionQueue.java index b2b597dbd8ef7745c0b70e276f495ee61da2257c..6891dfd6c4297b28004110efd026bc0291395940 100644 --- a/joram/joram/client/jms/src/main/java/org/objectweb/joram/client/jms/admin/RestDistributionQueue.java +++ b/joram/joram/client/jms/src/main/java/org/objectweb/joram/client/jms/admin/RestDistributionQueue.java @@ -63,7 +63,7 @@ public class RestDistributionQueue { private boolean batch = true; private boolean async = true; private int period = 1000; - private long idleTimeout; // TODO (AF): Fix a default value (used in constructor) + private long idleTimeout = 60; /** * @return the hostName @@ -303,7 +303,7 @@ public class RestDistributionQueue { if (!props.containsKey(DestinationConstants.BATCH_DISTRIBUTION_OPTION)) props.setProperty(DestinationConstants.BATCH_DISTRIBUTION_OPTION, ""+batch); if (!props.containsKey(DestinationConstants.IDLETIMEOUT_PROP)) - props.setProperty(DestinationConstants.IDLETIMEOUT_PROP, ""+ idleTimeout); + props.setProperty(DestinationConstants.IDLETIMEOUT_PROP, ""+idleTimeout); if (!props.containsKey("period")) props.setProperty("period", ""+period);