fix: fix log feign response stream close bug

Shanyou Yu (Sean Yu) 3 years ago committed by Haotian Zhang
parent d7677d1715
commit dced3736e4

@ -79,7 +79,7 @@ Spring Cloud Tencent 所有组件都已上传到 Maven 中央仓库,只需要
<groupId>com.tencent.cloud</groupId>
<artifactId>spring-cloud-tencent-dependencies</artifactId>
<!--version number-->
<version>1.10.0-2020.0.5</version>
<version>1.10.1-2020.0.5</version>
<type>pom</type>
<scope>import</scope>
</dependency>

@ -76,7 +76,7 @@ For example:
<groupId>com.tencent.cloud</groupId>
<artifactId>spring-cloud-tencent-dependencies</artifactId>
<!--version number-->
<version>1.10.0-2020.0.5</version>
<version>1.10.1-2020.0.5</version>
<type>pom</type>
<scope>import</scope>
</dependency>

@ -88,7 +88,7 @@
<properties>
<!-- Project revision -->
<revision>1.10.0-2020.0.5</revision>
<revision>1.10.1-2020.0.5</revision>
<!-- Spring Framework -->
<spring.framework.version>5.3.21</spring.framework.version>

@ -70,7 +70,7 @@
</developers>
<properties>
<revision>1.10.0-2020.0.5</revision>
<revision>1.10.1-2020.0.5</revision>
<!-- Dependencies -->
<polaris.version>1.11.1</polaris.version>

@ -75,7 +75,7 @@ public class ExceptionPolarisReporter implements EnhancedFeignPlugin {
if (exception instanceof SocketTimeoutException) {
retStatus = RetStatus.RetTimeout;
}
LOG.debug("Will report result of {}. Request=[{}]. Response=[{}].", retStatus.name(), request, response);
LOG.debug("Will report result of {}. Request=[{} {}]. Response=[{}].", retStatus.name(), request.httpMethod().name(), request.url(), response.status());
ServiceCallResult resultRequest = ReporterUtils.createServiceCallResult(request, retStatus);
consumerAPI.updateServiceCallResult(resultRequest);
// update result without method for service circuit break.

@ -72,7 +72,7 @@ public class SuccessPolarisReporter extends AbstractPolarisReporterAdapter imple
if (apply(HttpStatus.resolve(response.status()))) {
retStatus = RetStatus.RetFail;
}
LOG.debug("Will report result of {}. Request=[{}]. Response=[{}].", retStatus.name(), request, response);
LOG.debug("Will report result of {}. Request=[{} {}]. Response=[{}].", retStatus.name(), request.httpMethod().name(), request.url(), response.status());
ServiceCallResult resultRequest = ReporterUtils.createServiceCallResult(request, retStatus);
consumerAPI.updateServiceCallResult(resultRequest);
// update result without method for service circuit break.

@ -17,6 +17,8 @@
package com.tencent.cloud.rpc.enhancement.feign.plugin.reporter;
import java.util.HashMap;
import com.tencent.cloud.rpc.enhancement.config.RpcEnhancementReporterProperties;
import com.tencent.cloud.rpc.enhancement.feign.plugin.EnhancedFeignContext;
import com.tencent.cloud.rpc.enhancement.feign.plugin.EnhancedFeignPluginType;
@ -83,7 +85,7 @@ public class ExceptionPolarisReporterTest {
@Test
public void testRun() {
// mock request
Request request = mock(Request.class);
Request request = Request.create(Request.HttpMethod.GET, "/", new HashMap<>(), null, null, null);
// mock response
Response response = mock(Response.class);

@ -17,6 +17,8 @@
package com.tencent.cloud.rpc.enhancement.feign.plugin.reporter;
import java.util.HashMap;
import com.tencent.cloud.rpc.enhancement.config.RpcEnhancementReporterProperties;
import com.tencent.cloud.rpc.enhancement.feign.plugin.EnhancedFeignContext;
import com.tencent.cloud.rpc.enhancement.feign.plugin.EnhancedFeignPluginType;
@ -83,7 +85,7 @@ public class SuccessPolarisReporterTest {
@Test
public void testRun() {
// mock request
Request request = mock(Request.class);
Request request = Request.create(Request.HttpMethod.GET, "/", new HashMap<>(), null, null, null);
// mock response
Response response = mock(Response.class);
doReturn(502).when(response).status();

Loading…
Cancel
Save