org.jboss.messaging.core.plugin
Class ClusteredPostOfficeService

java.lang.Object
  ServiceMBeanSupport
      org.jboss.messaging.core.plugin.JDBCServiceSupport
          org.jboss.messaging.core.plugin.ClusteredPostOfficeService

All Implemented Interfaces:

Peer, ServerPlugin

public class ClusteredPostOfficeService

extends JDBCServiceSupport

implements Peer

A ClusteredPostOfficeService MBean wrapper for a clustered post office

Version:

$Revision: 2684 $ $Id: ClusteredPostOfficeService.java 2684 2007-05-15 07:31:30Z timfox $

Author:

Tim Fox, Ovidiu Feodorov

See Also:

Serialized Form

Field Summary

Fields inherited from class org.jboss.messaging.core.plugin.JDBCServiceSupport

createTablesOnStartup, ds, sqlProperties

Constructor Summary

ClusteredPostOfficeService()

Method Summary

void	addNotificationListener(NotificationListener listener, NotificationFilter filter, java.lang.Object object)
org.w3c.dom.Element	getAsyncChannelConfig()
java.lang.String	getAsyncChannelName()
long	getCastTimeout()
ObjectName	getChannelFactoryName()
java.lang.String	getChannelPartitionName()
java.lang.String	getClusterRouterFactory()
java.lang.String	getGroupName()
MessagingComponent	getInstance() A server plugin will be always accessed via a hard reference, so it is essential that each implementation exposes this method.
java.lang.String	getMessagePullPolicy()
java.util.Set	getNodeIDView() Returns a set of nodeIDs (integers) representing the IDs of cluster's nodes.
MBeanNotificationInfo[]	getNotificationInfo()
java.lang.String	getPostOfficeName()
ObjectName	getServerPeer()
long	getStateTimeout()
long	getStatsSendPeriod()
org.w3c.dom.Element	getSyncChannelConfig()
java.lang.String	getSyncChannelName()
int	getThreadPoolSize()
java.lang.String	listBindings()
void	removeNotificationListener(NotificationListener listener)
void	setAsyncChannelConfig(org.w3c.dom.Element config)
void	setAsyncChannelName(java.lang.String asyncChannelName)
void	setCastTimeout(long timeout)
void	setChannelFactoryName(ObjectName channelFactoryName)
void	setChannelPartitionName(java.lang.String channelPartitionName)
void	setClusterRouterFactory(java.lang.String clusterRouterFactory)
void	setGroupName(java.lang.String groupName)
void	setMessagePullPolicy(java.lang.String messagePullPolicy)
void	setPostOfficeName(java.lang.String name)
void	setServerPeer(ObjectName on)
void	setStateTimeout(long timeout)
void	setStatsSendPeriod(long period)
void	setSyncChannelConfig(org.w3c.dom.Element config)
void	setSyncChannelName(java.lang.String syncChannelName)
void	setThreadPoolSize(int size)
protected void	startService()
protected void	stopService()

Methods inherited from class org.jboss.messaging.core.plugin.JDBCServiceSupport

getDataSource, getSqlProperties, getTransactionManager, getTransactionManagerReference, isCreateTablesOnStartup, setCreateTablesOnStartup, setDataSource, setSqlProperties, setTransactionManager

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusteredPostOfficeService

public ClusteredPostOfficeService()

Method Detail

getInstance

public MessagingComponent getInstance()

Description copied from interface: ServerPlugin

A server plugin will be always accessed via a hard reference, so it is essential that each implementation exposes this method.

Specified by:

getInstance in interface ServerPlugin

getNodeIDView

public java.util.Set getNodeIDView()

Description copied from interface: Peer

Returns a set of nodeIDs (integers) representing the IDs of cluster's nodes.

Specified by:

getNodeIDView in interface Peer

addNotificationListener

public void addNotificationListener(NotificationListener listener,
                                    NotificationFilter filter,
                                    java.lang.Object object)
                             throws java.lang.IllegalArgumentException

Throws:

java.lang.IllegalArgumentException

removeNotificationListener

public void removeNotificationListener(NotificationListener listener)
                                throws ListenerNotFoundException

Throws:

ListenerNotFoundException

getNotificationInfo

public MBeanNotificationInfo[] getNotificationInfo()

getServerPeer

public ObjectName getServerPeer()

setServerPeer

public void setServerPeer(ObjectName on)

getPostOfficeName

public java.lang.String getPostOfficeName()

setPostOfficeName

public void setPostOfficeName(java.lang.String name)

getChannelFactoryName

public ObjectName getChannelFactoryName()

setChannelFactoryName

public void setChannelFactoryName(ObjectName channelFactoryName)

getSyncChannelName

public java.lang.String getSyncChannelName()

setSyncChannelName

public void setSyncChannelName(java.lang.String syncChannelName)

getAsyncChannelName

public java.lang.String getAsyncChannelName()

setAsyncChannelName

public void setAsyncChannelName(java.lang.String asyncChannelName)

getChannelPartitionName

public java.lang.String getChannelPartitionName()

setChannelPartitionName

public void setChannelPartitionName(java.lang.String channelPartitionName)

setSyncChannelConfig

public void setSyncChannelConfig(org.w3c.dom.Element config)
                          throws java.lang.Exception

Throws:

java.lang.Exception

getSyncChannelConfig

public org.w3c.dom.Element getSyncChannelConfig()

setAsyncChannelConfig

public void setAsyncChannelConfig(org.w3c.dom.Element config)
                           throws java.lang.Exception

Throws:

java.lang.Exception

getAsyncChannelConfig

public org.w3c.dom.Element getAsyncChannelConfig()

setStateTimeout

public void setStateTimeout(long timeout)

getStateTimeout

public long getStateTimeout()

setCastTimeout

public void setCastTimeout(long timeout)

getCastTimeout

public long getCastTimeout()

setGroupName

public void setGroupName(java.lang.String groupName)

getGroupName

public java.lang.String getGroupName()

setStatsSendPeriod

public void setStatsSendPeriod(long period)

getStatsSendPeriod

public long getStatsSendPeriod()

getClusterRouterFactory

public java.lang.String getClusterRouterFactory()

getMessagePullPolicy

public java.lang.String getMessagePullPolicy()

setClusterRouterFactory

public void setClusterRouterFactory(java.lang.String clusterRouterFactory)

setMessagePullPolicy

public void setMessagePullPolicy(java.lang.String messagePullPolicy)

listBindings

public java.lang.String listBindings()

getThreadPoolSize

public int getThreadPoolSize()

setThreadPoolSize

public void setThreadPoolSize(int size)

startService

protected void startService()
                     throws java.lang.Exception

Overrides:

startService in class JDBCServiceSupport

Throws:

java.lang.Exception

stopService

protected void stopService()
                    throws java.lang.Exception

Overrides:

stopService in class JDBCServiceSupport

Throws:

java.lang.Exception