Class JChannelManager
- java.lang.Object
-
- org.apache.activemq.artemis.api.core.jgroups.JChannelManager
-
public class JChannelManager extends Object
This class maintain a global Map of JChannels wrapped in JChannelWrapper for the purpose of reference counting. Wherever a JChannel is needed it should only get it by calling the getChannel() method of this class. The real disconnect of channels are also done here only.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description JChannelManager
clear()
static JChannelManager
getInstance()
JChannelWrapper
getJChannel(String channelName, JGroupsBroadcastEndpoint endpoint)
boolean
isLoopbackMessages()
void
removeChannel(String channelName)
JChannelManager
setLoopbackMessages(boolean loopbackMessages)
-
-
-
Method Detail
-
getInstance
public static JChannelManager getInstance()
-
clear
public JChannelManager clear()
-
isLoopbackMessages
public boolean isLoopbackMessages()
-
setLoopbackMessages
public JChannelManager setLoopbackMessages(boolean loopbackMessages)
-
getJChannel
public JChannelWrapper getJChannel(String channelName, JGroupsBroadcastEndpoint endpoint) throws Exception
- Throws:
Exception
-
removeChannel
public void removeChannel(String channelName)
-
-