org.jboss.jms.server
Class ServerPeer

java.lang.Object
  ServiceMBeanSupport
      org.jboss.jms.server.ServerPeer

All Implemented Interfaces:

ServerPeerMBean

public class ServerPeer

extends ServiceMBeanSupport

implements ServerPeerMBean

A JMS server peer.

Version:

$Revision: 2747 $ $Id: ServerPeer.java 2747 2007-06-01 09:16:18Z timfox $

Author:

Ovidiu Feodorov, Tim Fox, Juha Lindfors

See Also:

Serialized Form

Field Summary

protected Queue	defaultDLQ
protected ObjectName	defaultDLQObjectName
protected Queue	defaultExpiryQueue
protected ObjectName	defaultExpiryQueueObjectName
protected JMSUserManager	jmsUserManager
protected ObjectName	jmsUserManagerObjectName
protected PersistenceManager	persistenceManager
protected ObjectName	persistenceManagerObjectName
protected PostOffice	postOffice
protected ObjectName	postOfficeObjectName
static java.lang.String	REMOTING_JMS_SUBSYSTEM

Constructor Summary

ServerPeer(int serverPeerID, java.lang.String defaultQueueJNDIContext, java.lang.String defaultTopicJNDIContext)

Method Summary

void	addSession(java.lang.Integer id, ServerSessionEndpoint session)
java.lang.String	deployQueue(java.lang.String name, java.lang.String jndiName)
java.lang.String	deployQueue(java.lang.String name, java.lang.String jndiName, int fullSize, int pageSize, int downCacheSize)
java.lang.String	deployTopic(java.lang.String name, java.lang.String jndiName)
java.lang.String	deployTopic(java.lang.String name, java.lang.String jndiName, int fullSize, int pageSize, int downCacheSize)
boolean	destroyQueue(java.lang.String name)
boolean	destroyTopic(java.lang.String name)
void	disableMessageCounters()
void	enableMessageCounters()
IDManager	getChannelIDManager()
byte[]	getClientAOPStack()
ConnectionFactoryManager	getConnectionFactoryManager()
ConnectionManager	getConnectionManager()
ConnectorManager	getConnectorManager()
ObjectName	getDefaultDLQ()
Queue	getDefaultDLQInstance()
ObjectName	getDefaultExpiryQueue()
Queue	getDefaultExpiryQueueInstance()
int	getDefaultMaxDeliveryAttempts()
int	getDefaultMessageCounterHistoryDayLimit()
java.lang.String	getDefaultQueueJNDIContext()
long	getDefaultRedeliveryDelay()
org.w3c.dom.Element	getDefaultSecurityConfig()
java.lang.String	getDefaultTopicJNDIContext()
DestinationManager	getDestinationManager()
java.util.Set	getDestinations()
long	getFailoverCompleteTimeout()
long	getFailoverStartTimeout()
java.lang.Object	getInstance()
int	getJMSMajorVersion()
int	getJMSMinorVersion()
java.lang.String	getJMSProviderName()
ObjectName	getJmsUserManager()
JMSUserManager	getJmsUserManagerInstance()
java.lang.String	getJMSVersion()
MemoryManager	getMemoryManager()
MessageCounterManager	getMessageCounterManager()
java.util.List	getMessageCounters()
IDManager	getMessageIDManager()
java.util.List	getMessageStatistics()
MessageStore	getMessageStore()
int	getNextObjectID()
ObjectName	getPersistenceManager()
PersistenceManager	getPersistenceManagerInstance()
ObjectName	getPostOffice()
PostOffice	getPostOfficeInstance()
int	getProviderMajorVersion()
int	getProviderMinorVersion()
java.lang.String	getProviderVersion()
long	getQueueStatsSamplePeriod()
Replicator	getReplicator()
java.lang.String	getSecurityDomain()
SecurityManager	getSecurityManager()
int	getServerPeerID()
ServerSessionEndpoint	getSession(java.lang.Integer sessionID)
TransactionRepository	getTxRepository()
Version	getVersion()
boolean	isStarted()
java.lang.String	listMessageCountersAsHTML()
void	removeSession(java.lang.Integer id)
void	resetAllMessageCounterHistories()
void	resetAllMessageCounters()
java.util.List	retrievePreparedTransactions()
void	setDefaultDLQ(ObjectName on)
void	setDefaultExpiryQueue(ObjectName on)
void	setDefaultMaxDeliveryAttempts(int attempts)
void	setDefaultMessageCounterHistoryDayLimit(int limit)
void	setDefaultRedeliveryDelay(long delay)
void	setDefaultSecurityConfig(org.w3c.dom.Element conf)
void	setFailoverCompleteTimeout(long timeout)
void	setFailoverStartTimeout(long timeout)
void	setJMSUserManager(ObjectName on)
void	setPersistenceManager(ObjectName on)
void	setPostOffice(ObjectName on)
void	setQueueStatsSamplePeriod(long newPeriod)
void	setSecurityDomain(java.lang.String securityDomain)
java.lang.String	showPreparedTransactionsAsHTML()
void	startService()
void	stopService()
java.lang.String	toString()
boolean	undeployQueue(java.lang.String name)
boolean	undeployTopic(java.lang.String name)
int	waitForFailover(int failedNodeID)

