| |
@@ -348,6 +348,11 @@
|
| |
columns=('id', 'address', 'props', 'body'),
|
| |
opts={'order': 'id', 'limit': limit})
|
| |
msgs = list(query.execute())
|
| |
+ for msg in msgs:
|
| |
+ try:
|
| |
+ msg['props'] = json.loads(msg['props'])
|
| |
+ except Exception:
|
| |
+ LOG.error('Unable to load message from db: %r', msg)
|
| |
if not msgs:
|
| |
return
|
| |
if CONFIG.getboolean('broker', 'test_mode', fallback=False):
|
| |
props is encoded as json on insertion, so we should decode it when we read it back