org.jgroups.protocols
Class SHUFFLE
- Runnable
public class SHUFFLE
implements Runnable
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.
down_handler, down_prot, down_queue, down_thread, down_thread_prio, log, observer, props, stack, stats, trace, up_handler, up_prot, up_queue, up_thread, up_thread_prio, warn |
String | getName()
|
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.
|
boolean | setProperties(Properties props)- Configures the protocol initially.
|
void | start()- Starts the
messagesHandler<\code>
|
void | stop()- Stops the messagesHandler
|
void | up(Event evt)- Adds upcoming messages to the
messages List<\code> where the messagesHandler<\code>
retrieves them.
|
destroy, down, downThreadEnabled, dumpStats, enableStats, getDownProtocol, getDownQueue, getName, getProperties, getUpProtocol, getUpQueue, handleSpecialDownEvent, init, isTrace, isWarn, passDown, passUp, printStats, providedDownServices, providedUpServices, receiveDownEvent, receiveUpEvent, requiredDownServices, requiredUpServices, resetStats, setDownProtocol, setObserver, setProperties, setPropertiesInternal, setProtocolStack, setTrace, setUpProtocol, setWarn, start, startDownHandler, startUpHandler, statsEnabled, stop, stopInternal, up, upThreadEnabled |
run
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.
setProperties
public boolean setProperties(Properties props)
Configures the protocol initially. A configuration string consists of name=value
items, separated by a ';' (semicolon), e.g.:
"loopback=false;unicast_inport=4444"
- setProperties in interface Protocol
start
public void start()
throws Exception Starts the messagesHandler<\code>
- start in interface Protocol
stop
public void stop()
Stops the messagesHandler
- stop in interface Protocol
up
public void up(Event evt)
Adds upcoming messages to the messages List<\code> where the messagesHandler<\code>
retrieves them.
- up in interface Protocol
Copyright B) 1998-2005 Bela Ban. All Rights Reserved.