This is an automated email from the ASF dual-hosted git repository. wujimin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-java-chassis.git
commit 731e09e20e0ee4c1f295a4533fd2954370fec352 Author: zhengyangyong <yangyong.zh...@huawei.com> AuthorDate: Fri May 18 12:51:23 2018 +0800 SCB-548 fix pr comment Signed-off-by: zhengyangyong <yangyong.zh...@huawei.com> --- .../servicecomb/core/provider/consumer/InvokerUtils.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/core/src/main/java/org/apache/servicecomb/core/provider/consumer/InvokerUtils.java b/core/src/main/java/org/apache/servicecomb/core/provider/consumer/InvokerUtils.java index 78a4430..d617bd8 100644 --- a/core/src/main/java/org/apache/servicecomb/core/provider/consumer/InvokerUtils.java +++ b/core/src/main/java/org/apache/servicecomb/core/provider/consumer/InvokerUtils.java @@ -35,7 +35,7 @@ public final class InvokerUtils { private static final Logger LOGGER = LoggerFactory.getLogger(InvokerUtils.class); public static Object syncInvoke(String microserviceName, String schemaId, String operationName, Object[] args) { - validCanInvoke(); + checkEngineStatus(); ReferenceConfig referenceConfig = CseContext.getInstance().getConsumerProviderManager() .getReferenceConfig(microserviceName); return syncInvoke(generateInvocation(schemaId, operationName, args, referenceConfig)); @@ -43,14 +43,14 @@ public final class InvokerUtils { public static Object syncInvoke(String microserviceName, String microserviceVersion, String transport, String schemaId, String operationName, Object[] args) { - validCanInvoke(); + checkEngineStatus(); ReferenceConfig referenceConfig = CseContext.getInstance().getConsumerProviderManager() .createReferenceConfig(microserviceName, microserviceVersion, transport); return syncInvoke(generateInvocation(schemaId, operationName, args, referenceConfig)); } public static Object syncInvoke(Invocation invocation) throws InvocationException { - validCanInvoke(); + checkEngineStatus(); Response response = innerSyncInvoke(invocation); if (response.isSuccessed()) { return response.getResult(); @@ -59,7 +59,7 @@ public final class InvokerUtils { } public static Response innerSyncInvoke(Invocation invocation) { - validCanInvoke(); + checkEngineStatus(); try { invocation.onStart(); SyncResponseExecutor respExecutor = new SyncResponseExecutor(); @@ -82,7 +82,7 @@ public final class InvokerUtils { } public static void reactiveInvoke(Invocation invocation, AsyncResponse asyncResp) { - validCanInvoke(); + checkEngineStatus(); try { invocation.onStart(); invocation.setSync(false); @@ -114,7 +114,7 @@ public final class InvokerUtils { return InvocationFactory.forConsumer(referenceConfig, schemaMeta, operationName, args); } - private static void validCanInvoke() { + private static void checkEngineStatus() { if (!SCBStatus.UP.equals(SCBEngine.getInstance().getStatus())) { throw new IllegalStateException( "System is starting and not ready for remote calls or shutting down in progress, STATUS = " + String @@ -124,7 +124,7 @@ public final class InvokerUtils { @Deprecated public static Object invoke(Invocation invocation) { - validCanInvoke(); + checkEngineStatus(); return syncInvoke(invocation); } } -- To stop receiving notification emails like this one, please contact wuji...@apache.org.