added manager start method #release-note

Author: lsbardel

pq/mq.py

@@ -77,6 +77,11 @@ async def store_message(self, message):
  """
  pass
 
+ def start(self):
+ """Optional start method, called by the backend when it starts
+ """
+ pass
+
  def close(self):
  pass
 

pq/server/producer.py

@@ -67,9 +67,12 @@ def is_consumer(self):
  return False
 
  async def start(self):
+ # Register consumers
  for consumer in self.consumers:
  await as_coroutine(consumer.register())
+ # connect channels
  await self.channels.connect()
+ self.manager.start()
  return self
 
  async def publish(self, event, message):