diff --git a/platypush/bus/__init__.py b/platypush/bus/__init__.py
index 64269cf5..257035d2 100644
--- a/platypush/bus/__init__.py
+++ b/platypush/bus/__init__.py
@@ -58,7 +58,8 @@ class Bus(object):
         stop = False
         while not stop:
             msg = self.get()
-            if msg.timestamp and time.time() - msg.timestamp > self._MSG_EXPIRY_TIMEOUT:
+            timestamp = msg.timestamp if hasattr(msg, 'timestamp') else msg.get('timestamp')
+            if timestamp and time.time() - timestamp > self._MSG_EXPIRY_TIMEOUT:
                 logger.debug('{} seconds old message on the bus expired, ignoring it: {}'.
                              format(int(time.time()-msg.timestamp), msg))
                 continue