|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jgroups.mux.Multiplexer
public class Multiplexer
Used for dispatching incoming messages. The Multiplexer implements UpHandler and registers with the associated JChannel (there can only be 1 Multiplexer per JChannel). When up() is called with a message, the header of the message is removed and the MuxChannel corresponding to the header's service ID is retrieved from the map, and MuxChannel.up() is called with the message.
Constructor Summary | |
---|---|
Multiplexer()
|
|
Multiplexer(JChannel channel)
|
Method Summary | |
---|---|
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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Multiplexer()
public Multiplexer(JChannel channel)
Method Detail |
---|
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
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
up
in interface 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)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |