Fix streaming functions for LegacySNSMessage (#324) (#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]>
opensearch-project · Jan 24, 2023 · 17f9b49 · 17f9b49
1 parent 97dc905
commit 17f9b49
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);