Comments (7)
I actually think the bug is in XSUB.
.recv() will block until an EOF is sent.
from zmq4.
Actually, it seems to be because there is no subscribe logic in the SUB/XSUB sockets. SUB does keep a map of subscribed topics, but it doesn't actually use it to screen the messages. Instead, that logic is in the PUB thread -- it won't send a message unless the PUB socket is subscribed to it, which is counter to how ZMQ is supposed to work -- you subscribe to topics with SUB/XSUB and the publisher shouldn't have to know or care what you're subscribed to.
from zmq4.
it's probably because I initially wrote this with a heavy inspiration from nanomsg/mango
that has subscription logic (IIRC).
PRs welcomed.
from zmq4.
I made a fix, but it hadn't finished building before it was time to knock off work for the day, so I'll test it fully on Monday.
from zmq4.
I made a fix, but it hadn't finished building before it was time to knock off work for the day, so I'll test it fully on Monday.
Any update, sir? @stitchinthyme
from zmq4.
Any update, sir? @stitchinthyme
Just submitted the PR, which works with my test programs above.
P.S. Not a 'sir'. :-)
from zmq4.
@stitchinthyme My bad, lol! thank you!
from zmq4.
Related Issues (20)
- pub sub err , when close the server the client get error and close HOT 1
- Go channel interface
- meta: consider setting up an OpenCollective account HOT 1
- router node restart recv block
- SUB socket SetOption must come after Dial, goczmq/pebbe don't have such limitation HOT 1
- Pull socket can not be properly closed, if no clients ever connected HOT 3
- REP socket races on client connection
- no reconnect possible when using `zmq4.NewPub` with `socket.Dial` HOT 4
- Why is go-zeromq/zmq4 not needing libzmq on windows? HOT 1
- socket accept a new connection, will send and read the greet message,if client always not response with greet message,other client can't connect to server
- Dead lock, how to fix? HOT 2
- github.com/pebbe/zmq2 (2.2.0) sub socket cannot connect to github.com/go-zeromq/zmq4 pub socket HOT 2
- Can't get a proxy to work (XSUB/XPUB)
- subSocket.Topics() is not accessible
- meta: new ZeroMQ/C++ license HOT 7
- Send timeout does not works HOT 4
- Deadlock detected by TestConnReaperDeadlock HOT 2
- PUB / SUB sockets
- PUB/SUB UDP socket HOT 1
- The connReaper goroutine may leak HOT 2
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from zmq4.