Aucune programmation n'est nécessaire pour recevoir des messages des files d'attente AMQP. Créez une définition et un canal AMQP dans Dashboard et un service donné sera invoqué pour chaque message retiré d'une file d'attente. La requête sera dans self.request.payload.
from zato.server.service import Service
class MyService(Service):
def handle(self):
self.logger.info('Message received: %s', self.request.payload)
Créez une définition AMQP et une connexion AMQP sortante dans Dashboard et envoyez un message comme dans l'exemple ci-dessous.
from zato.server.service import Service
class MyService(Service):
def handle(self):
self.outgoing.amqp.send('my-message', 'outconn-name', '/exchange', 'route-key')