Remove unused IncomingMessage.done()

We appear to not have a use for this. I had originally thought we might
use this to ack messages one they've been processed and replied to, but
we actually have always acked messages as soon as they have been
deserialized and queued for dispatching.

Change-Id: I8e1fd565814f3b5e3ba0f1bc77e62ed52ff08661
This commit is contained in:
Mark McLoughlin 2013-08-01 22:26:13 +01:00
parent 7c305150ff
commit 84a0693737
4 changed files with 0 additions and 14 deletions

View File

@ -65,11 +65,6 @@ class AMQPIncomingMessage(base.IncomingMessage):
self._send_reply(conn, reply, failure)
self._send_reply(conn, ending=True)
def done(self):
LOG.info("done")
# FIXME(markmc): I'm not sure we need this method ... we've already
# acked the message at this point
class AMQPListener(base.Listener):

View File

@ -36,10 +36,6 @@ class IncomingMessage(object):
def reply(self, reply=None, failure=None):
"Send a reply or failure back to the client."
@abc.abstractmethod
def done(self):
"The message has been dispatched and replied to."
class Listener(object):

View File

@ -44,9 +44,6 @@ class FakeIncomingMessage(base.IncomingMessage):
if self._reply_q:
self._reply_q.put(reply)
def done(self):
pass
class FakeListener(base.Listener):

View File

@ -39,8 +39,6 @@ class ExecutorBase(object):
_LOG.error("Failed to process message... skipping it.",
exc_info=exc_info)
incoming.reply(failure=exc_info)
finally:
incoming.done()
@abc.abstractmethod
def start(self):