+ remote timeout & connect timeout setters

Author: cheesterx3

README.md

@@ -22,6 +22,8 @@ This is just a simple implementation of single request/reply using dynamic regis
                         .deserializer(deserializer)
                         .serializer(serializer)
                         .cacheable("!headers['host'].equals(\"127.0.0.1\")")
+                        .connectTimeout(30)
+                        .remoteTimeout(20_000L)                        
                         .responseChannelName("serverResponseChannel"))
                 .get();
     }

dynamic-tcp/src/main/java/org/spring/integration/dynamic/tcp/spec/DynamicTcpOutboundGatewaySpec.java

@@ -6,6 +6,7 @@
 import org.springframework.integration.dsl.MessageProcessorSpec;
 import org.springframework.integration.dsl.context.IntegrationFlowContext;
 import org.springframework.integration.expression.FunctionExpression;
+import org.springframework.integration.expression.ValueExpression;
 import org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer;
 import org.springframework.messaging.Message;
 
@@ -142,6 +143,30 @@ public DynamicTcpOutboundGatewaySpec remoteTimeout(String expression) {
         return _this();
     }
 
+    /**
+     * Setting a connectTimeout value retrieving expression from message
+     *
+     * @param timeout connect timeout value
+     * @return DynamicTcpOutboundGatewaySpec
+     */
+    public DynamicTcpOutboundGatewaySpec connectTimeout(int timeout) {
+        getRequestFlow().setConnectTimeout(new ValueExpression<>(timeout));
+        return _this();
+    }
+
+    /**
+     * Setting a remoteTimeout value retrieving expression from message
+     *
+     * @param timeout remote timeout value
+     * @return DynamicTcpOutboundGatewaySpec
+     */
+    public DynamicTcpOutboundGatewaySpec remoteTimeout(long timeout) {
+        getRequestFlow().setRemoteTimeout(new ValueExpression<>(timeout));
+        return _this();
+    }
+
+
+
     private DynamicTcpOutboundGateway getRequestFlow() {
         return (DynamicTcpOutboundGateway) this.target;
     }