Package org.jgroups.jmx

Class JChannel

java.lang.Object

org.jgroups.jmx.JChannel

All Implemented Interfaces:

JChannelMBean

public class JChannel
extends Object
implements JChannelMBean

Version:

$Id: JChannel.java,v 1.17 2007/06/06 11:02:32 belaban Exp $

Author:

Bela Ban

Constructor Summary

Constructors

Constructor	Description
JChannel()
JChannel(JChannel channel)

Method Summary

Modifier and Type	Method	Description
void	addChannelListener(ChannelListener listener)
void	blockOk()
void	close()
void	connect(String channel_name)
void	create()
void	destroy()
void	disconnect()
void	down(Event evt)
String	dumpQueue()
Map	dumpStats()
String	dumpTimerQueue()
boolean	getAutoGetState()
boolean	getAutoReconnect()
JChannel	getChannel()
String	getClusterName()
String	getGroupName()
Address	getLocalAddress()
String	getLocalAddressAsString()
String	getMBeanServerName()
int	getNumberOfTasksInTimer()
int	getNumMessages()
String	getObjectName()
String	getProperties()
boolean	getReceiveBlockEvents()
long	getReceivedBytes()
long	getReceivedMessages()
boolean	getReceiveLocalMessages()
long	getSentBytes()
long	getSentMessages()
boolean	getState(Address target, long timeout)
boolean	getStatsEnabled()
int	getTimerThreads()
String	getVersion()
View	getView()
String	getViewAsString()
boolean	isConnected()
boolean	isOpen()
Object	peek(long timeout)
String	printProtocolSpec(boolean include_properties)
Object	receive(long timeout)
void	removeChannelListener(ChannelListener l)
void	resetStats()
void	returnState(byte[] state)
void	returnState(byte[] state, String state_id)
void	send(Address dst, Address src, Serializable obj)
void	send(Message msg)
void	sendToAll(String msg)
void	setAutoGetState(boolean flag)
void	setAutoReconnect(boolean flag)
void	setChannelListener(ChannelListener channel_listener)	Deprecated. Use addChannelListener() instead
void	setClusterConfig(Element config)	To configure via XML file
void	setClusterName(String cluster_name)
void	setGroupName(String group_name)
void	setMBeanServerName(String n)
void	setObjectName(String name)
void	setProperties(String props)
void	setReceiveBlockEvents(boolean flag)
void	setReceiveLocalMessages(boolean flag)
void	setStatsEnabled(boolean flag)
protected final void	setValues()
void	shutdown()
void	start()
void	stop()
String	toString(boolean print_details)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JChannel

public JChannel()

JChannel

public JChannel(JChannel channel)

Method Details

setValues

protected final void setValues()

getChannel

public JChannel getChannel()

Specified by:

getChannel in interface JChannelMBean

getVersion

public String getVersion()

Specified by:

getVersion in interface JChannelMBean

getMBeanServerName

public String getMBeanServerName()

setMBeanServerName

public void setMBeanServerName(String n)

getProperties

public String getProperties()

Specified by:

getProperties in interface JChannelMBean

setProperties

public void setProperties(String props)

Specified by:

setProperties in interface JChannelMBean

getObjectName

public String getObjectName()

Specified by:

getObjectName in interface JChannelMBean

setObjectName

public void setObjectName(String name)

Specified by:

setObjectName in interface JChannelMBean

getNumberOfTasksInTimer

public int getNumberOfTasksInTimer()

Specified by:

getNumberOfTasksInTimer in interface JChannelMBean

dumpTimerQueue

public String dumpTimerQueue()

Specified by:

dumpTimerQueue in interface JChannelMBean

setClusterConfig

public void setClusterConfig(Element config)

Description copied from interface: JChannelMBean

To configure via XML file

Specified by:

setClusterConfig in interface JChannelMBean

getGroupName

public String getGroupName()

Specified by:

getGroupName in interface JChannelMBean

setGroupName

public void setGroupName(String group_name)

Specified by:

setGroupName in interface JChannelMBean

getClusterName

public String getClusterName()

Specified by:

getClusterName in interface JChannelMBean

setClusterName

public void setClusterName(String cluster_name)

Specified by:

setClusterName in interface JChannelMBean

getReceiveBlockEvents

public boolean getReceiveBlockEvents()

Specified by:

getReceiveBlockEvents in interface JChannelMBean

setReceiveBlockEvents

public void setReceiveBlockEvents(boolean flag)

Specified by:

setReceiveBlockEvents in interface JChannelMBean

getReceiveLocalMessages

public boolean getReceiveLocalMessages()

Specified by:

getReceiveLocalMessages in interface JChannelMBean

setReceiveLocalMessages

public void setReceiveLocalMessages(boolean flag)

Specified by:

setReceiveLocalMessages in interface JChannelMBean

getAutoReconnect

public boolean getAutoReconnect()

Specified by:

getAutoReconnect in interface JChannelMBean

setAutoReconnect

public void setAutoReconnect(boolean flag)

Specified by:

