commit a0428e65011c61c73546d250ce3123dbac946ff6
author James Dubee <jwdubee@us.ibm.com> Thu Jan 10 11:02:03 2019 -0500
committer Jason Peterson <jasonpet@us.ibm.com> Thu Jan 10 11:02:03 2019 -0500
tree d95d907416c06a5b2534b30d3adc35c026586b25
parent 4afc13afe604828831340db5cbdb18feaf97cd86

Guard Against Message of NoneType (#315)

provider/consumer.py

diff --git a/provider/consumer.py b/provider/consumer.py
index 865c209..84e1e2d 100644
--- a/provider/consumer.py
+++ b/provider/consumer.py
@@ -479,6 +479,9 @@
             except UnicodeDecodeError:
                 logging.warn('[{}] Value contains non-unicode bytes. Replacing invalid bytes.'.format(self.trigger))
                 value = unicode(value, errors='replace').encode('utf-8')
+        except AttributeError:
+           logging.warn('[{}] Cannot decode a NoneType message value'.format(self.trigger))
+           return value
 
         if self.encodeValueAsJSON:
             try: