@Deprecated public class Multiplexer extends Object implements UpHandler
The multiplexer is essentially a building block residing on top of a JChannel providing multiplexing functionality to N instances of MuxChannel. Since MuxChannel extends the JGroups JChannel class, user applications are completely unaware of this change in the underlying plumbing.
Each JGroups application sharing a channel through a multiplexer has to create a MuxChannel with a unique application id. The multiplexer keeps track of all registered applications and tags messages belonging to a specific application with that id for sent messages. When receiving a message from a remote peer, the multiplexer will dispatch a message to the appropriate MuxChannel depending on the id attached to the message.
MuxChannel
,
Channel
Modifier and Type | Field and Description |
---|---|
protected long |
service_ack_timeout
Deprecated.
|
Constructor and Description |
---|
Multiplexer(JChannel channel)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
close()
Deprecated.
|
void |
closeAll()
Deprecated.
|
Channel |
createMuxChannel(String id,
String stack_name)
Deprecated.
|
protected ThreadPoolExecutor |
createThreadPool()
Deprecated.
|
Set |
getApplicationIds()
Deprecated.
Use ${link #getServiceIds()} instead
|
long |
getServiceAckTimeout()
Deprecated.
|
Set<String> |
getServiceIds()
Deprecated.
|
long |
getServicesResponseTimeout()
Deprecated.
|
void |
registerForStateTransfer(String appl_id,
String substate_id)
Deprecated.
|
protected MuxChannel |
removeService(String id)
Deprecated.
|
void |
setServiceAckTimeout(long service_ack_timeout)
Deprecated.
|
void |
setServicesResponseTimeout(long services_rsp_timeout)
Deprecated.
|
protected void |
shutdownThreadPool()
Deprecated.
|
Object |
up(Event evt)
Deprecated.
Remove mux header and dispatch to correct MuxChannel
|
public Multiplexer(JChannel channel)
public Set getApplicationIds()
public long getServicesResponseTimeout()
public void setServicesResponseTimeout(long services_rsp_timeout)
public long getServiceAckTimeout()
public void setServiceAckTimeout(long service_ack_timeout)
public void registerForStateTransfer(String appl_id, String substate_id)
protected ThreadPoolExecutor createThreadPool()
protected void shutdownThreadPool()
public Channel createMuxChannel(String id, String stack_name) throws Exception
Exception
protected MuxChannel removeService(String id)
public boolean close()
public void closeAll()
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.