fix checkstyle error

xwm1992 · Aug 5, 2024 · abe3e93 · abe3e93
1 parent f3c1cb5
commit abe3e93
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 26 deletions.
diff --git a/.../src/main/java/org/apache/eventmesh/connector/http/sink/handle/CommonHttpSinkHandler.java b/.../src/main/java/org/apache/eventmesh/connector/http/sink/handle/CommonHttpSinkHandler.java
@@ -125,33 +125,32 @@ public void handle(ConnectRecord record) {
             final Map<String, ?> finalOffset = offset;
             Future<HttpResponse<Buffer>> responseFuture = deliver(url, httpConnectRecord);
             responseFuture.onSuccess(res -> {
-                    log.info("Request sent successfully. Record: timestamp={}, offset={}", timestamp, finalOffset);
-                    // log the response
-                    if (HttpUtils.is2xxSuccessful(res.statusCode())) {
-                        if (log.isDebugEnabled()) {
-                            log.debug("Received successful response: statusCode={}. Record: timestamp={}, offset={}, responseBody={}",
-                                res.statusCode(), timestamp, finalOffset, res.bodyAsString());
-                        } else {
-                            log.info("Received successful response: statusCode={}. Record: timestamp={}, offset={}", res.statusCode(), timestamp,
-                                finalOffset);
-                        }
-                        record.getCallback().onSuccess(convertToSendResult(record));
+                log.info("Request sent successfully. Record: timestamp={}, offset={}", timestamp, finalOffset);
+                // log the response
+                if (HttpUtils.is2xxSuccessful(res.statusCode())) {
+                    if (log.isDebugEnabled()) {
+                        log.debug("Received successful response: statusCode={}. Record: timestamp={}, offset={}, responseBody={}",
+                            res.statusCode(), timestamp, finalOffset, res.bodyAsString());
                     } else {
-                        if (log.isDebugEnabled()) {
-                            log.warn("Received non-2xx response: statusCode={}. Record: timestamp={}, offset={}, responseBody={}",
-                                res.statusCode(), timestamp, finalOffset, res.bodyAsString());
-                        } else {
-                            log.warn("Received non-2xx response: statusCode={}. Record: timestamp={}, offset={}", res.statusCode(), timestamp,
-                                finalOffset);
-                        }
-                        record.getCallback()
-                            .onException(buildSendExceptionContext(record, new RuntimeException("HTTP response code: " + res.statusCode())));
+                        log.info("Received successful response: statusCode={}. Record: timestamp={}, offset={}", res.statusCode(), timestamp,
+                            finalOffset);
                     }
-                })
-                .onFailure(err -> {
-                    log.error("Request failed to send. Record: timestamp={}, offset={}", timestamp, finalOffset, err);
-                    record.getCallback().onException(buildSendExceptionContext(record, err));
-                });
+                    record.getCallback().onSuccess(convertToSendResult(record));
+                } else {
+                    if (log.isDebugEnabled()) {
+                        log.warn("Received non-2xx response: statusCode={}. Record: timestamp={}, offset={}, responseBody={}",
+                            res.statusCode(), timestamp, finalOffset, res.bodyAsString());
+                    } else {
+                        log.warn("Received non-2xx response: statusCode={}. Record: timestamp={}, offset={}", res.statusCode(), timestamp,
+                            finalOffset);
+                    }
+                    record.getCallback()
+                        .onException(buildSendExceptionContext(record, new RuntimeException("HTTP response code: " + res.statusCode())));
+                }
+            }).onFailure(err -> {
+                log.error("Request failed to send. Record: timestamp={}, offset={}", timestamp, finalOffset, err);
+                record.getCallback().onException(buildSendExceptionContext(record, err));
+            });
         }
     }
 

diff --git a/...or-http/src/main/java/org/apache/eventmesh/connector/http/source/HttpSourceConnector.java b/...or-http/src/main/java/org/apache/eventmesh/connector/http/source/HttpSourceConnector.java
@@ -21,7 +21,6 @@
 import org.apache.eventmesh.common.config.connector.http.HttpSourceConfig;
 import org.apache.eventmesh.common.exception.EventMeshException;
 import org.apache.eventmesh.connector.http.common.SynchronizedCircularFifoQueue;
-import org.apache.eventmesh.connector.http.source.data.CommonResponse;
 import org.apache.eventmesh.connector.http.source.protocol.Protocol;
 import org.apache.eventmesh.connector.http.source.protocol.ProtocolFactory;
 import org.apache.eventmesh.openconnect.api.ConnectorCreateService;