PyMQI directly under Zato

zato_pymqi.py

from zato.server.service import Service

class MyService(Service):

    def handle(self):

        import pymqi

        queue_manager = 'IDM'
        channel = 'SYSTEM.AUTO.SVRCONN'
        host = '10.1.0.12'
        port = '1414'
        queue_name = 'TESTEG'
        message = 'Hello from Zato!'
        conn_info = '%s(%s)' % (host, port)

        qmgr = pymqi.connect(queue_manager, channel, conn_info)

        queue = pymqi.Queue(qmgr, queue_name)
        queue.put(message)
        queue.close()

        qmgr.disconnect()