public class JChannel extends java.lang.Object implements JChannelMBean
Modifier and Type | Method and 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() instead
|
void |
setClusterConfig(org.w3c.dom.Element config)
To configure via XML file
|
void |
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) |
public JChannel()
public JChannel(JChannel channel)
protected final void setValues()
public JChannel getChannel()
getChannel
in interface JChannelMBean
public java.lang.String getVersion()
getVersion
in interface JChannelMBean
public java.lang.String getMBeanServerName()
public void setMBeanServerName(java.lang.String n)
public java.lang.String getProperties()
getProperties
in interface JChannelMBean
public void setProperties(java.lang.String props)
setProperties
in interface JChannelMBean
public java.lang.String getObjectName()
getObjectName
in interface JChannelMBean
public void setObjectName(java.lang.String name)
setObjectName
in interface JChannelMBean
public int getNumberOfTasksInTimer()
getNumberOfTasksInTimer
in interface JChannelMBean
public java.lang.String dumpTimerQueue()
dumpTimerQueue
in interface JChannelMBean
public void setClusterConfig(org.w3c.dom.Element config)
JChannelMBean
setClusterConfig
in interface JChannelMBean
public java.lang.String getGroupName()
getGroupName
in interface JChannelMBean
public void setGroupName(java.lang.String group_name)
setGroupName
in interface JChannelMBean
public java.lang.String getClusterName()
getClusterName
in interface JChannelMBean
public void setClusterName(java.lang.String cluster_name)
setClusterName
in interface JChannelMBean
public boolean getReceiveBlockEvents()
getReceiveBlockEvents
in interface JChannelMBean
public void setReceiveBlockEvents(boolean flag)
setReceiveBlockEvents
in interface JChannelMBean
public boolean getReceiveLocalMessages()
getReceiveLocalMessages
in interface JChannelMBean
public void setReceiveLocalMessages(boolean flag)
setReceiveLocalMessages
in interface JChannelMBean
public boolean getAutoReconnect()
getAutoReconnect
in interface JChannelMBean
public void setAutoReconnect(boolean flag)
setAutoReconnect
in interface JChannelMBean
public boolean getAutoGetState()
getAutoGetState
in interface JChannelMBean
public void setAutoGetState(boolean flag)
setAutoGetState
in interface JChannelMBean
public boolean getStatsEnabled()
getStatsEnabled
in interface JChannelMBean
public void setStatsEnabled(boolean flag)
setStatsEnabled
in interface JChannelMBean
public java.util.Map dumpStats()
dumpStats
in interface JChannelMBean
public void resetStats()
resetStats
in interface JChannelMBean
public long getSentMessages()
getSentMessages
in interface JChannelMBean
public long getSentBytes()
getSentBytes
in interface JChannelMBean
public long getReceivedMessages()
getReceivedMessages
in interface JChannelMBean
public long getReceivedBytes()
getReceivedBytes
in interface JChannelMBean
public int getTimerThreads()
getTimerThreads
in interface JChannelMBean
public void create() throws java.lang.Exception
create
in interface JChannelMBean
java.lang.Exception
public void start() throws java.lang.Exception
start
in interface JChannelMBean
java.lang.Exception
public void stop()
stop
in interface JChannelMBean
public void destroy()
destroy
in interface JChannelMBean
public View getView()
getView
in interface JChannelMBean
public java.lang.String getViewAsString()
getViewAsString
in interface JChannelMBean
public Address getLocalAddress()
getLocalAddress
in interface JChannelMBean
public java.lang.String getLocalAddressAsString()
getLocalAddressAsString
in interface JChannelMBean
public void setChannelListener(ChannelListener channel_listener)
setChannelListener
in interface JChannelMBean
public void addChannelListener(ChannelListener listener)
public void removeChannelListener(ChannelListener l)
public boolean isOpen()
isOpen
in interface JChannelMBean
public boolean isConnected()
isConnected
in interface JChannelMBean
public int getNumMessages()
getNumMessages
in interface JChannelMBean
public java.lang.String dumpQueue()
dumpQueue
in interface JChannelMBean
public java.lang.String printProtocolSpec(boolean include_properties)
printProtocolSpec
in interface JChannelMBean
public java.lang.String toString(boolean print_details)
toString
in interface JChannelMBean
public void connect(java.lang.String channel_name) throws ChannelException
connect
in interface JChannelMBean
ChannelException
public void disconnect()
disconnect
in interface JChannelMBean
public void close()
close
in interface JChannelMBean
public void shutdown()
shutdown
in interface JChannelMBean
public void send(Message msg) throws ChannelNotConnectedException, ChannelClosedException
send
in interface JChannelMBean
ChannelNotConnectedException
ChannelClosedException
public void send(Address dst, Address src, java.io.Serializable obj) throws ChannelNotConnectedException, ChannelClosedException
send
in interface JChannelMBean
ChannelNotConnectedException
ChannelClosedException
public void sendToAll(java.lang.String msg) throws ChannelNotConnectedException, ChannelClosedException
sendToAll
in interface JChannelMBean
ChannelNotConnectedException
ChannelClosedException
public void down(Event evt)
down
in interface JChannelMBean
public java.lang.Object receive(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException
receive
in interface JChannelMBean
ChannelNotConnectedException
ChannelClosedException
TimeoutException
public java.lang.Object peek(long timeout) throws ChannelNotConnectedException, ChannelClosedException, TimeoutException
peek
in interface JChannelMBean
ChannelNotConnectedException
ChannelClosedException
TimeoutException
public void blockOk()
blockOk
in interface JChannelMBean
public boolean getState(Address target, long timeout) throws ChannelNotConnectedException, ChannelClosedException
getState
in interface JChannelMBean
ChannelNotConnectedException
ChannelClosedException
public void returnState(byte[] state)
returnState
in interface JChannelMBean
public void returnState(byte[] state, java.lang.String state_id)
returnState
in interface JChannelMBean
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.