This is an automated email from the ASF dual-hosted git repository.
mxsm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 8237eca75 [ISSUE#5177] Incorrect attribute assignment in BROADCAST
strategy of AbstractHttpSinkHandler (#5179)
8237eca75 is described below
commit 8237eca756e853fb90858503f6415ccacd0ec781
Author: Zaki <[email protected]>
AuthorDate: Fri Mar 7 16:47:14 2025 +0800
[ISSUE#5177] Incorrect attribute assignment in BROADCAST strategy of
AbstractHttpSinkHandler (#5179)
---
.../connector/http/sink/handler/AbstractHttpSinkHandler.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git
a/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java
b/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java
index 9ef760617..d38e9d30d 100644
---
a/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java
+++
b/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java
@@ -75,10 +75,9 @@ public abstract class AbstractHttpSinkHandler implements
HttpSinkHandler {
sendRecordToUrl(record, attributes, url);
break;
case BROADCAST:
- for (URI broadcastUrl : urls) {
- attributes.put(MultiHttpRequestContext.NAME, new
MultiHttpRequestContext(urls.size()));
- sendRecordToUrl(record, attributes, broadcastUrl);
- }
+ attributes.put(MultiHttpRequestContext.NAME, new
MultiHttpRequestContext(urls.size()));
+ // send the record to all URLs
+ urls.forEach(url0 -> sendRecordToUrl(record, attributes,
url0));
break;
default:
throw new IllegalArgumentException("Unknown delivery strategy:
" + deliveryStrategy);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
