Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- # -*- coding: utf-8 -*-
- from __future__ import absolute_import, division, print_function, unicode_literals
- # gevent
- from gevent import sleep
- # Zato
- from zato.common.broker_message import SERVICE
- from zato.common.util import new_cid
- from zato.server.service import Service
- class EnforceAutoSQLPing(Service):
- name = 'enforce.auto.sql.ping'
- def handle(self):
- while True:
- msg = {
- 'action': SERVICE.PUBLISH.value,
- 'service': 'zato.outgoing.sql.auto-ping',
- 'payload': 'My payload',
- 'cid': new_cid()
- }
- self.broker_client.publish(msg)
- # Wait half a minute before pinging again
- sleep(30)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement