No programming is needed to receive messages from AMQP queues. Create an AMQP definition and channel in Dashboard, point it to a queue, and a service of your choice will be invoked for each message taken off the queue.
The message payload will be available in self.request.payload.
from zato.server.service import Service
class MyService(Service):
def handle(self):
# The AMQP message payload
data = self.request.payload
# Log what was received
self.logger.info('AMQP message: %s', data)
Create an AMQP definition and outgoing connection in Dashboard and use self.outgoing.amqp.send to publish messages.
from zato.server.service import Service
class MyService(Service):
def handle(self):
self.outgoing.amqp.send('Hello from Zato', 'my-outconn', '/exchange', 'routing-key')
AMQP headers can be attached to each message by passing a headers dict.
from zato.server.service import Service
class MyService(Service):
def handle(self):
self.outgoing.amqp.send(
'My message',
'my-outconn',
'/exchange',
'routing-key',
headers={'content-type': 'application/json', 'x-source': 'zato'},
)
A common pattern is to consume a message from one queue, process it and publish the result to another.
from zato.server.service import Service
class MyService(Service):
def handle(self):
# Incoming message from an AMQP channel
data = self.request.payload
self.logger.info('Processing: %s', data)
# Forward to another exchange
self.outgoing.amqp.send(data, 'processed-outconn', '/processed', 'done')
Book a demo with an expert who will help you build meaningful systems that match your ambitions
"For me, Zato Source is the only technology partner to help with operational improvements."
- John Adams
Program Manager of Channel Enablement at Keysight 