|
|
@@ -1,17 +1,18 @@ |
|
|
|
package me.chanjar.weixin.mp.api; |
|
|
|
|
|
|
|
import me.chanjar.weixin.common.bean.result.WxError; |
|
|
|
import me.chanjar.weixin.common.exception.WxErrorException; |
|
|
|
import me.chanjar.weixin.common.util.http.RequestExecutor; |
|
|
|
import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl; |
|
|
|
import org.testng.annotations.DataProvider; |
|
|
|
import org.testng.annotations.Test; |
|
|
|
|
|
|
|
import java.util.concurrent.ExecutionException; |
|
|
|
import java.util.concurrent.ExecutorService; |
|
|
|
import java.util.concurrent.Executors; |
|
|
|
import java.util.concurrent.Future; |
|
|
|
|
|
|
|
import org.testng.annotations.DataProvider; |
|
|
|
import org.testng.annotations.Test; |
|
|
|
|
|
|
|
import me.chanjar.weixin.common.bean.result.WxError; |
|
|
|
import me.chanjar.weixin.common.exception.WxErrorException; |
|
|
|
import me.chanjar.weixin.common.util.http.RequestExecutor; |
|
|
|
import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl; |
|
|
|
|
|
|
|
@Test |
|
|
|
public class WxMpBusyRetryTest { |
|
|
|
|
|
|
@@ -20,7 +21,9 @@ public class WxMpBusyRetryTest { |
|
|
|
WxMpService service = new WxMpServiceImpl() { |
|
|
|
|
|
|
|
@Override |
|
|
|
protected <T, E> T executeInternal(RequestExecutor<T, E> executor, String uri, E data) throws WxErrorException { |
|
|
|
protected synchronized <T, E> T executeInternal( |
|
|
|
RequestExecutor<T, E> executor, String uri, E data) |
|
|
|
throws WxErrorException { |
|
|
|
WxError error = new WxError(); |
|
|
|
error.setErrorCode(-1); |
|
|
|
throw new WxErrorException(error); |
|
|
|