This is an automated email from the ASF dual-hosted git repository. liubao pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-java-chassis.git
commit fb60b966e3c9d6e34a99bc2e6edc2dfe6b4fc4dd Author: wujimin <[email protected]> AuthorDate: Sun Apr 22 04:00:13 2018 +0800 [SCB-486] fix bug: edge invocation should be async. --- .../src/main/java/org/apache/servicecomb/edge/core/EdgeInvocation.java | 1 + .../test/java/org/apache/servicecomb/edge/core/TestEdgeInvocation.java | 1 + 2 files changed, 2 insertions(+) diff --git a/edge/edge-core/src/main/java/org/apache/servicecomb/edge/core/EdgeInvocation.java b/edge/edge-core/src/main/java/org/apache/servicecomb/edge/core/EdgeInvocation.java index e898887..71a9f65 100644 --- a/edge/edge-core/src/main/java/org/apache/servicecomb/edge/core/EdgeInvocation.java +++ b/edge/edge-core/src/main/java/org/apache/servicecomb/edge/core/EdgeInvocation.java @@ -121,6 +121,7 @@ public class EdgeInvocation extends AbstractRestInvocation { this.invocation = InvocationFactory.forConsumer(referenceConfig, restOperationMeta.getOperationMeta(), null); + this.invocation.setSync(false); this.invocation.setResponseExecutor(new ReactiveResponseExecutor()); } } diff --git a/edge/edge-core/src/test/java/org/apache/servicecomb/edge/core/TestEdgeInvocation.java b/edge/edge-core/src/test/java/org/apache/servicecomb/edge/core/TestEdgeInvocation.java index 5cbadbf..302656f 100644 --- a/edge/edge-core/src/test/java/org/apache/servicecomb/edge/core/TestEdgeInvocation.java +++ b/edge/edge-core/src/test/java/org/apache/servicecomb/edge/core/TestEdgeInvocation.java @@ -227,5 +227,6 @@ public class TestEdgeInvocation { edgeInvocation.createInvocation(); Invocation invocation = Deencapsulation.getField(edgeInvocation, "invocation"); Assert.assertThat(invocation.getResponseExecutor(), Matchers.instanceOf(ReactiveResponseExecutor.class)); + Assert.assertFalse(invocation.isSync()); } } -- To stop receiving notification emails like this one, please contact [email protected].
