Description of problem:

In 0.35, the gofer consumer is not stopping the receiver thread.   So, when the endpoint closes, it closes the session but the receiver thread continues to fetch() on the receiver.  The following spam is generated in the log(s):

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()


Version-Release number of selected component (if applicable):

0.35 (gofer)

How reproducible:

Always

Steps to Reproduce:
1. Create a consumer
2. Delete the consumer
3.
  
Actual results:

Spam

Expected results:

2011-05-09 10:03:13,843 [INFO][jortel] deleted() @ pulp.py:186 - Artifacts deleted
2011-05-09 10:03:16,990 [INFO][pending:jortel] run() @ store.py:241 - stopped
2011-05-09 10:03:19,862 [INFO][jortel] run() @ consumer.py:77 - stopped
2011-05-09 10:03:19,882 [INFO][pulp-monitor] update() @ main.py:95 - uuid="jortel", detached


Additional info: