Trait spring_stream::extractor::Message

source ·

pub trait Message: Send {
    // Required methods
    fn stream_key(&self) -> StreamKey;
    fn shard_id(&self) -> ShardId;
    fn sequence(&self) -> u64;
    fn timestamp(&self) -> OffsetDateTime;
    fn message(&self) -> Payload<'_>;

    // Provided methods
    fn to_owned(&self) -> SharedMessage { ... }
    fn identifier(&self) -> (StreamKey, ShardId, u64) { ... }
}