| |
|
| java.lang.Object java.lang.Thread org.jgroups.stack.UpHandler org.jgroups.protocols.SHUFFLE
SHUFFLE | public class SHUFFLE extends Protocol implements Runnable(Code) | | This layer shuffles upcoming messages, put it just above your bottom layer.
If you system sends less than 2 messages per sec you can notice a latency due
to this layer.
author: Gianluca Collot |
Constructor Summary | |
public | SHUFFLE() |
Method Summary | |
public String | getName() | int | rnd(int n) | public void | run() Removes a random chosen message from the messages List<\code> if there
are less than 10 messages in the List it waits some time to ensure to chose from
a set of messages > 1. | public boolean | setProperties(Properties props) | public void | start() | public void | stop() | public void | up(Event evt) Adds upcoming messages to the messages List<\code> where the messagesHandler<\code>
retrieves them. |
run | public void run()(Code) | | Removes a random chosen message from the messages List<\code> if there
are less than 10 messages in the List it waits some time to ensure to chose from
a set of messages > 1.
|
start | public void start() throws Exception(Code) | | Starts the messagesHandler<\code>
|
stop | public void stop()(Code) | | Stops the messagesHandler
|
up | public void up(Event evt)(Code) | | Adds upcoming messages to the messages List<\code> where the messagesHandler<\code>
retrieves them.
|
Fields inherited from org.jgroups.stack.UpHandler | final protected Log log(Code)(Java Doc)
|
|
|
|