File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
spring-integration-core/src/main/java/org/springframework/integration/gateway Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change 24
24
25
25
import org .springframework .beans .factory .BeanCreationException ;
26
26
import org .springframework .beans .factory .config .ConfigurableListableBeanFactory ;
27
+ import org .springframework .core .task .SimpleAsyncTaskExecutor ;
27
28
import org .springframework .integration .handler .AbstractReplyProducingMessageHandler ;
28
29
import org .springframework .integration .support .management .ManageableLifecycle ;
29
30
import org .springframework .lang .Nullable ;
@@ -66,7 +67,7 @@ public class GatewayMessageHandler extends AbstractReplyProducingMessageHandler
66
67
67
68
private boolean errorOnTimeout ;
68
69
69
- private Executor executor ;
70
+ private Executor executor = new SimpleAsyncTaskExecutor () ;
70
71
71
72
public void setRequestChannel (MessageChannel requestChannel ) {
72
73
this .requestChannel = requestChannel ;
@@ -147,6 +148,7 @@ private void initialize() {
147
148
this .gatewayProxyFactoryBean .setDefaultReplyChannelName (this .replyChannelName );
148
149
this .gatewayProxyFactoryBean .setErrorChannel (this .errorChannel );
149
150
this .gatewayProxyFactoryBean .setErrorChannelName (this .errorChannelName );
151
+ this .gatewayProxyFactoryBean .setErrorOnTimeout (this .errorOnTimeout );
150
152
this .gatewayProxyFactoryBean .setAsyncExecutor (this .executor );
151
153
if (this .requestTimeout != null ) {
152
154
this .gatewayProxyFactoryBean .setDefaultRequestTimeout (this .requestTimeout );
You can’t perform that action at this time.
0 commit comments