ingoogni

#https://stackoverflow.com/questions/26270681/can-an-asyncio-event-loop-run-in-the-background-without-suspending-the-python-in

import asyncio
import threading
import cherrypy
from cherrypy.process import plugins
from hbmqtt.client import MQTTClient, ClientException
from hbmqtt.mqtt.constants import QOS_1, QOS_2

ingoogni

import threading
import pgpubsub
import cherrypy
from cherrypy.process import plugins

class PGrepub(plugins.SimplePlugin):
    """
    Plugin that listens to Postresql notification channels and publishes
    the payload unmodified to a channel on the CherryPy bus.
    

ingoogni

import threading
import cherrypy
from cherrypy.process import plugins

class Portier(threading.Thread):
    """
    The Doorman (Portier) detects changes of message by listening to the
    subscribed channel, opens 'the door' as a message appears, yield it
    and closes the door once trough.