Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

The PollingDispatcher's default receiveTimeout is now -1 for indefinite blocking.

Browse Source
This commit is contained in:
Mark Fisher
2008-08-06 19:43:24 +00:00
parent 528f5e6341
commit 52f61b3d88
4 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/PollingDispatcher.java
View File

@@ -36,7 +36,7 @@ public class PollingDispatcher implements SchedulableTask, SubscribableSource {
public final static int MAX_MESSAGES_UNBOUNDED = -1;
public final static long DEFAULT_RECEIVE_TIMEOUT = 5000;
public final static long DEFAULT_RECEIVE_TIMEOUT = -1;
private final Log logger = LogFactory.getLog(this.getClass());
@@ -80,8 +80,8 @@ public class PollingDispatcher implements SchedulableTask, SubscribableSource {
* Note that this value will only be applicable if the source is an instance
* of {@link BlockingSource}.
* <p/>
* A negative value indicates that receive calls should block indefinitely.
* The default value is 5000 (5 seconds).
* A negative value indicates that receive calls should block indefinitely,
* and that is the default behavior.
*/
public void setReceiveTimeout(long receiveTimeout) {
this.messageExchangeTemplate.setReceiveTimeout(receiveTimeout);
@@ -90,7 +90,7 @@ public class PollingDispatcher implements SchedulableTask, SubscribableSource {
/**
* Specify the timeout to use when sending to a target (in milliseconds).
* Note that this value will only be applicable if the target is an instance
* of {@link BlockingTarget}. The default value is 0.
* of {@link BlockingTarget}.
*/
public void setSendTimeout(long sendTimeout) {
this.dispatcher.setTimeout(sendTimeout);

3
org.springframework.integration/src/main/java/org/springframework/integration/router/RouterMessageHandlerAdapter.java
View File

@@ -124,9 +124,6 @@ public class RouterMessageHandlerAdapter extends AbstractMessageHandlerAdapter i
}
return false;
}
if (logger.isDebugEnabled()) {
logger.debug("sending message to channel '" + channelName + "'");
}
return this.sendMessage(message, channel);
}

2
org.springframework.integration/src/test/java/org/springframework/integration/config/handlerAdapterEndpointTests.xml
View File

@@ -7,7 +7,7 @@
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration-core-1.0.xsd">
<beans:bean class="org.springframework.integration.bus.DefaultMessageBus"/>
<beans:bean id="messageBus" class="org.springframework.integration.bus.DefaultMessageBus"/>
<queue-channel id="testChannel" capacity="50"/>

2
org.springframework.integration/src/test/java/org/springframework/integration/config/simpleEndpointTests.xml
View File

@@ -7,7 +7,7 @@
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration-core-1.0.xsd">
<beans:bean class="org.springframework.integration.bus.DefaultMessageBus"/>
<beans:bean id="messageBus" class="org.springframework.integration.bus.DefaultMessageBus"/>
<queue-channel id="testChannel" capacity="50"/>