This is an automated email from the ASF dual-hosted git repository.
mikexue 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 19ffa83bf Update EventMeshConsumer.java
new 7f0052433 Merge pull request #3627 from harshithasudhakar/patch-1
19ffa83bf is described below
commit 19ffa83bf8fdb557084310d3f92d166a9c1db571
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Tue Apr 4 23:55:09 2023 +0530
Update EventMeshConsumer.java
Removed the parameter 'defaultValue' at line 256. Replaced 'defaultvalue'
with "" at line 258 . I have also removed the third parameter at lines 196 and
197.
---
.../runtime/core/protocol/http/consumer/EventMeshConsumer.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
index cb81a1d89..3708dec0a 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java
@@ -193,8 +193,8 @@ public class EventMeshConsumer {
.build();
String topic = event.getSubject();
- String bizSeqNo = getEventExtension(event,
ProtocolKey.ClientInstanceKey.BIZSEQNO, "");
- String uniqueId = getEventExtension(event,
ProtocolKey.ClientInstanceKey.UNIQUEID, "");
+ String bizSeqNo = getEventExtension(event,
ProtocolKey.ClientInstanceKey.BIZSEQNO);
+ String uniqueId = getEventExtension(event,
ProtocolKey.ClientInstanceKey.UNIQUEID);
if (messageLogger.isDebugEnabled()) {
messageLogger.debug("message|mq2eventMesh|topic={}|msg={}", topic, event);
@@ -253,9 +253,9 @@ public class EventMeshConsumer {
log.info("EventMeshConsumer [{}] inited.............",
consumerGroupConf.getConsumerGroup());
}
- private String getEventExtension(CloudEvent event, String protocolKey,
String defaultValue) {
+ private String getEventExtension(CloudEvent event, String protocolKey) {
Object extension = event.getExtension(protocolKey);
- return Objects.isNull(extension) ? defaultValue : extension.toString();
+ return Objects.isNull(extension) ? "" : extension.toString();
}
public synchronized void start() throws Exception {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
