(rocketmq-eventbridge) branch main updated: Update RocketMQEventDataAPIImpl.java

[shenlin]

This is an automated email from the ASF dual-hosted git repository.

shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git


The following commit(s) were added to refs/heads/main by this push:
     new de41d18  Update RocketMQEventDataAPIImpl.java
de41d18 is described below

commit de41d18938c389fd0510c7452bdf1181007e881e
Author: Shen Yi <32639811+xu...@users.noreply.github.com>
AuthorDate: Tue May 7 19:56:35 2024 +0800

    Update RocketMQEventDataAPIImpl.java
    
    fix(typo): fix typo in RocketMQEventDataAPIImpl
---
 .../adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java
 
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java
index ae547a8..4749798 100644
--- 
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java
+++ 
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java
@@ -70,12 +70,12 @@ public class RocketMQEventDataAPIImpl implements 
EventDataOnRocketMQConnectAPI {
             rocketMQMsg.setBody(eventBridgeEvent.getData());
             size += rocketMQMsg.getBody().length;
         }
-        size += fillEventAttribues(rocketMQMsg, eventBridgeEvent);
+        size += fillEventAttributes(rocketMQMsg, eventBridgeEvent);
         size += fillExtension(rocketMQMsg, eventBridgeEvent.getExtensions());
         return size;
     }
 
-    public static int fillEventAttribues(Message rocketMQMsg, EventBridgeEvent 
eventBridgeEvent) {
+    public static int fillEventAttributes(Message rocketMQMsg, 
EventBridgeEvent eventBridgeEvent) {
         int totalLength = 0;
         totalLength += putIfPresent(PROPERTY_ATTRIBUTE_EVENT_ID, 
eventBridgeEvent.getId(), rocketMQMsg);
         totalLength += putIfPresent(PROPERTY_ATTRIBUTE_EVENT_SOURCE, 
eventBridgeEvent.getSource(), rocketMQMsg);