@Override
                public void run() {
                    try {
                        helloService.sayHello("xxx", 22);
                        success.incrementAndGet();
                    } catch (Exception e) {
                        if (e instanceof SofaRpcException) {
                            Assert.assertEquals(((SofaRpcException) e).getErrorType(), RpcErrorType.SERVER_BUSY);
                        }
                        failure.incrementAndGet();
                    } finally {
                        latch.countDown();
                    }
                }
@author <a href="mailto:zhanggeng.zg@antfin.com">GengZhang</a>
test/test-integration/src/test/java/com/alipay/sofa/rpc/server/bolt/RejectedTest.java