Prev Class | Next Class | Frames | No Frames |
Summary: Nested | Field | Method | Constr | Detail: Nested | Field | Method | Constr |
java.lang.Object
org.jgroups.Channel
org.jgroups.EnsChannel
Field Summary | |
protected Log |
Fields inherited from class org.jgroups.Channel | |
AUTO_GETSTATE , AUTO_RECONNECT , BLOCK , GET_STATE_EVENTS , LOCAL , SUSPECT , VIEW , channel_listener , up_handler |
Constructor Summary | |
| |
|
Method Summary | |
void |
|
void |
|
void |
|
void |
|
void |
|
void | |
void |
|
boolean |
|
String | |
Address | |
Object |
|
boolean | |
View |
|
void |
|
boolean | |
boolean |
|
Object |
|
Object |
|
void |
|
void |
|
void |
|
void | |
void | |
void |
|
Methods inherited from class org.jgroups.Channel | |
blockOk , close , connect , disconnect , down , getAllStates , getChannelName , getLocalAddress , getNumMessages , getOpt , getState , getView , isConnected , isOpen , open , option2String , peek , receive , returnState , send , send , setChannelListener , setOpt , setUpHandler |
public EnsChannel(Object props) throws ChannelException
Creates a new EnsChannel, which spawns an outboard process and connects to it.
- Parameters:
props
- Ensemble properties (cf. Ensemble reference manual). A value ofnull
uses the default properties.
public EnsChannel(Object props, String transport_props, int outboard_port) throws ChannelException
Creates a new EnsChannel. Instead of spawning a new outboard process, it connects to an already running outboard process (on the same machine) usingoutboard_port
. This allows multiple EnsChannels to share a copy of outboard. If the port is 0, outboard will be spawned. Parametertransport_props
defines the type of transport to be used (UDP, ATM, IP MCAST etc).
- Parameters:
props
- Ensemble properties (cf. Ensemble reference manual). A value ofnull
uses the default properties.transport_props
- Transport parameters.Null
means use default (UDP). Example:"UDP:DEERING"
uses IP multicast (gossip is not needed in this case).outboard_port
- Port on which the local outboard process is listening. The outboard process has to be started before. Value of 0 means spawn outboard nevertheless.
public void acceptedView(Hot_GroupContext gctx, Object env, Hot_ViewState viewState)
- Specified by:
- acceptedView in interface Hot_Callbacks
public void block(Hot_GroupContext gctx, Object env)
- Specified by:
- block in interface Hot_Callbacks
public boolean getAllStates(Vector targets, long timeout)
- Overrides:
- getAllStates in interface Channel
public void heartbeat(Hot_GroupContext gctx, Object env, int rate)
- Specified by:
- heartbeat in interface Hot_Callbacks
public Object peek(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException
public Object receive(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException
public void receiveCast(Hot_GroupContext gctx, Object env, Hot_Endpoint origin, Hot_Message msg)
- Specified by:
- receiveCast in interface Hot_Callbacks
public void receiveSend(Hot_GroupContext gctx, Object env, Hot_Endpoint origin, Hot_Message msg)
- Specified by:
- receiveSend in interface Hot_Callbacks
public void send(Address dst, Address src, Serializable obj) throws ChannelNotConnectedException, ChannelClosedException