| java.lang.Object
 org.jgroups.stack.GossipRouter
| GossipRouter | | public class GossipRouter (Code) | | Router for TCP based group comunication (using layer TCP instead of UDP).
Instead of the TCP layer sending packets point-to-point to each other
member, it sends the packet to the router which - depending on the target
address - multicasts or unicasts it to the group / or single member.
This class is especially interesting for applets which cannot directly make
connections (neither UDP nor TCP) to a host different from the one they were
loaded from. Therefore, an applet would create a normal channel plus
protocol stack, but the bottom layer would have to be the TCP layer which
sends all packets point-to-point (over a TCP connection) to the router,
which in turn forwards them to their end location(s) (also over TCP). A
centralized router would therefore have to be running on the host the applet
was loaded from.
An alternative for running JGroups in an applet (IP multicast is not allows
in applets as of 1.2), is to use point-to-point UDP communication via the
gossip server. However, then the appplet has to be signed which involves
additional administrative effort on the part of the user.
author:
Bela Ban
author:
Ovidiu Feodorov
since:
2.1.1 |
| Inner Class :class AddressEntry | |
| Inner Class :class SocketThread extends Thread | |
| CONNECT | | final public static byte CONNECT(Code) | | |
| DISCONNECT | | final public static byte DISCONNECT(Code) | | |
| DUMP | | final public static byte DUMP(Code) | | |
| EXPIRY_TIME | | final public static long EXPIRY_TIME(Code) | | |
| GET_RSP | | final public static byte GET_RSP(Code) | | |
| GOSSIP_GET | | final public static byte GOSSIP_GET(Code) | | |
| GOSSIP_REQUEST_TIMEOUT | | final public static long GOSSIP_REQUEST_TIMEOUT(Code) | | |
| PORT | | final public static int PORT(Code) | | |
| REGISTER | | final public static byte REGISTER(Code) | | |
| ROUTER_GET | | final public static byte ROUTER_GET(Code) | | |
| ROUTING_CLIENT_REPLY_TIMEOUT | | final public static long ROUTING_CLIENT_REPLY_TIMEOUT(Code) | | |
| SHUTDOWN | | final public static byte SHUTDOWN(Code) | | |
| UNREGISTER | | final public static byte UNREGISTER(Code) | | |
| log | | final protected Log log(Code) | | |
| GossipRouter | | public GossipRouter()(Code) | | |
| GossipRouter | | public GossipRouter(int port)(Code) | | |
| GossipRouter | | public GossipRouter(int port, String bindAddressString)(Code) | | |
| GossipRouter | | public GossipRouter(int port, String bindAddressString, long expiryTime)(Code) | | |
| GossipRouter | | public GossipRouter(int port, String bindAddressString, long expiryTime, long gossipRequestTimeout, long routingClientReplyTimeout)(Code) | | |
| create | | public void create() throws Exception(Code) | | JBoss MBean lifecycle operation.
|
| destroy | | public void destroy()(Code) | | JBoss MBean lifecycle operation.
|
| getExpiryTime | | public long getExpiryTime()(Code) | | |
| getGossipRequestTimeout | | public long getGossipRequestTimeout()(Code) | | |
| getPort | | public int getPort()(Code) | | |
| getRoutingClientReplyTimeout | | public long getRoutingClientReplyTimeout()(Code) | | |
| isDiscardLoopbacks | | public boolean isDiscardLoopbacks()(Code) | | |
| isStarted | | public boolean isStarted()(Code) | | |
| setBindAddress | | public void setBindAddress(String bindAddress)(Code) | | |
| setDiscardLoopbacks | | public void setDiscardLoopbacks(boolean discard_loopbacks)(Code) | | |
| setExpiryTime | | public void setExpiryTime(long expiryTime)(Code) | | |
| setGossipRequestTimeout | | public void setGossipRequestTimeout(long gossipRequestTimeout)(Code) | | |
| setPort | | public void setPort(int port)(Code) | | |
| setRoutingClientReplyTimeout | | public void setRoutingClientReplyTimeout(long routingClientReplyTimeout)(Code) | | |
| start | | public void start() throws Exception(Code) | | JBoss MBean lifecycle operation. Called after create(). When this method
is called, the managed attributes have already been set.
Brings the Router in fully functional state.
|
| stop | | public void stop()(Code) | | JBoss MBean lifecycle operation. The JMX agent allways calls this method
before destroy(). Close connections and frees resources.
|
|
|