org.jgroups.protocols

Class WANPIPE

public class WANPIPE extends Protocol implements LogicalLink.Receiver

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).
Nested Class Summary
classWANPIPE.WanPipeHeader
Constructor Summary
WANPIPE()
Method Summary
voiddown(Event evt)
Sent to destination(s) using the WAN pipe.
StringgetName()
voidlinkDown(InetAddress local, int local_port, InetAddress remote, int remote_port)
voidlinkUp(InetAddress local, int local_port, InetAddress remote, int remote_port)
voidmissedHeartbeat(InetAddress local, int local_port, InetAddress remote, int remote_port, int num_hbs)
voidreceive(byte[] buf)
voidreceivedHeartbeatAgain(InetAddress local, int local_port, InetAddress remote, int remote_port)
booleansetProperties(Properties props)
Setup the Protocol instance acording to the configuration string
voidstart()
voidstop()
StringtoString()

Constructor Detail

WANPIPE

public WANPIPE()

Method Detail

down

public void down(Event evt)
Sent to destination(s) using the WAN pipe. Send local messages directly back up the stack

getName

public String getName()

linkDown

public void linkDown(InetAddress local, int local_port, InetAddress remote, int remote_port)

linkUp

public void linkUp(InetAddress local, int local_port, InetAddress remote, int remote_port)

missedHeartbeat

public void missedHeartbeat(InetAddress local, int local_port, InetAddress remote, int remote_port, int num_hbs)

receive

public void receive(byte[] buf)

receivedHeartbeatAgain

public void receivedHeartbeatAgain(InetAddress local, int local_port, InetAddress remote, int remote_port)

setProperties

public boolean setProperties(Properties props)
Setup the Protocol instance acording to the configuration string

start

public void start()

stop

public void stop()

toString

public String toString()
Copyright ? 1998-2005 Bela Ban. All Rights Reserved.