commit de41d18938c389fd0510c7452bdf1181007e881e
author Shen Yi <32639811+XuyiK@users.noreply.github.com> Tue May 07 19:56:35 2024 +0800
committer shenlin <2011shenlin@gmail.com> Sat May 11 17:18:52 2024 +0800
tree 681878c386319b37cc107a2905d6bbb0b03ea0a9
parent 4d66b0f7664b2343f81372dcd99781834edd4bc5

Update RocketMQEventDataAPIImpl.java

fix(typo): fix typo in RocketMQEventDataAPIImpl

adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java

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 @@
             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);