Package org.jgroups.jmx
Class JChannel
- java.lang.Object
-
- org.jgroups.jmx.JChannel
-
- All Implemented Interfaces:
JChannelMBean
public class JChannel extends java.lang.Object implements JChannelMBean
- Version:
- $Id: JChannel.java,v 1.17 2007/06/06 11:02:32 belaban Exp $
- Author:
- Bela Ban
-
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description void
addChannelListener(ChannelListener listener)
void
blockOk()
void
close()
void
connect(java.lang.String channel_name)
void
create()
void
destroy()
void
disconnect()
void
down(Event evt)
java.lang.String
dumpQueue()
java.util.Map
dumpStats()
java.lang.String
dumpTimerQueue()
boolean
getAutoGetState()
boolean
getAutoReconnect()
JChannel
getChannel()
java.lang.String
getClusterName()
java.lang.String
getGroupName()
Address
getLocalAddress()
java.lang.String
getLocalAddressAsString()
java.lang.String
getMBeanServerName()
int
getNumberOfTasksInTimer()
int
getNumMessages()
java.lang.String
getObjectName()
java.lang.String
getProperties()
boolean
getReceiveBlockEvents()
long
getReceivedBytes()
long
getReceivedMessages()
boolean
getReceiveLocalMessages()
long
getSentBytes()
long
getSentMessages()
boolean
getState(Address target, long timeout)
boolean
getStatsEnabled()
int
getTimerThreads()
java.lang.String
getVersion()
View
getView()
java.lang.String
getViewAsString()
boolean
isConnected()
boolean
isOpen()
java.lang.Object
peek(long timeout)
java.lang.String
printProtocolSpec(boolean include_properties)
java.lang.Object
receive(long timeout)
void
removeChannelListener(ChannelListener l)
void
resetStats()
void
returnState(byte[] state)
void
returnState(byte[] state, java.lang.String state_id)
void
send(Address dst, Address src, java.io.Serializable obj)
void
send(Message msg)
void
sendToAll(java.lang.String msg)
void
setAutoGetState(boolean flag)
void
setAutoReconnect(boolean flag)
void
setChannelListener(ChannelListener channel_listener)
Deprecated.Use addChannelListener() insteadvoid
setClusterConfig(org.w3c.dom.Element config)
To configure via XML filevoid
setClusterName(java.lang.String cluster_name)
void
setGroupName(java.lang.String group_name)
void
setMBeanServerName(java.lang.String n)
void
setObjectName(java.lang.String name)
void
setProperties(java.lang.String props)
void
setReceiveBlockEvents(boolean flag)
void
setReceiveLocalMessages(boolean flag)
void
setStatsEnabled(boolean flag)
protected void
setValues()
void
shutdown()
void
start()
void
stop()
java.lang.String
toString(boolean print_details)
-
-
-
Constructor Detail
-
JChannel
public JChannel()
-
JChannel
public JChannel(JChannel channel)
-
-
Method Detail
-
setValues
protected final void setValues()
-
getChannel
public JChannel getChannel()
- Specified by:
getChannel
in interfaceJChannelMBean
-
getVersion
public java.lang.String getVersion()
- Specified by:
getVersion
in interfaceJChannelMBean
-
getMBeanServerName
public java.lang.String getMBeanServerName()
-
setMBeanServerName
public void setMBeanServerName(java.lang.String n)
-
getProperties
public java.lang.String getProperties()
- Specified by:
getProperties
in interfaceJChannelMBean
-
setProperties
public void setProperties(java.lang.String props)
- Specified by:
setProperties
in interfaceJChannelMBean
-
getObjectName
public java.lang.String getObjectName()
- Specified by:
getObjectName
in interfaceJChannelMBean
-
setObjectName
public void setObjectName(java.lang.String name)
- Specified by:
setObjectName
in interfaceJChannelMBean
-
getNumberOfTasksInTimer
public int getNumberOfTasksInTimer()
- Specified by:
getNumberOfTasksInTimer
in interfaceJChannelMBean
-
dumpTimerQueue
public java.lang.String dumpTimerQueue()
- Specified by:
dumpTimerQueue
in interfaceJChannelMBean
-
setClusterConfig
public void setClusterConfig(org.w3c.dom.Element config)
Description copied from interface:JChannelMBean
To configure via XML file- Specified by:
setClusterConfig
in interfaceJChannelMBean
-
getGroupName
public java.lang.String getGroupName()
- Specified by:
getGroupName
in interfaceJChannelMBean
-
setGroupName
public void setGroupName(java.lang.String group_name)
- Specified by:
setGroupName
in interfaceJChannelMBean
-
getClusterName
public java.lang.String getClusterName()
- Specified by:
getClusterName
in interfaceJChannelMBean
-
setClusterName
public void setClusterName(java.lang.String cluster_name)
- Specified by:
setClusterName
in interfaceJChannelMBean
-
getReceiveBlockEvents
public boolean getReceiveBlockEvents()
- Specified by:
getReceiveBlockEvents
in interfaceJChannelMBean
-
setReceiveBlockEvents
public void setReceiveBlockEvents(boolean flag)
- Specified by:
setReceiveBlockEvents
in interfaceJChannelMBean
-
getReceiveLocalMessages
public boolean getReceiveLocalMessages()
- Specified by:
getReceiveLocalMessages
in interfaceJChannelMBean
-
setReceiveLocalMessages
public void setReceiveLocalMessages(boolean flag)
- Specified by:
setReceiveLocalMessages
in interfaceJChannelMBean
-
getAutoReconnect
public boolean getAutoReconnect()
- Specified by:
getAutoReconnect
in interfaceJChannelMBean
-
setAutoReconnect
public void setAutoReconnect(boolean flag)
- Specified by:
setAutoReconnect
in interfaceJChannelMBean
-
getAutoGetState
public boolean getAutoGetState()
- Specified by:
getAutoGetState
in interfaceJChannelMBean
-
setAutoGetState
public void setAutoGetState(boolean flag)
- Specified by:
setAutoGetState
in interfaceJChannelMBean
-
getStatsEnabled
public boolean getStatsEnabled()
- Specified by:
getStatsEnabled
in interfaceJChannelMBean
-
setStatsEnabled
public void setStatsEnabled(boolean flag)
- Specified by:
setStatsEnabled
in interfaceJChannelMBean
-
dumpStats
public java.util.Map dumpStats()
- Specified by:
dumpStats
in interfaceJChannelMBean
-
resetStats
public void resetStats()
- Specified by:
resetStats
in interfaceJChannelMBean
-
getSentMessages
public long getSentMessages()
- Specified by:
getSentMessages
in interfaceJChannelMBean
-
getSentBytes
public long getSentBytes()
- Specified by:
getSentBytes
in interfaceJChannelMBean
-
getReceivedMessages
public long getReceivedMessages()
- Specified by:
getReceivedMessages
in interfaceJChannelMBean
-
getReceivedBytes
public long getReceivedBytes()
- Specified by:
getReceivedBytes
in interfaceJChannelMBean
-
getTimerThreads
public int getTimerThreads()
- Specified by:
getTimerThreads
in interfaceJChannelMBean
-
create
public void create() throws java.lang.Exception
- Specified by:
create
in interfaceJChannelMBean
- Throws:
java.lang.Exception
-
start
public void start() throws java.lang.Exception
- Specified by:
start
in interfaceJChannelMBean
- Throws:
java.lang.Exception
-
stop
public void stop()
- Specified by:
stop
in interfaceJChannelMBean
-
destroy
public void destroy()
- Specified by:
destroy
in interfaceJChannelMBean
-
getView
public View getView()
- Specified by:
getView
in interfaceJChannelMBean
-
getViewAsString
public java.lang.String getViewAsString()
- Specified by:
getViewAsString
in interfaceJChannelMBean
-
getLocalAddress
public Address getLocalAddress()
- Specified by:
getLocalAddress
in interfaceJChannelMBean
-
getLocalAddressAsString
public java.lang.String getLocalAddressAsString()
- Specified by:
getLocalAddressAsString
in interfaceJChannelMBean
-
setChannelListener
public void setChannelListener(ChannelListener channel_listener)
Deprecated.Use addChannelListener() instead- Specified by:
setChannelListener
in interfaceJChannelMBean
-
addChannelListener
public void addChannelListener(ChannelListener listener)
-
removeChannelListener
public void removeChannelListener(ChannelListener l)
-
isOpen
public boolean isOpen()
- Specified by:
isOpen
in interfaceJChannelMBean
-
isConnected
public boolean isConnected()
- Specified by:
isConnected
in interfaceJChannelMBean
-
getNumMessages
public int getNumMessages()
- Specified by:
getNumMessages
in interfaceJChannelMBean
-
dumpQueue
public java.lang.String dumpQueue()
- Specified by:
dumpQueue
in interfaceJChannelMBean
-
printProtocolSpec
public java.lang.String printProtocolSpec(boolean include_properties)
- Specified by:
printProtocolSpec
in interfaceJChannelMBean
-
toString
public java.lang.String toString(boolean print_details)
- Specified by:
toString
in interfaceJChannelMBean
-
connect
public void connect(java.lang.String channel_name) throws ChannelException
- Specified by:
connect
in interfaceJChannelMBean
- Throws:
ChannelException
-
disconnect
public void disconnect()
- Specified by:
disconnect
in interfaceJChannelMBean
-
close
public void close()
- Specified by:
close
in interfaceJChannelMBean
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceJChannelMBean
-
send
public void send(Message msg) throws ChannelNotConnectedException, ChannelClosedException
- Specified by:
send
in interfaceJChannelMBean
- Throws:
ChannelNotConnectedException
ChannelClosedException
-
send
public void send(Address dst, Address src, java.io.Serializable obj) throws ChannelNotConnectedException, ChannelClosedException
- Specified by:
send
in interfaceJChannelMBean
- Throws:
ChannelNotConnectedException
ChannelClosedException
-
sendToAll
public void sendToAll(java.lang.String msg) throws ChannelNotConnectedException, ChannelClosedException
- Specified by:
sendToAll
in interfaceJChannelMBean
- Throws:
ChannelNotConnectedException
ChannelClosedException
-
down
public void down(Event evt)
- Specified by:
down
in interfaceJChannelMBean
-
receive
public java.lang.Object receive(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException
- Specified by:
receive
in interfaceJChannelMBean
- Throws:
ChannelNotConnectedException
ChannelClosedException
TimeoutException
-
peek
public java.lang.Object peek(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException
- Specified by:
peek
in interfaceJChannelMBean
- Throws:
ChannelNotConnectedException
ChannelClosedException
TimeoutException
-
blockOk
public void blockOk()
- Specified by:
blockOk
in interfaceJChannelMBean
-
getState
public boolean getState(Address target, long timeout) throws ChannelNotConnectedException, ChannelClosedException
- Specified by:
getState
in interfaceJChannelMBean
- Throws:
ChannelNotConnectedException
ChannelClosedException
-
returnState
public void returnState(byte[] state)
- Specified by:
returnState
in interfaceJChannelMBean
-
returnState
public void returnState(byte[] state, java.lang.String state_id)
- Specified by:
returnState
in interfaceJChannelMBean
-
-