| java.lang.Object java.lang.Thread org.jgroups.stack.UpHandler org.jgroups.protocols.WANPIPE
WANPIPE | public class WANPIPE extends Protocol implements LogicalLink.Receiver(Code) | | Logical point-to-point link. Uses multiple physical links to provide a reliable transport. For example,
if there are 2 physical links over different networks, and one of them fails, the WAN pipe will still be
able to send traffic over the other link. Currently traffic is sent over the physical links round-robin,
but this will be made configurable in the future. Example: 70% over first link, 30% over second, or
packets are split and sent across both links (increasing the available bandwidth).
|
Inner Class :public class WanPipeHeader extends Header | |
Constructor Summary | |
public | WANPIPE() |
Method Summary | |
public void | down(Event evt) Sent to destination(s) using the WAN pipe. | public String | getName() | Object | getPeer() | public void | linkDown(InetAddress local, int local_port, InetAddress remote, int remote_port) | public void | linkUp(InetAddress local, int local_port, InetAddress remote, int remote_port) | public void | missedHeartbeat(InetAddress local, int local_port, InetAddress remote, int remote_port, int num_hbs) | boolean | parseLinks(String s) | public void | receive(byte[] buf) | public void | receivedHeartbeatAgain(InetAddress local, int local_port, InetAddress remote, int remote_port) | void | returnLocal(Message msg) | public boolean | setProperties(Properties props) | public void | start() | public void | stop() | public String | toString() |
down | public void down(Event evt)(Code) | | Sent to destination(s) using the WAN pipe. Send local messages directly back up the stack
|
parseLinks | boolean parseLinks(String s)(Code) | | Parse link spec and put each link into 'links' (as LinkInfo)
Example: [daddy@6666,daddy@7777,daddy@7777,sindhu@6666]
|
receive | public void receive(byte[] buf)(Code) | | |
returnLocal | void returnLocal(Message msg)(Code) | | Make a response and send back up the same stack it came down
|
setProperties | public boolean setProperties(Properties props)(Code) | | Setup the Protocol instance acording to the configuration string
|
Fields inherited from org.jgroups.stack.UpHandler | final protected Log log(Code)(Java Doc)
|
|
|