Methods inherited from class java.lang.Object

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

Field Detail

REMOTING_JMS_SUBSYSTEM

public static final java.lang.String REMOTING_JMS_SUBSYSTEM

See Also:

Constant Field Values

persistenceManagerObjectName

protected ObjectName persistenceManagerObjectName

persistenceManager

protected PersistenceManager persistenceManager

postOfficeObjectName

protected ObjectName postOfficeObjectName

postOffice

protected PostOffice postOffice

jmsUserManagerObjectName

protected ObjectName jmsUserManagerObjectName

jmsUserManager

protected JMSUserManager jmsUserManager

defaultDLQObjectName

protected ObjectName defaultDLQObjectName

defaultDLQ

protected Queue defaultDLQ

defaultExpiryQueueObjectName

protected ObjectName defaultExpiryQueueObjectName

defaultExpiryQueue

protected Queue defaultExpiryQueue

Constructor Detail

ServerPeer

public ServerPeer(int serverPeerID,
                  java.lang.String defaultQueueJNDIContext,
                  java.lang.String defaultTopicJNDIContext)
           throws java.lang.Exception

Method Detail

startService

public void startService()
                  throws java.lang.Exception

Throws:

java.lang.Exception

stopService

public void stopService()
                 throws java.lang.Exception

Throws:

java.lang.Exception

getPersistenceManager

public ObjectName getPersistenceManager()

Specified by:

getPersistenceManager in interface ServerPeerMBean

setPersistenceManager

public void setPersistenceManager(ObjectName on)

Specified by:

setPersistenceManager in interface ServerPeerMBean

getPostOffice

public ObjectName getPostOffice()

Specified by:

getPostOffice in interface ServerPeerMBean

setPostOffice

public void setPostOffice(ObjectName on)

Specified by:

setPostOffice in interface ServerPeerMBean

getJmsUserManager

public ObjectName getJmsUserManager()

Specified by:

getJmsUserManager in interface ServerPeerMBean

setJMSUserManager

public void setJMSUserManager(ObjectName on)

Specified by:

setJMSUserManager in interface ServerPeerMBean

getDefaultDLQ

public ObjectName getDefaultDLQ()

Specified by:

getDefaultDLQ in interface ServerPeerMBean

setDefaultDLQ

public void setDefaultDLQ(ObjectName on)

Specified by:

setDefaultDLQ in interface ServerPeerMBean

getDefaultExpiryQueue

public ObjectName getDefaultExpiryQueue()

Specified by:

getDefaultExpiryQueue in interface ServerPeerMBean

setDefaultExpiryQueue

public void setDefaultExpiryQueue(ObjectName on)

Specified by:

setDefaultExpiryQueue in interface ServerPeerMBean

getInstance

public java.lang.Object getInstance()

getJMSVersion

public java.lang.String getJMSVersion()

Specified by:

getJMSVersion in interface ServerPeerMBean

getJMSMajorVersion

public int getJMSMajorVersion()

Specified by:

getJMSMajorVersion in interface ServerPeerMBean

getJMSMinorVersion

public int getJMSMinorVersion()

Specified by:

getJMSMinorVersion in interface ServerPeerMBean

getJMSProviderName

public java.lang.String getJMSProviderName()

Specified by:

getJMSProviderName in interface ServerPeerMBean

getProviderVersion

public java.lang.String getProviderVersion()

Specified by:

getProviderVersion in interface ServerPeerMBean

getProviderMajorVersion

public int getProviderMajorVersion()

Specified by:

getProviderMajorVersion in interface ServerPeerMBean

getProviderMinorVersion

public int getProviderMinorVersion()

Specified by:

getProviderMinorVersion in interface ServerPeerMBean

getServerPeerID

