# Pastebin qXHjnOdq root@224741a12a4e:/code# python -m sir amqp_watch 2017-02-01 18:32:20,902: Connection to RabbitMQ established 2017-02-01 18:32:20,904: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,909: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,913: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,917: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,924: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,929: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,947: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,953: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,958: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,965: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,971: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,976: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,980: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:20,984: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:21,026: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:21,034: Setting up a connection to http://10.2.2.39:18983/solr 2017-02-01 18:32:21,058: Adding a callback to search.index 2017-02-01 18:32:21,067: Adding a callback to search.delete ('MSG:', 'recording 11299821 11299826 11299820 11299828 11299822 11299819 11299827 11299824 11299823 11299825') ('GOT:', ) ('MSG:', 'release_group 1104480') ('GOT:', ) ('MSG:', 'release 1086158') ('GOT:', ) ('MSG:', 'editor 1797565') ('GOT:', ) ('MSG:', 'editor 1797525') ('GOT:', ) ('MSG:', 'editor 1797525') ('GOT:', ) ('MSG:', '') 2017-02-01 18:32:23,226: AMQP messages must at least contain 2 entries separated by spaces 2017-02-01 18:32:23,258: application_headers Traceback (most recent call last): File "/usr/local/lib/python2.7/site-packages/retrying.py", line 200, in call attempt = Attempt(fn(*args, **kwargs), attempt_number, False) File "sir/amqp/handler.py", line 146, in _watch_impl ch.wait() File "/usr/local/lib/python2.7/site-packages/amqp/abstract_channel.py", line 69, in wait return self.dispatch_method(method_sig, args, content) File "/usr/local/lib/python2.7/site-packages/amqp/abstract_channel.py", line 89, in dispatch_method return amqp_method(self, args, content) File "/usr/local/lib/python2.7/site-packages/amqp/channel.py", line 1908, in _basic_deliver fun(msg) File "sir/amqp/handler.py", line 68, in wrapper retries_remaining = msg.application_headers.get("mb-retries", File "/usr/local/lib/python2.7/site-packages/amqp/serialization.py", line 450, in __getattr__ raise AttributeError(name) AttributeError: application_headers Traceback (most recent call last): File "/usr/local/lib/python2.7/runpy.py", line 174, in _run_module_as_main "__main__", fname, loader, pkg_name) File "/usr/local/lib/python2.7/runpy.py", line 72, in _run_code exec code in run_globals File "/code/sir/__main__.py", line 116, in main() File "/code/sir/__main__.py", line 113, in main func(args) File "sir/amqp/handler.py", line 166, in watch _watch_impl() File "/usr/local/lib/python2.7/site-packages/retrying.py", line 49, in wrapped_f return Retrying(*dargs, **dkw).call(f, *args, **kw) File "/usr/local/lib/python2.7/site-packages/retrying.py", line 206, in call return attempt.get(self._wrap_exception) File "/usr/local/lib/python2.7/site-packages/retrying.py", line 247, in get six.reraise(self.value[0], self.value[1], self.value[2]) File "/usr/local/lib/python2.7/site-packages/retrying.py", line 200, in call attempt = Attempt(fn(*args, **kwargs), attempt_number, False) File "sir/amqp/handler.py", line 146, in _watch_impl ch.wait() File "/usr/local/lib/python2.7/site-packages/amqp/abstract_channel.py", line 69, in wait return self.dispatch_method(method_sig, args, content) File "/usr/local/lib/python2.7/site-packages/amqp/abstract_channel.py", line 89, in dispatch_method return amqp_method(self, args, content) File "/usr/local/lib/python2.7/site-packages/amqp/channel.py", line 1908, in _basic_deliver fun(msg) File "sir/amqp/handler.py", line 68, in wrapper retries_remaining = msg.application_headers.get("mb-retries", File "/usr/local/lib/python2.7/site-packages/amqp/serialization.py", line 450, in __getattr__ raise AttributeError(name) AttributeError: application_headers