example.py

from pyeventbus import *
import time

class Events:
    class EventFromA:
        def __init__(self, msg):
            self.msg = msg
        def getMessage(self):
            return self.msg
    class EventFromB:
        def __init__(self, msg):
            self.msg = msg
        def getMessage(self):
            return self.msg

class A:
    def __init__(self):
        self.bus = PyBus.Instance()
        pass

    def register(self, aInstance):
        PyBus.Instance().register(aInstance, self.__class__.__name__)

    def post(self):
        PyBus.Instance().post(Events.EventFromA("EventFromA"))
    
    @subscribe(threadMode = Mode.PARALLEL, onEvent=Events.EventFromB)
    def readEventFromB(self, event):
        print 'Class A', event.getMessage()


class B:
    def __init__(self):
        self.bus = PyBus.Instance()
        pass
    
    def register(self, bInstance):
        PyBus.Instance().register(bInstance, self.__class__.__name__)

    @subscribe( threadMode = Mode.BACKGROUND, onEvent=Events.EventFromA)
    def readEventFromA(self, event):
        print 'Class B:', event.getMessage()
    
    def post(self):
        PyBus.Instance().post(Events.EventFromB("EventFromB"))


if __name__ == "__main__":
    a = A()
    a.register(a)

    b = B()
    b.register(b)
        
    a.post()
    b.post()