(messaging, message, identity)
| 31 | |
| 32 | |
| 33 | def send_json(messaging, message, identity): |
| 34 | message = snakemq.message.Message(json.dumps(message).encode("utf-8"), ttl=600) |
| 35 | messaging.send_message(identity, message) |
| 36 | |
| 37 | |
| 38 | def init_snakemq(ident, init_type="listen"): |
nothing calls this directly
no outgoing calls
no test coverage detected