setAutoReconnect in interface JChannelMBean

getAutoGetState

public boolean getAutoGetState()

Specified by:

getAutoGetState in interface JChannelMBean

setAutoGetState

public void setAutoGetState(boolean flag)

Specified by:

setAutoGetState in interface JChannelMBean

getStatsEnabled

public boolean getStatsEnabled()

Specified by:

getStatsEnabled in interface JChannelMBean

setStatsEnabled

public void setStatsEnabled(boolean flag)

Specified by:

setStatsEnabled in interface JChannelMBean

dumpStats

public Map dumpStats()

Specified by:

dumpStats in interface JChannelMBean

resetStats

public void resetStats()

Specified by:

resetStats in interface JChannelMBean

getSentMessages

public long getSentMessages()

Specified by:

getSentMessages in interface JChannelMBean

getSentBytes

public long getSentBytes()

Specified by:

getSentBytes in interface JChannelMBean

getReceivedMessages

public long getReceivedMessages()

Specified by:

getReceivedMessages in interface JChannelMBean

getReceivedBytes

public long getReceivedBytes()

Specified by:

getReceivedBytes in interface JChannelMBean

getTimerThreads

public int getTimerThreads()

Specified by:

getTimerThreads in interface JChannelMBean

create

public void create()
            throws Exception

Specified by:

create in interface JChannelMBean

Throws:

Exception

start

public void start()
           throws Exception

Specified by:

start in interface JChannelMBean

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface JChannelMBean

destroy

public void destroy()

Specified by:

destroy in interface JChannelMBean

getView

public View getView()

Specified by:

getView in interface JChannelMBean

getViewAsString

public String getViewAsString()

Specified by:

getViewAsString in interface JChannelMBean

getLocalAddress

public Address getLocalAddress()

Specified by:

getLocalAddress in interface JChannelMBean

getLocalAddressAsString

public String getLocalAddressAsString()

Specified by:

getLocalAddressAsString in interface JChannelMBean

setChannelListener

public void setChannelListener(ChannelListener channel_listener)

Deprecated.

Use addChannelListener() instead

Specified by:

setChannelListener in interface JChannelMBean

addChannelListener

public void addChannelListener(ChannelListener listener)

removeChannelListener

public void removeChannelListener(ChannelListener l)

isOpen

public boolean isOpen()

Specified by:

isOpen in interface JChannelMBean

isConnected

public boolean isConnected()

Specified by:

isConnected in interface JChannelMBean

getNumMessages

public int getNumMessages()

Specified by:

getNumMessages in interface JChannelMBean

dumpQueue

public String dumpQueue()

Specified by:

dumpQueue in interface JChannelMBean

printProtocolSpec

public String printProtocolSpec(boolean include_properties)

Specified by:

printProtocolSpec in interface JChannelMBean

toString

public String toString(boolean print_details)

Specified by:

toString in interface JChannelMBean

connect

public void connect(String channel_name)
             throws ChannelException

Specified by:

connect in interface JChannelMBean

Throws:

ChannelException

disconnect

public void disconnect()

Specified by:

disconnect in interface JChannelMBean

close

public void close()

Specified by:

close in interface JChannelMBean

shutdown

public void shutdown()

Specified by:

shutdown in interface JChannelMBean

send

public void send(Message msg)
          throws ChannelNotConnectedException,
ChannelClosedException

Specified by:

send in interface JChannelMBean

Throws:

ChannelNotConnectedException

ChannelClosedException

send

public void send(Address dst,
 Address src,
 Serializable obj)
          throws ChannelNotConnectedException,
ChannelClosedException

Specified by:

send in interface JChannelMBean

Throws:

ChannelNotConnectedException

ChannelClosedException

sendToAll

public void sendToAll(String msg)
               throws ChannelNotConnectedException,
ChannelClosedException

Specified by:

sendToAll in interface JChannelMBean

Throws:

ChannelNotConnectedException

ChannelClosedException

down

public void down(Event evt)

Specified by:

down in interface JChannelMBean

Parameters:

evt -

receive

public Object receive(long timeout)
               throws ChannelNotConnectedException,
ChannelClosedException,
TimeoutException

Specified by:

receive in interface JChannelMBean

Throws:

ChannelNotConnectedException

ChannelClosedException

TimeoutException

peek

public Object peek(long timeout)
            throws ChannelNotConnectedException,
ChannelClosedException,
TimeoutException

Specified by:

peek in interface JChannelMBean

Throws:

ChannelNotConnectedException

ChannelClosedException

TimeoutException

blockOk

public void blockOk()

Specified by:

blockOk in interface JChannelMBean

getState

public boolean getState(Address target,
 long timeout)
                 throws ChannelNotConnectedException,
ChannelClosedException

Specified by:

getState in interface JChannelMBean

Throws:

ChannelNotConnectedException

ChannelClosedException

returnState

public void returnState(byte[] state)

Specified by:

returnState in interface JChannelMBean

returnState

public void returnState(byte[] state,
 String state_id)

Specified by:

returnState in interface JChannelMBean