txZMQ
txZMQ copied to clipboard
ZeroMQ bindings for Twisted
There is a small typo in txzmq/pubsub.py. Should read `received` rather than `recevied`. Semi-automated pull request generated by https://github.com/timgates42/meticulous/blob/master/docs/NOTE.md
File "/home/ar/Envs/a3_pyvcluster/lib/python3.7/site-packages/txzmq/pubsub.py", line 26, in publish |class ZmqSubConnection(ZmqConnection): self.send(tag + b'\0' + message) | """ TypeError: can only concatenate str (not "bytes") to str def publish(self, message, tag=b''): """ Publish...
pylint flags messageReceived as an abstract-method in ZmqPubConnection, I suppose that it has to be overriden with do-nothing function.
I'm not quite sure this is a bug or if its an intended feature, and I'd like to elaborate on this problem that I've spent some time figuring out: I'm...
I've changed the pub/sub code to remove the custom framing using a null byte and added code to send and receive multipart messages. I've ensured API-level compatibility as well as...
Hi there! Does txZMQ support ZMQ 4.x? Thanks! Matthew
This is the beginning of some work that I'll be doing to bring the APIs in txZMQ more inline with the APIs in twisted.internet.endpoints (see http://twistedmatrix.com/documents/current/core/howto/endpoints.html); as of Twisted 10,...
Please add the interface for removing endpoints from an existing sockets. As libzmq 3.x supports disconnect, this is all we're looking forward to!
The latest tag is 1.0.1, but VERSION file was not bumped, it's also not on pypi https://pypi.org/project/txZMQ
Closes #91.