Package zmq.socket.pubsub
Class Dist
java.lang.Object
zmq.socket.pubsub.Dist
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
(package private) int
active()
void
boolean
checkHwm()
private void
distribute
(Msg msg) (package private) int
eligible()
boolean
hasOut()
void
(package private) int
matching()
boolean
boolean
sendToMatching
(Msg msg) void
terminated
(Pipe pipe) void
unmatch()
private boolean
-
Field Details
-
pipes
-
matching
private int matching -
active
private int active -
eligible
private int eligible -
more
private boolean more
-
-
Constructor Details
-
Dist
public Dist()
-
-
Method Details
-
attach
-
match
-
unmatch
public void unmatch() -
terminated
-
activated
-
sendToAll
-
sendToMatching
-
distribute
-
hasOut
public boolean hasOut() -
write
-
checkHwm
public boolean checkHwm() -
active
int active() -
eligible
int eligible() -
matching
int matching()
-