Miscellaneous changes

mkdocs.yml

@@ -120,7 +120,6 @@ nav:
 
     - Domain Model:
       - Compose a Domain:
-        - guides/compose-a-domain/index.md
         - guides/compose-a-domain/register-elements.md
         - guides/compose-a-domain/initialize-domain.md
         - guides/compose-a-domain/activate-domain.md

src/protean/server/broker_subscription.py

@@ -114,7 +114,7 @@ async def shutdown(self):
             None
         """
         self.keep_going = False  # Signal to stop polling
-        logger.info(f"Shutting down subscription {self.subscriber_id}")
+        logger.debug(f"Shutting down subscription {self.subscriber_id}")
 
     async def get_next_batch_of_messages(self):
         """

src/protean/server/engine.py

@@ -217,7 +217,7 @@ def run(self):
         """
         Start the Protean Engine and run the subscriptions.
         """
-        logger.info("Starting Protean Engine...")
+        logger.debug("Starting Protean Engine...")
         # Handle Signals
         signals = (signal.SIGHUP, signal.SIGTERM, signal.SIGINT)
         for s in signals:
@@ -270,7 +270,8 @@ def handle_exception(loop, context):
                 # Then immediately call and await the shutdown directly
                 self.loop.run_until_complete(self.shutdown())
             else:
+                logger.info("Protean Engine is running...")
                 self.loop.run_forever()
         finally:
             self.loop.close()
-            logger.debug("Successfully shutdown Protean Engine.")
+            logger.info("Protean Engine has stopped.")

src/protean/server/subscription.py

@@ -131,7 +131,7 @@ async def shutdown(self):
         """
         self.keep_going = False  # Signal to stop polling
         await self.update_current_position_to_store()
-        logger.info(f"Shutting down subscription {self.subscriber_id}")
+        logger.debug(f"Shutting down subscription {self.subscriber_id}")
 
     async def fetch_last_position(self):
         """