Skip to content
Snippets Groups Projects
Commit f4d93d7a authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

SW-796: fixed tObservationStartListener

parent c18077d2
No related branches found
No related tags found
1 merge request!47Merge Lofar release 4 0 back to master
...@@ -199,6 +199,9 @@ class MessageContent(object): ...@@ -199,6 +199,9 @@ class MessageContent(object):
qpidMsg.body = qpidMsg.body.decode('utf-8') qpidMsg.body = qpidMsg.body.decode('utf-8')
plIdx = qpidMsg.body.find('<payload>') plIdx = qpidMsg.body.find('<payload>')
if isinstance(qpidMsg.body, bytes):
qpidMsg.body = qpidMsg.body.decode('utf-8')
if plIdx != -1: if plIdx != -1:
plIdx += len('<payload>') plIdx += len('<payload>')
plEndIdx = qpidMsg.body.rfind('</payload>', plIdx) plEndIdx = qpidMsg.body.rfind('</payload>', plIdx)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment