diff --git a/mq/plugins/rra.py b/mq/plugins/rra.py index 0dd103e6c..110e5844d 100644 --- a/mq/plugins/rra.py +++ b/mq/plugins/rra.py @@ -42,8 +42,10 @@ def validate(self, message): return False if (len(message['details']['metadata']['service']) == 0): + sys.stderr.write('warning: no service name for {0}\n'.format(message['source'])) return False if (message['details']['metadata']['service'] == 'RRA for '): + sys.stderr.write('warning: Invalid service name for {0}\n'.format(message['source'])) return False return True