[incubator-servicecomb-java-chassis] 11/13: [SCB-292] chassis support standard parameter validation

[liubao]

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 430e81ee1532916204a4f84c5e7ca46e1e90ff03
Author: acsukesh <sukes...@huawei.com>
AuthorDate: Fri Apr 13 11:01:00 2018 +0530

    [SCB-292] chassis support standard parameter validation
---
 .../demo/jaxrs/client/CustomLoadbalanceExtensionsFactory.java    | 9 +++++++++
 .../org/apache/servicecomb/demo/jaxrs/client/JaxrsClient.java    | 6 +++---
 2 files changed, 12 insertions(+), 3 deletions(-)

diff --git 
a/demo/demo-jaxrs/jaxrs-client/src/main/java/org/apache/servicecomb/demo/jaxrs/client/CustomLoadbalanceExtensionsFactory.java
 
b/demo/demo-jaxrs/jaxrs-client/src/main/java/org/apache/servicecomb/demo/jaxrs/client/CustomLoadbalanceExtensionsFactory.java
index 819249d..77ce21b 100644
--- 
a/demo/demo-jaxrs/jaxrs-client/src/main/java/org/apache/servicecomb/demo/jaxrs/client/CustomLoadbalanceExtensionsFactory.java
+++ 
b/demo/demo-jaxrs/jaxrs-client/src/main/java/org/apache/servicecomb/demo/jaxrs/client/CustomLoadbalanceExtensionsFactory.java
@@ -22,6 +22,7 @@ import org.springframework.stereotype.Component;
 
 import com.netflix.client.DefaultLoadBalancerRetryHandler;
 import com.netflix.client.RetryHandler;
+import com.netflix.client.Utils;
 import com.netflix.loadbalancer.IRule;
 import com.netflix.loadbalancer.RoundRobinRule;
 
@@ -33,6 +34,14 @@ public class CustomLoadbalanceExtensionsFactory implements 
ExtensionsFactory {
   }
 
   class MyCustomHandler extends DefaultLoadBalancerRetryHandler {
+    @Override
+    public boolean isRetriableException(Throwable e, boolean sameServer) {
+      if (retryEnabled) {
+        return Utils.isPresentAsCause(e, getRetriableExceptions());
+      }
+      return false;
+    }
+
     public MyCustomHandler(int retrySameServer, int retryNextServer, boolean 
retryEnabled) {
       super(retrySameServer, retryNextServer, retryEnabled);
     }
diff --git 
a/demo/demo-jaxrs/jaxrs-client/src/main/java/org/apache/servicecomb/demo/jaxrs/client/JaxrsClient.java
 
b/demo/demo-jaxrs/jaxrs-client/src/main/java/org/apache/servicecomb/demo/jaxrs/client/JaxrsClient.java
index 6b7a8af..680e6ad 100644
--- 
a/demo/demo-jaxrs/jaxrs-client/src/main/java/org/apache/servicecomb/demo/jaxrs/client/JaxrsClient.java
+++ 
b/demo/demo-jaxrs/jaxrs-client/src/main/java/org/apache/servicecomb/demo/jaxrs/client/JaxrsClient.java
@@ -178,7 +178,7 @@ public class JaxrsClient {
       template.postForObject(cseUrlPrefix + "add", params, Integer.class);
     } catch (InvocationException e) {
       isExcep = true;
-      TestMgr.check(490, e.getStatus().getStatusCode());
+      TestMgr.check(400, e.getStatus().getStatusCode());
     }
 
     TestMgr.check(true, isExcep);
@@ -198,7 +198,7 @@ public class JaxrsClient {
       template.exchange(cseUrlPrefix + "sayhi/{name}", HttpMethod.PUT, null, 
String.class, "te");
     } catch (InvocationException e) {
       isExcep = true;
-      TestMgr.check(490, e.getStatus().getStatusCode());
+      TestMgr.check(400, e.getStatus().getStatusCode());
     }
     TestMgr.check(true, isExcep);
   }
@@ -225,7 +225,7 @@ public class JaxrsClient {
           Student.class);
     } catch (InvocationException e) {
       isExcep = true;
-      TestMgr.check(490, e.getStatus().getStatusCode());
+      TestMgr.check(400, e.getStatus().getStatusCode());
     }
     TestMgr.check(true, isExcep);
   }

-- 
To stop receiving notification emails like this one, please contact
liu...@apache.org.