zeromessage 0.2

Lightweight ROS-like pub-sub tool utilizing ZeroMQ

Zero Message

Zero Message is a lightweight ROS-like pub-sub tool for Python 3.4+.

• Provides a wrapper around ZeroMQ socket.
• Communicate between any Python program using publisher-subscriber protocol

Installation

pip install zeromessage

Quick start

Refer to the /examples:

# listener.py
import asyncio
from zeromessage import EnvelopSocket

socket = EnvelopSocket.as_subscriber()

def doSomething(msg):
    print(msg)

subscribe_coroutine = socket.subscribe('test', doSomething)

asyncio.get_event_loop().run_until_complete(subscribe_coroutine())

# talker.py
import time
from zeromessage import EnvelopSocket

socket = EnvelopSocket.as_publisher()

while True:
    socket.publish('test', {
        'data': [1, 2, 3]
    })
    time.sleep(1)

Command Line tools

A rostopic like tool is provided.

zerotopic echo -- --help

API Document

zero-message.readthedocs.io