refactor

maniskum · maniskum · commit eb5c62adf0e4 · 2024-05-28T12:15:23.000+05:30
diff --git a/streaming-connect-sink/src/main/java/com/adobe/platform/streaming/sink/impl/AEPPublisher.java b/streaming-connect-sink/src/main/java/com/adobe/platform/streaming/sink/impl/AEPPublisher.java
@@ -109,7 +109,7 @@ public void publishData(List<Pair<String, SinkRecord>> messages) throws AEPStrea
             if (Objects.nonNull(errorReporter)) {
               final int responseCode = messageResponse.get(STATUS_KEY).asInt();
               errorReporter.report(failedMessage.getRight(),
-                new HttpException(String.format("error response= %s", failedMessage), responseCode));
+                new HttpException(String.format("error response= %s", messageResponse), responseCode));
             }
           } else {
             successMessageCount++;

Original file line number	Diff line number	Diff line change
`@@ -109,7 +109,7 @@ public void publishData(List<Pair<String, SinkRecord>> messages) throws AEPStrea`
`109`	`109`	`if (Objects.nonNull(errorReporter)) {`
`110`	`110`	`final int responseCode = messageResponse.get(STATUS_KEY).asInt();`
`111`	`111`	`errorReporter.report(failedMessage.getRight(),`
`112`		`- new HttpException(String.format("error response= %s", failedMessage), responseCode));`
	`112`	`+ new HttpException(String.format("error response= %s", messageResponse), responseCode));`
`113`	`113`	`}`
`114`	`114`	`} else {`
`115`	`115`	`successMessageCount++;`