Package org.jgroups.jmx

Interface JChannelMBean

All Known Implementing Classes:

JChannel

public interface JChannelMBean

Version:

$Id: JChannelMBean.java,v 1.11 2007/02/16 07:32:10 belaban Exp $

Author:

Bela Ban

Method Summary

Modifier and Type	Method	Description
void	blockOk()
void	close()
void	connect(String channel_name)
void	create()
void	destroy()
void	disconnect()
void	down(Event evt)	Deprecated.
String	dumpQueue()
Map	dumpStats()
String	dumpTimerQueue()
boolean	getAutoGetState()
boolean	getAutoReconnect()
JChannel	getChannel()
String	getClusterName()
String	getGroupName()
Address	getLocalAddress()
String	getLocalAddressAsString()
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	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)
void	setClusterConfig(Element el)	To configure via XML file
void	setClusterName(String cluster_name)
void	setGroupName(String group_name)
void	setObjectName(String name)
void	setProperties(String props)
void	setReceiveBlockEvents(boolean flag)
void	setReceiveLocalMessages(boolean flag)
void	setStatsEnabled(boolean flag)
void	shutdown()
void	start()
void	stop()
String	toString(boolean print_details)

Method Details

create

void create()
     throws Exception

Throws:

Exception

start

void start()
    throws Exception

Throws:

Exception

stop

void stop()

destroy

void destroy()

getChannel

JChannel getChannel()

getProperties

String getProperties()

setProperties

void setProperties(String props)

getVersion

String getVersion()

getObjectName

String getObjectName()

setObjectName

void setObjectName(String name)

getNumberOfTasksInTimer

int getNumberOfTasksInTimer()

dumpTimerQueue

String dumpTimerQueue()

getTimerThreads

int getTimerThreads()

setClusterConfig

void setClusterConfig(Element el)

To configure via XML file

getGroupName

String getGroupName()

setGroupName

void setGroupName(String group_name)

getClusterName

String getClusterName()

setClusterName

void setClusterName(String cluster_name)

getReceiveBlockEvents

boolean getReceiveBlockEvents()

setReceiveBlockEvents

void setReceiveBlockEvents(boolean flag)

getReceiveLocalMessages

boolean getReceiveLocalMessages()

setReceiveLocalMessages

void setReceiveLocalMessages(boolean flag)

getAutoReconnect

boolean getAutoReconnect()

setAutoReconnect

void setAutoReconnect(boolean flag)

getAutoGetState

boolean getAutoGetState()

setAutoGetState

void setAutoGetState(boolean flag)

dumpStats

Map dumpStats()

getView

View getView()

getViewAsString

String getViewAsString()

getLocalAddress

Address getLocalAddress()

getLocalAddressAsString

String getLocalAddressAsString()

setChannelListener

void setChannelListener(ChannelListener channel_listener)

getStatsEnabled

boolean getStatsEnabled()

setStatsEnabled

void setStatsEnabled(boolean flag)

resetStats

void resetStats()

getSentMessages

long getSentMessages()

getSentBytes

long getSentBytes()

getReceivedMessages

long getReceivedMessages()

getReceivedBytes

long getReceivedBytes()

isOpen

boolean isOpen()

isConnected

boolean isConnected()

getNumMessages

int getNumMessages()

dumpQueue

String dumpQueue()

printProtocolSpec

String printProtocolSpec(boolean include_properties)

toString

String toString(boolean print_details)

connect

void connect(String channel_name)
      throws ChannelException,
ChannelClosedException

Throws:

ChannelException

ChannelClosedException

disconnect

void disconnect()

close

void close()

shutdown

void shutdown()

send

void send(Message msg)
   throws ChannelNotConnectedException,
ChannelClosedException

Throws:

ChannelNotConnectedException

ChannelClosedException

send

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

Throws:

ChannelNotConnectedException

ChannelClosedException

sendToAll

void sendToAll(String msg)
        throws ChannelNotConnectedException,
ChannelClosedException

Throws:

ChannelNotConnectedException

ChannelClosedException

down

void down(Event evt)

Deprecated.

Parameters:

evt -

receive

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

Throws:

ChannelNotConnectedException

ChannelClosedException

TimeoutException

peek

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

Throws:

ChannelNotConnectedException

ChannelClosedException

TimeoutException

blockOk

void blockOk()

getState

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

Throws:

ChannelNotConnectedException

ChannelClosedException

returnState

void returnState(byte[] state)

returnState

void returnState(byte[] state,
 String state_id)