io.github.daedalus/mcp-zmq
MCP server for ZMQ messaging
Versions
0.1.0latestTools 6
zmq_publish Publish a message to a ZMQ PUB socket. Args: topic: Message topic/topic filter for subscribers. message: Message payload to publish. bind_address: Address to bind PUB socket. Defaults to "tcp://127.0.0.1:5555". Returns: Dictionary with success status, topic, and message. Example: >>> zmq_publish("chat", "Hello world", "tcp://127.0.0.1:5555") {"success": true, "topic": "chat", "message": "Hello world"}
zmq_subscribe Subscribe to messages from a ZMQ SUB socket. Args: topic_filter: Topic to subscribe to. Empty string subscribes to all topics. connect_address: Address to connect SUB socket. Defaults to "tcp://127.0.0.1:5555". timeout_ms: Receive timeout in milliseconds. Defaults to 5000. Returns: Dictionary with success status, topic, message, and timed_out flag. Example: >>> zmq_subscribe("chat", "tcp://127.0.0.1:5555", 5000) {"success": true, "topic": "chat", "message": "Hello", "timed_out": false}
zmq_send_request Send a request via ZMQ REQ socket. Args: message: Request payload to send. connect_address: Address to connect REQ socket. Defaults to "tcp://127.0.0.1:5556". timeout_ms: Request timeout in milliseconds. Defaults to 5000. Returns: Dictionary with success status and response message. Example: >>> zmq_send_request("Hello", "tcp://127.0.0.1:5556", 5000) {"success": true, "message": "World"}
zmq_listen_reply Listen for requests and reply via ZMQ REP socket. Args: bind_address: Address to bind REP socket. Defaults to "tcp://127.0.0.1:5556". reply_message: Message to send in response to requests. Defaults to "OK". timeout_ms: Listen timeout in milliseconds. Defaults to 5000. Returns: Dictionary with success status, received message, replied message, and timed_out flag. Example: >>> zmq_listen_reply("tcp://127.0.0.1:5556", "Got it", 5000) {"success": true, "received": "Hello", "replied": "Got it", "timed_out": false}
zmq_pair_connect Connect to a ZMQ PAIR socket for bi-directional communication. Args: connect_address: Address to connect PAIR socket. Defaults to "tcp://127.0.0.1:5557". message: Optional message to send after connecting. timeout_ms: Timeout in milliseconds. Defaults to 5000. Returns: Dictionary with success status, sent message, received message, and timed_out flag. Example: >>> zmq_pair_connect("tcp://127.0.0.1:5557", "Hello", 5000) {"success": true, "sent": "Hello", "received": "World", "timed_out": false}
zmq_pair_bind Bind a ZMQ PAIR socket for bi-directional communication. Args: bind_address: Address to bind PAIR socket. Defaults to "tcp://127.0.0.1:5557". message: Optional message to send after binding. timeout_ms: Timeout in milliseconds. Defaults to 5000. Returns: Dictionary with success status, sent message, received message, and timed_out flag. Example: >>> zmq_pair_bind("tcp://127.0.0.1:5557", "Ready", 5000) {"success": true, "sent": "Ready", "received": "Hello", "timed_out": false}
Permissions 0
No permissions indexed yet.