public class Multiplexer extends java.lang.Object implements UpHandler
Constructor and Description |
---|
Multiplexer() |
Multiplexer(JChannel channel) |
Modifier and Type | Method and Description |
---|---|
void |
addServiceIfNotPresent(java.lang.String id,
MuxChannel ch) |
void |
blockOk()
Called by a MuxChannel when BLOCK_OK is sent down
|
boolean |
close() |
void |
closeAll() |
Channel |
createMuxChannel(JChannelFactory f,
java.lang.String id,
java.lang.String stack_name) |
void |
disconnect()
Closes the underlying JChannel if all MuxChannels have been disconnected
|
void |
fetchServiceInformation()
Fetches the map of services and hosts from the coordinator (Multiplexer).
|
java.util.Set |
getApplicationIds()
Deprecated.
Use ${link #getServiceIds()} instead
|
java.util.Set |
getServiceIds() |
long |
getServicesResponseTimeout() |
View |
getServiceView(java.lang.String service_id)
Returns a copy of the current view minus the nodes on which service service_id is not running
|
boolean |
getState(Address target,
java.lang.String id,
long timeout) |
Address |
getStateProvider(Address preferredTarget,
java.lang.String service_id)
Returns an Address of a state provider for a given service_id.
|
void |
registerForStateTransfer(java.lang.String appl_id,
java.lang.String substate_id) |
MuxChannel |
remove(java.lang.String id) |
void |
sendServiceDownMessage(java.lang.String service,
Address host,
boolean bypassFlush) |
void |
sendServiceUpMessage(java.lang.String service,
Address host,
boolean bypassFlush) |
void |
setServicesResponseTimeout(long services_rsp_timeout) |
boolean |
shutdown() |
boolean |
stateTransferListenersPresent() |
void |
unregister(java.lang.String appl_id) |
void |
up(Event evt)
Invoked for all channel events except connection management and state transfer.
|
public Multiplexer()
public Multiplexer(JChannel channel)
public java.util.Set getApplicationIds()
public java.util.Set getServiceIds()
public long getServicesResponseTimeout()
public void setServicesResponseTimeout(long services_rsp_timeout)
public View getServiceView(java.lang.String service_id)
service_id
- public boolean stateTransferListenersPresent()
public void blockOk()
public void registerForStateTransfer(java.lang.String appl_id, java.lang.String substate_id)
public boolean getState(Address target, java.lang.String id, long timeout) throws ChannelNotConnectedException, ChannelClosedException
public void fetchServiceInformation() throws java.lang.Exception
java.lang.Exception
public void sendServiceUpMessage(java.lang.String service, Address host, boolean bypassFlush) throws java.lang.Exception
java.lang.Exception
public void sendServiceDownMessage(java.lang.String service, Address host, boolean bypassFlush) throws java.lang.Exception
java.lang.Exception
public void up(Event evt)
UpHandler
public Channel createMuxChannel(JChannelFactory f, java.lang.String id, java.lang.String stack_name) throws java.lang.Exception
java.lang.Exception
public MuxChannel remove(java.lang.String id)
public void disconnect()
public void unregister(java.lang.String appl_id)
public boolean close()
public void closeAll()
public boolean shutdown()
public Address getStateProvider(Address preferredTarget, java.lang.String service_id)
preferredTarget
- service_id
- public void addServiceIfNotPresent(java.lang.String id, MuxChannel ch)
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.