Skip to content

Commit 5c6ebe3

Browse files
committed
fix: fix bugs
1 parent e8fdcd3 commit 5c6ebe3

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

Diff for: eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java

+3-4
Original file line numberDiff line numberDiff line change
@@ -75,10 +75,9 @@ public void handle(ConnectRecord record) {
7575
sendRecordToUrl(record, attributes, url);
7676
break;
7777
case BROADCAST:
78-
for (URI broadcastUrl : urls) {
79-
attributes.put(MultiHttpRequestContext.NAME, new MultiHttpRequestContext(urls.size()));
80-
sendRecordToUrl(record, attributes, broadcastUrl);
81-
}
78+
attributes.put(MultiHttpRequestContext.NAME, new MultiHttpRequestContext(urls.size()));
79+
// send the record to all URLs
80+
urls.forEach(url0 -> sendRecordToUrl(record, attributes, url0));
8281
break;
8382
default:
8483
throw new IllegalArgumentException("Unknown delivery strategy: " + deliveryStrategy);

0 commit comments

Comments
 (0)