Class
Tree
          
SUMMARY: INNER | FIELD | CONSTR | METHODDETAIL: FIELD | CONSTR | METHOD
  
com.newstep.solid.replication
Class MulticastChannel
public class MulticastChannel      
MulticastChannel sends and receives replication control messages on behalf of
its clients. There is a single multicast channel per replication node.
Author:
dpetroni
 
Links:
Kernel Association Association Link
to Interface MulticastChannelListener
Associates type:
association
Client cardinality:
1
Client navigability:
NOT NAVIGABLE
Client visibility:
private
Supplier cardinality:
1
Supplier navigability:
NAVIGABLE
Supplier visibility:
private
 
 
Field Summary
int
String
int
private byte[]
private final static String
private boolean
private final static Logger
private InetAddress
private String
private int
private byte[]
private String
private String
private byte[]
private String
private String
private MulticastSocket
private int
private int
Method Summary
public void
public int
public void
protected void
public byte[]
public void
public void
send(Byte message)
public void
setMulticastGroupAddress(String mcastGroupAddress)
public void
setMulticastGroupPort(Integer mcastGroupPort)
public void
setTimeOutMillis(Integer timeOut)
public void
public void
public void
Field Detail
buffer
private byte[] buffer
single receive buffer
Multiplicity:
1
 
className
private final static String className
Final.
Multiplicity:
1
Static.
 
dontStop
private boolean dontStop
loop control
Multiplicity:
1
 
listener
private MulticastChannelListener listener
Multiplicity:
1
 
logger
private final static Logger logger
Final.
Multiplicity:
1
Static.
 
multicastGroup
private InetAddress multicastGroup
address for this replication group
Multiplicity:
1
 
multicastGroupAddress
String multicastGroupAddress
address for this replication group in string format
 
multicastGroupAddress
private String multicastGroupAddress
address for this replication group in string format
Multiplicity:
1
 
multicastGroupPort
int multicastGroupPort
port for this replication group
 
multicastGroupPort
private int multicastGroupPort
port for this replication group
Multiplicity:
1
 
primaryLocalAddress
private byte[] primaryLocalAddress
Multiplicity:
1
 
primaryNicAddress
private String primaryNicAddress
Primary network interface's IP address
Multiplicity:
1
 
primaryNicName
private String primaryNicName
Primary network interface to use for multicasting
Multiplicity:
1
 
secondaryLocalAddress
private byte[] secondaryLocalAddress
Multiplicity:
1
 
secondaryNicAddress
private String secondaryNicAddress
Secondary network interface's IP address
Multiplicity:
1
 
secondaryNicName
private String secondaryNicName
Secondary network interface to use for multicasting
Multiplicity:
1
 
socket
private MulticastSocket socket
Multiplicity:
1
 
timeOutMillis
int timeOutMillis
How long to wait for response during the initaial id negotiations
 
timeOutMillis
private int timeOutMillis
How long to wait for response during the initaial id negotiations
Multiplicity:
1
 
timeToLive
private int timeToLive
time to live for the replication messages
Multiplicity:
1
 
Method Detail
addListener
public void addListener (MulticastChannelListener mcl)
 
 
getTimeOutMillis
public int getTimeOutMillis ()
 
 
initialize
public void initialize (MulticastChannelConfig config)
 
MulticastChannel must be initialized with proper configuration before it
can be used. During the initalization it joins the configured multicast
group and obtains a unique id within the group
Parameters:
config
configuration containing all the necessary config parameters
Throws:
ConfigurationException
 
multicastListen
protected void multicastListen ()
 
Listens for incomming messages in a while ( dontStop ) loop
 
multicastReceive
public byte[] multicastReceive ()
 
Receives a message blocking for the duration of the socket timeout or
indefinitely if socket timeout is 0
Return:
replication message
 
removeListener
public void removeListener (MulticastChannelListener mcl)
 
 
send
public void send (Byte message)
 
Sends a message
Parameters:
message
byte array containg the message to be sent
 
setMulticastGroupAddress
public void setMulticastGroupAddress (String mcastGroupAddress)
 
 
setMulticastGroupPort
public void setMulticastGroupPort (Integer mcastGroupPort)
 
 
setTimeOutMillis
public void setTimeOutMillis (Integer timeOut)
 
 
start
public void start ()
 
 
stop
public void stop ()
 
 
stopListening
public void stopListening ()
 
 
Class
Tree
          
SUMMARY: INNER | FIELD | CONSTR | METHODDETAIL: FIELD | CONSTR | METHOD