fix(gateway-vertx) Ensure #resume called in error cases before #end to avoid potential TCP hang.
MODIFY
gateway/platforms/vertx3/vertx3/src/main/java/io/apiman/gateway/platforms/vertx3/http/HttpPolicyAdapter.java
gateway/platforms/vertx3/vertx3/src/main/java/io/apiman/gateway/platforms/vertx3/http/HttpPolicyAdapter.java
@@ -139,16 +139,19 @@ public class HttpPolicyAdapter {
@Override
public void write(StringBuffer buffer) {
+ vertxRequest.resume();
vertxResponse.end(buffer.toString());
}
@Override
public void write(StringBuilder builder) {
+ vertxRequest.resume();
vertxResponse.end(builder.toString());
}
@Override
public void write(String body) {
+ vertxRequest.resume();
vertxResponse.end(body);
}
@@ -170,16 +173,19 @@ public class HttpPolicyAdapter {
@Override
public void write(StringBuffer buffer) {
+ vertxRequest.resume();
vertxResponse.end(buffer.toString());
}
@Override
public void write(StringBuilder builder) {
+ vertxRequest.resume();
vertxResponse.end(builder.toString());
}
@Override
public void write(String body) {
+ vertxRequest.resume();
vertxResponse.end(body);
}

fix(gateway-vertx) Ensure #resume called in error cases before #end to avoid potential TCP hang.