mypub.py

# -*- coding: utf-8 -*-

from __future__ import absolute_import, division, print_function, unicode_literals

from zato.common.broker_message import SERVICE
from zato.common.util import new_cid
from zato.server.service import Service

class MyPub(Service):
    def handle(self):
        msg = {
            'action': SERVICE.PUBLISH.value,
            'service': 'zato.helpers.input-logger',
            'payload': '{"hello":"how are you?"}',
            'cid': new_cid(),
        }

        self.broker_client.invoke_async(msg)

good