Skip to content

Commit 7951ba9

Browse files
Fix streaming functions for LegacySNSMessage (#324) (#350)
Signed-off-by: Ashish Agrawal <ashisagr@amazon.com> Signed-off-by: Ashish Agrawal <ashisagr@amazon.com> (cherry picked from commit 84b4ee3) Co-authored-by: Ashish Agrawal <ashisagr@amazon.com>
1 parent 97dc905 commit 7951ba9

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/main/java/org/opensearch/commons/destination/message/LegacySNSMessage.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,8 +57,8 @@ private LegacySNSMessage(
5757

5858
public LegacySNSMessage(StreamInput streamInput) throws java.io.IOException {
5959
super(streamInput);
60-
this.subject = streamInput.readString();
6160
this.message = super.getMessageContent();
61+
this.subject = streamInput.readString();
6262
this.roleArn = streamInput.readString();
6363
this.topicArn = streamInput.readString();
6464
this.clusterName = streamInput.readString();
@@ -148,7 +148,6 @@ public String getClusterName() {
148148
public void writeTo(StreamOutput streamOutput) throws IOException {
149149
super.writeTo(streamOutput);
150150
streamOutput.writeString(subject);
151-
streamOutput.writeString(message);
152151
streamOutput.writeString(roleArn);
153152
streamOutput.writeString(topicArn);
154153
streamOutput.writeString(clusterName);

0 commit comments

Comments
 (0)