Eggplant

Usage

app = Eggplant(RabbitKombuBroker(amqp_uri='amqp://localhost', exchange='eggplant-exchange', queue='users_service_queue'))

# Function handlers
@app.handler('user_logged_in')
def handle_user_login(message):
    User.updateLastLoginTime()

# Class handlers
@app.handler('user_logged_in')
class UserLoginHandler:
    def handle(self, message):
        User.updateLastLoginTime()
        
# Publish 
app.publish(topic='user_logged_in', message='username:kuku')