public int getServerPeerID()

Specified by:

getServerPeerID in interface ServerPeerMBean

getDefaultQueueJNDIContext

public java.lang.String getDefaultQueueJNDIContext()

Specified by:

getDefaultQueueJNDIContext in interface ServerPeerMBean

getDefaultTopicJNDIContext

public java.lang.String getDefaultTopicJNDIContext()

Specified by:

getDefaultTopicJNDIContext in interface ServerPeerMBean

setSecurityDomain

public void setSecurityDomain(java.lang.String securityDomain)
                       throws java.lang.Exception

Specified by:

setSecurityDomain in interface ServerPeerMBean

Throws:

java.lang.Exception

getSecurityDomain

public java.lang.String getSecurityDomain()

Specified by:

getSecurityDomain in interface ServerPeerMBean

setDefaultSecurityConfig

public void setDefaultSecurityConfig(org.w3c.dom.Element conf)
                              throws java.lang.Exception

Specified by:

setDefaultSecurityConfig in interface ServerPeerMBean

Throws:

java.lang.Exception

getDefaultSecurityConfig

public org.w3c.dom.Element getDefaultSecurityConfig()

Specified by:

getDefaultSecurityConfig in interface ServerPeerMBean

getFailoverStartTimeout

public long getFailoverStartTimeout()

Specified by:

getFailoverStartTimeout in interface ServerPeerMBean

setFailoverStartTimeout

public void setFailoverStartTimeout(long timeout)

Specified by:

setFailoverStartTimeout in interface ServerPeerMBean

getFailoverCompleteTimeout

public long getFailoverCompleteTimeout()

Specified by:

getFailoverCompleteTimeout in interface ServerPeerMBean

setFailoverCompleteTimeout

public void setFailoverCompleteTimeout(long timeout)

Specified by:

setFailoverCompleteTimeout in interface ServerPeerMBean

getDefaultMaxDeliveryAttempts

public int getDefaultMaxDeliveryAttempts()

Specified by:

getDefaultMaxDeliveryAttempts in interface ServerPeerMBean

setDefaultMaxDeliveryAttempts

public void setDefaultMaxDeliveryAttempts(int attempts)

Specified by:

setDefaultMaxDeliveryAttempts in interface ServerPeerMBean

getQueueStatsSamplePeriod

public long getQueueStatsSamplePeriod()

Specified by:

getQueueStatsSamplePeriod in interface ServerPeerMBean

setQueueStatsSamplePeriod

public void setQueueStatsSamplePeriod(long newPeriod)

Specified by:

setQueueStatsSamplePeriod in interface ServerPeerMBean

getDefaultRedeliveryDelay

public long getDefaultRedeliveryDelay()

Specified by:

getDefaultRedeliveryDelay in interface ServerPeerMBean

setDefaultRedeliveryDelay

public void setDefaultRedeliveryDelay(long delay)

Specified by:

setDefaultRedeliveryDelay in interface ServerPeerMBean

getDefaultMessageCounterHistoryDayLimit

public int getDefaultMessageCounterHistoryDayLimit()

Specified by:

getDefaultMessageCounterHistoryDayLimit in interface ServerPeerMBean

setDefaultMessageCounterHistoryDayLimit

public void setDefaultMessageCounterHistoryDayLimit(int limit)

Specified by:

setDefaultMessageCounterHistoryDayLimit in interface ServerPeerMBean

enableMessageCounters

public void enableMessageCounters()

Specified by:

enableMessageCounters in interface ServerPeerMBean

disableMessageCounters

public void disableMessageCounters()

Specified by:

disableMessageCounters in interface ServerPeerMBean

deployQueue

public java.lang.String deployQueue(java.lang.String name,
                                    java.lang.String jndiName)
                             throws java.lang.Exception

Specified by:

deployQueue in interface ServerPeerMBean

Throws:

java.lang.Exception

deployQueue

public java.lang.String deployQueue(java.lang.String name,
                                    java.lang.String jndiName,
                                    int fullSize,
                                    int pageSize,
                                    int downCacheSize)
                             throws java.lang.Exception

Specified by:

deployQueue in interface ServerPeerMBean

Throws:

java.lang.Exception

destroyQueue

public boolean destroyQueue(java.lang.String name)
                     throws java.lang.Exception

Specified by:

destroyQueue in interface ServerPeerMBean

Throws:

java.lang.Exception

undeployQueue

public boolean undeployQueue(java.lang.String name)
                      throws java.lang.Exception

Specified by:

