@InterfaceStability.Unstable public interface MessageEnvelope<K,M>
MessageStream
s.Modifier and Type | Method and Description |
---|---|
K |
getKey()
Get the key for this
MessageEnvelope . |
M |
getMessage()
Get the message in this
MessageEnvelope . |
default boolean |
isDelete()
Whether this
MessageEnvelope indicates deletion of a previous message with this key. |
K getKey()
MessageEnvelope
.MessageEnvelope
M getMessage()
MessageEnvelope
.MessageEnvelope
default boolean isDelete()
MessageEnvelope
indicates deletion of a previous message with this key.MessageEnvelope
indicates deletion of a previous message with this key