Throwing a MessageTimeoutException if the request/reply Message handling times out.
This commit is contained in:
@@ -36,6 +36,7 @@ import javax.servlet.http.HttpServletResponse;
|
||||
import org.springframework.integration.core.Message;
|
||||
import org.springframework.integration.gateway.SimpleMessagingGateway;
|
||||
import org.springframework.integration.message.MessageBuilder;
|
||||
import org.springframework.integration.message.MessageTimeoutException;
|
||||
import org.springframework.web.HttpRequestHandler;
|
||||
import org.springframework.web.servlet.View;
|
||||
|
||||
@@ -304,6 +305,10 @@ public class HttpInboundEndpoint extends SimpleMessagingGateway implements HttpR
|
||||
else {
|
||||
reply = this.sendAndReceiveMessage(requestMessage);
|
||||
}
|
||||
if (reply == null) {
|
||||
throw new MessageTimeoutException(requestMessage,
|
||||
"failed to handle Message within specified timeout value");
|
||||
}
|
||||
}
|
||||
else {
|
||||
this.send(requestMessage);
|
||||
|
||||
Reference in New Issue
Block a user