undeployQueue in interface ServerPeerMBean

Throws:

java.lang.Exception

deployTopic

public java.lang.String deployTopic(java.lang.String name,
                                    java.lang.String jndiName)
                             throws java.lang.Exception

Specified by:

deployTopic in interface ServerPeerMBean

Throws:

java.lang.Exception

deployTopic

public java.lang.String deployTopic(java.lang.String name,
                                    java.lang.String jndiName,
                                    int fullSize,
                                    int pageSize,
                                    int downCacheSize)
                             throws java.lang.Exception

Specified by:

deployTopic in interface ServerPeerMBean

Throws:

java.lang.Exception

destroyTopic

public boolean destroyTopic(java.lang.String name)
                     throws java.lang.Exception

Specified by:

destroyTopic in interface ServerPeerMBean

Throws:

java.lang.Exception

undeployTopic

public boolean undeployTopic(java.lang.String name)
                      throws java.lang.Exception

Specified by:

undeployTopic in interface ServerPeerMBean

Throws:

java.lang.Exception

getDestinations

public java.util.Set getDestinations()
                              throws java.lang.Exception

Specified by:

getDestinations in interface ServerPeerMBean

Throws:

java.lang.Exception

getMessageCounters

public java.util.List getMessageCounters()
                                  throws java.lang.Exception

Specified by:

getMessageCounters in interface ServerPeerMBean

Throws:

java.lang.Exception

getMessageStatistics

public java.util.List getMessageStatistics()
                                    throws java.lang.Exception

Specified by:

getMessageStatistics in interface ServerPeerMBean

Throws:

java.lang.Exception

listMessageCountersAsHTML

public java.lang.String listMessageCountersAsHTML()
                                           throws java.lang.Exception

Specified by:

listMessageCountersAsHTML in interface ServerPeerMBean

Throws:

java.lang.Exception

resetAllMessageCounters

public void resetAllMessageCounters()

Specified by:

resetAllMessageCounters in interface ServerPeerMBean

resetAllMessageCounterHistories

public void resetAllMessageCounterHistories()

Specified by:

resetAllMessageCounterHistories in interface ServerPeerMBean

retrievePreparedTransactions

public java.util.List retrievePreparedTransactions()

Specified by:

retrievePreparedTransactions in interface ServerPeerMBean

showPreparedTransactionsAsHTML

public java.lang.String showPreparedTransactionsAsHTML()

Specified by:

showPreparedTransactionsAsHTML in interface ServerPeerMBean

getClientAOPStack

public byte[] getClientAOPStack()

getMessageCounterManager

public MessageCounterManager getMessageCounterManager()

getMessageIDManager

public IDManager getMessageIDManager()

getChannelIDManager

public IDManager getChannelIDManager()

getSession

public ServerSessionEndpoint getSession(java.lang.Integer sessionID)

addSession

public void addSession(java.lang.Integer id,
                       ServerSessionEndpoint session)

removeSession

public void removeSession(java.lang.Integer id)

getDefaultDLQInstance

public Queue getDefaultDLQInstance()
                            throws java.lang.Exception

Throws:

java.lang.Exception

getDefaultExpiryQueueInstance

public Queue getDefaultExpiryQueueInstance()
                                    throws java.lang.Exception

Throws:

java.lang.Exception

getTxRepository

public TransactionRepository getTxRepository()

isStarted

public boolean isStarted()

getVersion

public Version getVersion()

getSecurityManager

public SecurityManager getSecurityManager()

getDestinationManager

public DestinationManager getDestinationManager()

getConnectionFactoryManager

public ConnectionFactoryManager getConnectionFactoryManager()

getConnectionManager

public ConnectionManager getConnectionManager()

getConnectorManager

public ConnectorManager getConnectorManager()

getMessageStore

public MessageStore getMessageStore()

getMemoryManager

public MemoryManager getMemoryManager()

getPersistenceManagerInstance

public PersistenceManager getPersistenceManagerInstance()

getJmsUserManagerInstance

public JMSUserManager getJmsUserManagerInstance()

getPostOfficeInstance

public PostOffice getPostOfficeInstance()
                                 throws java.lang.Exception

Throws:

java.lang.Exception

getReplicator

public Replicator getReplicator()
                         throws java.lang.Exception

Throws:

java.lang.Exception

getNextObjectID

public int getNextObjectID()

waitForFailover

public int waitForFailover(int failedNodeID)
                    throws java.lang.Exception

Throws:

java.lang.Exception

toString

public java.lang.String toString()