Package zmq.socket.pubsub
Class Dist
- java.lang.Object
-
- zmq.socket.pubsub.Dist
-
class Dist extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description Dist()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
activated(Pipe pipe)
(package private) int
active()
void
attach(Pipe pipe)
boolean
checkHwm()
private void
distribute(Msg msg)
(package private) int
eligible()
boolean
hasOut()
void
match(Pipe pipe)
(package private) int
matching()
boolean
sendToAll(Msg msg)
boolean
sendToMatching(Msg msg)
void
terminated(Pipe pipe)
void
unmatch()
private boolean
write(Pipe pipe, Msg msg)
-
-
-
Field Detail
-
pipes
private final java.util.List<Pipe> pipes
-
matching
private int matching
-
active
private int active
-
eligible
private int eligible
-
more
private boolean more
-
-
Method Detail
-
attach
public void attach(Pipe pipe)
-
match
public void match(Pipe pipe)
-
unmatch
public void unmatch()
-
terminated
public void terminated(Pipe pipe)
-
activated
public void activated(Pipe pipe)
-
sendToAll
public boolean sendToAll(Msg msg)
-
sendToMatching
public boolean sendToMatching(Msg msg)
-
distribute
private void distribute(Msg msg)
-
hasOut
public boolean hasOut()
-
checkHwm
public boolean checkHwm()
-
active
int active()
-
eligible
int eligible()
-
matching
int matching()
-
-