public class PARTITIONER extends Protocol
Modifier and Type | Class and Description |
---|---|
static class |
PARTITIONER.PartitionerHeader
The Partitioner header normally (type = NORMAL) contains just the partition number that is checked to discard messages
received from other partitions.
|
down_handler, down_prot, down_queue, down_thread, down_thread_prio, log, observer, props, stack, stats, up_handler, up_prot, up_queue, up_thread, up_thread_prio
Constructor and Description |
---|
PARTITIONER() |
Modifier and Type | Method and Description |
---|---|
void |
down(Event evt)
Adds to Messages a Header with the local partitin number and if receives a SET_PARTITIONS Event sends
a new Message with a PartitionerHeader set to COMMAND that carries the Hashtable
|
java.lang.String |
getName()
All protocol names have to be unique !
|
void |
reset()
Just remove if you don't need to reset any state
|
boolean |
setProperties(java.util.Properties props)
Configures the protocol initially.
|
void |
up(Event evt)
Discards Messages with the wrong partition number and sets local partition number if
it receives a COMMAND Header
|
destroy, downThreadEnabled, dumpStats, enableStats, getDownProtocol, getDownQueue, getProperties, getUpProtocol, getUpQueue, handleSpecialDownEvent, init, passDown, passUp, printStats, providedDownServices, providedUpServices, receiveDownEvent, receiveUpEvent, requiredDownServices, requiredUpServices, resetStats, setDownProtocol, setObserver, setPropertiesInternal, setProtocolStack, setUpProtocol, start, startDownHandler, startUpHandler, statsEnabled, stop, stopInternal, upThreadEnabled
public java.lang.String getName()
public boolean setProperties(java.util.Properties props)
Protocol
"loopback=false;unicast_inport=4444"
setProperties
in class Protocol
public void reset()
public void up(Event evt)
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.