[Pulp-list] gofer spam

[Jeff Ortel]

All,

In 0.35, a condition exploited by deleting a consumer generates spam[1] in the client.log 
& gofer/agent.log.

Fixed in 0.36.


[1]
2011-05-09 10:16:24,879 [ERROR][test_consumer_jkig_multTest] run() @ consumer.py:72 - failed:
Message(durable=True, properties={'x-amqp-0-10.routing-key': 
u'test_consumer_jkig_multTest'}, content='{\n  "origin": 
"e6b5c14e-c079-4486-b623-c075cde7869d", \n  "replyto": null, \n  "request": {\n 
"classname": "Consumer", \n    "kws": {}, \n    "args": [\n 
"f0ad3930fd6a1c9aa7c539f99a96fe247354d717b759b85eadd7d86ef079a5fd"\n    ], \n    "method": 
"deleted"\n  }, \n  "window": {}, \n  "secret": 
"f0ad3930fd6a1c9aa7c539f99a96fe247354d717b759b85eadd7d86ef079a5fd", \n  "version": "0.2", 
\n  "sn": "8de50fa4-c124-4841-899e-fe08212201fb", \n  "any": null\n}')
Traceback (most recent call last):
   File "/usr/lib/python2.6/site-packages/gofer/messaging/consumer.py", line 67, in run
     msg = self.__fetch(receiver)
   File "/usr/lib/python2.6/site-packages/gofer/messaging/consumer.py", line 99, in __fetch
     return receiver.fetch(timeout=self.WAIT)
   File "<string>", line 6, in fetch
   File "/usr/lib/python2.6/site-packages/qpid/messaging/endpoints.py", line 994, in fetch
     self._ecwait(lambda: self.linked)
   File "/usr/lib/python2.6/site-packages/qpid/messaging/endpoints.py", line 51, in _ecwait
     self.check_closed()
   File "/usr/lib/python2.6/site-packages/qpid/messaging/endpoints.py", line 963, in 
check_closed
     raise LinkClosed()