Aio pika ack request early

pjrpc/server/integration/aio_pika.py

@@ -94,6 +94,10 @@ async def _rpc_handle(self, message: aio_pika.abc.AbstractIncomingMessage) -> No
         """
 
         try:
+            # Acknowledge message early. This ensures, that a bad implemented rpc method
+            # which causes a appliaction crash won't be reissued again after restart
+            await message.ack()
+
             reply_to = message.reply_to
             response_text = await self._dispatcher.dispatch(message.body.decode(), context=message)