Fix streaming functions for LegacySNSMessage (opensearch-project#324) (…

…opensearch-project#325) Signed-off-by: Ashish Agrawal <[email protected]> Signed-off-by: Ashish Agrawal <[email protected]> (cherry picked from commit 84b4ee3) Co-authored-by: Ashish Agrawal <[email protected]>
ochprince · Jan 24, 2023 · 69e0f80 · 69e0f80
1 parent 6b16d7b
commit 69e0f80
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/main/java/org/opensearch/commons/destination/message/LegacySNSMessage.java b/src/main/java/org/opensearch/commons/destination/message/LegacySNSMessage.java
@@ -57,8 +57,8 @@ private LegacySNSMessage(
 
     public LegacySNSMessage(StreamInput streamInput) throws java.io.IOException {
         super(streamInput);
-        this.subject = streamInput.readString();
         this.message = super.getMessageContent();
+        this.subject = streamInput.readString();
         this.roleArn = streamInput.readString();
         this.topicArn = streamInput.readString();
         this.clusterName = streamInput.readString();
@@ -148,7 +148,6 @@ public String getClusterName() {
     public void writeTo(StreamOutput streamOutput) throws IOException {
         super.writeTo(streamOutput);
         streamOutput.writeString(subject);
-        streamOutput.writeString(message);
         streamOutput.writeString(roleArn);
         streamOutput.writeString(topicArn);
         streamOutput.writeString(clusterName);