Skip to content

Commit

Permalink
getMessageAtIndex should actually return the value in the streamMessa…
Browse files Browse the repository at this point in the history
…ge for compatibility (#11355)
  • Loading branch information
navina authored Aug 16, 2023
1 parent 4c307e1 commit e4220ec
Showing 1 changed file with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -49,11 +49,17 @@ public int getMessageCount() {
return _messageList.size();
}

@Deprecated
@Override
public PulsarStreamMessage getMessageAtIndex(int index) {
return _messageList.get(index);
}

@Override
public byte[] getMessageBytesAtIndex(int index) {
return getMessageAtIndex(index).getValue();
}

@Override
public int getMessageOffsetAtIndex(int index) {
return ByteBuffer.wrap(_messageList.get(index).getValue()).arrayOffset();
Expand Down

0 comments on commit e4220ec

Please sign in to comment.