What flags or statuses should we use to identify a final message for a given stream id?
Currently, my application uses
public boolean isFinal() {
Msg msg = decodeMsg();
return msg.isFinalMsg() || msg.msgClass() == MsgClasses.ACK;
}
Is this logic correct or we need to look for other markers in response
The application maintains a map of stream ids to their corresponding messages
Whenever the message is marked as final using isFinal() as shown above, we remove it from the map
However, what is noticed is we still get updates for those stream ids
What is the right approach?