rpc.server do not consume messages after message acknowledge failure
Affects | Status | Importance | Assigned to | Milestone | |
---|---|---|---|---|---|
oslo.messaging |
New
|
Undecided
|
Unassigned |
Bug Description
oslo_messaging.
def start(self):
@excutils.
def _executor_thread():
try:
while self._running:
incoming = self.listener.
if incoming is not None:
self.
except greenlet.
return
class Connection did not a lot work to ensure the operation on a connection can recovered after a reconnection. But after we get the incoming message, connection error on message acknowledgement can be raised and caught by the excutils.
Kombu related code is listed below.
def drain_events(self, **kwargs):
return self.transport.
@property
def connection(self):
if not self._closed:
if not self.connected:
return self._connection