I have a service that is invoked by ESB (zato) the role of this service is to publish a message in rabbitMQ through an AMQP outgoing but when i consult rabbitMQ and make get message the answer is queue is empty.this is service in zato
from zato.server.service import Service
class HelloService(Service):
def handle(self):
# Request parameters
msg = 'Hello AMQP broker!'
out_name = 'My CRM connection'
exchange = 'My exchange'
routing_key = ''
properties = {'app_id': 'ESB'}
headers = {'X-Foo': 'bar'}
# Send a message to the broker
self.outgoing.amqp.send(msg, out_name, exchange, routing_key,
properties, headers)