diff --git a/README.md b/README.md index 50a0f0d..daa4356 100644 --- a/README.md +++ b/README.md @@ -926,6 +926,7 @@ await message.delay(delay_in_seconds) ``` ### Get headers + Get headers per message ```python @@ -933,12 +934,21 @@ headers = message.get_headers() ``` ### Get message sequence number + Get message sequence number ```python sequence_number = msg.get_sequence_number() ``` +### Get message time sent + +Get message time sent + +```python +time_sent = msg.get_timesent() +``` + ### Destroying a Consumer ```python diff --git a/memphis/message.py b/memphis/message.py index 751a9c7..adaf83e 100644 --- a/memphis/message.py +++ b/memphis/message.py @@ -86,6 +86,14 @@ def get_sequence_number(self): except Exception: return + def get_timesent(self): + """Get timestamp when the message was sent.""" + try: + md = self.message.metadata() + return md.timestamp + except Exception: + return + async def delay(self, delay): """Delay and resend the message after delay seconds""" if (