Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.jboss.jms.server
Class ServerPeer

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

public class ServerPeer
extends ServiceMBeanSupport

A JMS server peer.

Version:
$Revision: 3225 $ $Id: ServerPeer.java 3225 2007-10-20 16:13:52Z timfox $
Author:
Ovidiu Feodorov, Tim Fox, Juha Lindfors, Aslak Knutsen

Field Summary
protected  Queue defaultDLQ
           
protected  javax.management.ObjectName defaultDLQObjectName
           
protected  Queue defaultExpiryQueue
           
protected  javax.management.ObjectName defaultExpiryQueueObjectName
           
protected  JMSUserManager jmsUserManager
           
protected  javax.management.ObjectName jmsUserManagerObjectName
           
protected  PersistenceManager persistenceManager
           
protected  javax.management.ObjectName persistenceManagerObjectName
           
protected  PostOffice postOffice
           
protected  javax.management.ObjectName postOfficeObjectName
           
static java.lang.String REMOTING_JMS_SUBSYSTEM
           
 
Constructor Summary
ServerPeer()
           
 
Method Summary
 void addSession(java.lang.String 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()
           
 ClusterNotifier getClusterNotifier()
           
 java.lang.String getClusterPullConnectionFactoryName()
           
 ConnectionFactoryManager getConnectionFactoryManager()
           
 ConnectionManager getConnectionManager()
           
 ConnectorManager getConnectorManager()
           
 javax.management.ObjectName getDefaultDLQ()
           
 Queue getDefaultDLQInstance()
           
 javax.management.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()
           
 FailoverWaiter getFailoverWaiter()
           
 java.lang.Object getInstance()
           
 int getJMSMajorVersion()
           
 int getJMSMinorVersion()
           
 java.lang.String getJMSProviderName()
           
 javax.management.ObjectName getJmsUserManager()
           
 JMSUserManager getJmsUserManagerInstance()
           
 java.lang.String getJMSVersion()
           
 MemoryManager getMemoryManager()
           
 MessageCounterManager getMessageCounterManager()
           
 java.util.List getMessageCounters()
           
 long getMessageCounterSamplePeriod()
           
 IDManager getMessageIDManager()
           
 java.util.List getMessageStatistics()
           
 MessageStore getMessageStore()
           
 javax.management.ObjectName getPersistenceManager()
           
 PersistenceManager getPersistenceManagerInstance()
           
 javax.management.ObjectName getPostOffice()
           
 PostOffice getPostOfficeInstance()
           
 int getProviderMajorVersion()
           
 int getProviderMinorVersion()
           
 java.lang.String getProviderVersion()
           
 long getRecoverDeliveriesTimeout()
           
 java.lang.String getSecurityDomain()
           
 SecurityStore getSecurityManager()
           
 int getServerPeerID()
           
 ServerSessionEndpoint getSession(java.lang.String sessionID)
           
 java.util.Collection getSessions()
           
 TransactionRepository getTxRepository()
           
 Version getVersion()
           
 boolean isDefaultPreserveOrdering()
           
 boolean isStarted()
           
 boolean isStrictTck()
           
 boolean isSupportsFailover()
           
 boolean isUseXAForMessagePull()
           
 java.lang.String listMessageCountersAsHTML()
           
 void removeSession(java.lang.String id)
           
 void resetAllMessageCounterHistories()
           
 void resetAllMessageCounters()
           
 void resetAllSuckers()
           
 java.util.List retrievePreparedTransactions()
           
 void setClusterPullConnectionFactoryName(java.lang.String name)
           
 void setDefaultDLQ(javax.management.ObjectName on)
           
 void setDefaultExpiryQueue(javax.management.ObjectName on)
           
 void setDefaultMaxDeliveryAttempts(int attempts)
           
 void setDefaultMessageCounterHistoryDayLimit(int limit)
           
 void setDefaultPreserveOrdering(boolean preserve)
           
 void setDefaultQueueJNDIContext(java.lang.String defaultQueueJNDIContext)
           
 void setDefaultRedeliveryDelay(long delay)
           
 void setDefaultSecurityConfig(org.w3c.dom.Element conf)
           
 void setDefaultTopicJNDIContext(java.lang.String defaultTopicJNDIContext)
           
 void setFailoverCompleteTimeout(long timeout)
           
 void setFailoverStartTimeout(long timeout)
           
 void setJMSUserManager(javax.management.ObjectName on)
           
 void setMessageCounterSamplePeriod(long newPeriod)
           
 void setPersistenceManager(javax.management.ObjectName on)
           
 void setPostOffice(javax.management.ObjectName on)
           
 void setRecoverDeliveriesTimeout(long timeout)
           
 void setSecurityDomain(java.lang.String securityDomain)
           
 void setServerPeerID(int serverPeerID)
           
 void setStrictTck(boolean strictTck)
           
 void setSuckerPassword(java.lang.String password)
           
 void setSupportsFailover(boolean supportsFailover)
           
 void setUseXAForMessagePull(boolean useXA)
           
 java.lang.String showActiveClientsAsHTML()
           
 java.lang.String showPreparedTransactionsAsHTML()
           
 void startService()
           
 void stopService()
           
 java.lang.String toString()
           
 boolean undeployQueue(java.lang.String name)
           
 boolean undeployTopic(java.lang.String name)
           
 
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 javax.management.ObjectName persistenceManagerObjectName

persistenceManager

protected PersistenceManager persistenceManager

postOfficeObjectName

protected javax.management.ObjectName postOfficeObjectName

postOffice

protected PostOffice postOffice

jmsUserManagerObjectName

protected javax.management.ObjectName jmsUserManagerObjectName

jmsUserManager

protected JMSUserManager jmsUserManager

defaultDLQObjectName

protected javax.management.ObjectName defaultDLQObjectName

defaultDLQ

protected Queue defaultDLQ

defaultExpiryQueueObjectName

protected javax.management.ObjectName defaultExpiryQueueObjectName

defaultExpiryQueue

protected Queue defaultExpiryQueue
Constructor Detail

ServerPeer

public ServerPeer()
           throws java.lang.Exception
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 javax.management.ObjectName getPersistenceManager()

setPersistenceManager

public void setPersistenceManager(javax.management.ObjectName on)

getPostOffice

public javax.management.ObjectName getPostOffice()

setPostOffice

public void setPostOffice(javax.management.ObjectName on)

getJmsUserManager

public javax.management.ObjectName getJmsUserManager()

setJMSUserManager

public void setJMSUserManager(javax.management.ObjectName on)

getDefaultDLQ

public javax.management.ObjectName getDefaultDLQ()

setDefaultDLQ

public void setDefaultDLQ(javax.management.ObjectName on)

getDefaultExpiryQueue

public javax.management.ObjectName getDefaultExpiryQueue()

setDefaultExpiryQueue

public void setDefaultExpiryQueue(javax.management.ObjectName on)

getInstance

public java.lang.Object getInstance()

getJMSVersion

public java.lang.String getJMSVersion()

getJMSMajorVersion

public int getJMSMajorVersion()

getJMSMinorVersion

public int getJMSMinorVersion()

getJMSProviderName

public java.lang.String getJMSProviderName()

getProviderVersion

public java.lang.String getProviderVersion()

getProviderMajorVersion

public int getProviderMajorVersion()

getProviderMinorVersion

public int getProviderMinorVersion()

setSecurityDomain

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

getSecurityDomain

public java.lang.String getSecurityDomain()

setDefaultSecurityConfig

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

getDefaultSecurityConfig

public org.w3c.dom.Element getDefaultSecurityConfig()

getFailoverStartTimeout

public long getFailoverStartTimeout()

setFailoverStartTimeout

public void setFailoverStartTimeout(long timeout)

getFailoverCompleteTimeout

public long getFailoverCompleteTimeout()

setFailoverCompleteTimeout

public void setFailoverCompleteTimeout(long timeout)

getDefaultMaxDeliveryAttempts

public int getDefaultMaxDeliveryAttempts()

setDefaultMaxDeliveryAttempts

public void setDefaultMaxDeliveryAttempts(int attempts)

getMessageCounterSamplePeriod

public long getMessageCounterSamplePeriod()

setMessageCounterSamplePeriod

public void setMessageCounterSamplePeriod(long newPeriod)

getDefaultRedeliveryDelay

public long getDefaultRedeliveryDelay()

setDefaultRedeliveryDelay

public void setDefaultRedeliveryDelay(long delay)

getDefaultMessageCounterHistoryDayLimit

public int getDefaultMessageCounterHistoryDayLimit()

setDefaultMessageCounterHistoryDayLimit

public void setDefaultMessageCounterHistoryDayLimit(int limit)

getClusterPullConnectionFactoryName

public java.lang.String getClusterPullConnectionFactoryName()

setClusterPullConnectionFactoryName

public void setClusterPullConnectionFactoryName(java.lang.String name)

isUseXAForMessagePull

public boolean isUseXAForMessagePull()

setUseXAForMessagePull

public void setUseXAForMessagePull(boolean useXA)
                            throws java.lang.Exception
Throws:
java.lang.Exception

isDefaultPreserveOrdering

public boolean isDefaultPreserveOrdering()

setDefaultPreserveOrdering

public void setDefaultPreserveOrdering(boolean preserve)
                                throws java.lang.Exception
Throws:
java.lang.Exception

getRecoverDeliveriesTimeout

public long getRecoverDeliveriesTimeout()

setRecoverDeliveriesTimeout

public void setRecoverDeliveriesTimeout(long timeout)

setServerPeerID

public void setServerPeerID(int serverPeerID)

getServerPeerID

public int getServerPeerID()

getDefaultQueueJNDIContext

public java.lang.String getDefaultQueueJNDIContext()

setDefaultQueueJNDIContext

public void setDefaultQueueJNDIContext(java.lang.String defaultQueueJNDIContext)

getDefaultTopicJNDIContext

public java.lang.String getDefaultTopicJNDIContext()

setDefaultTopicJNDIContext

public void setDefaultTopicJNDIContext(java.lang.String defaultTopicJNDIContext)

setSuckerPassword

public void setSuckerPassword(java.lang.String password)

setStrictTck

public void setStrictTck(boolean strictTck)

isStrictTck

public boolean isStrictTck()

enableMessageCounters

public void enableMessageCounters()

disableMessageCounters

public void disableMessageCounters()

deployQueue

public java.lang.String deployQueue(java.lang.String name,
                                    java.lang.String jndiName)
                             throws java.lang.Exception
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
Throws:
java.lang.Exception

destroyQueue

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

undeployQueue

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

deployTopic

public java.lang.String deployTopic(java.lang.String name,
                                    java.lang.String jndiName)
                             throws java.lang.Exception
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
Throws:
java.lang.Exception

destroyTopic

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

undeployTopic

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

getDestinations

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

getMessageCounters

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

getMessageStatistics

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

listMessageCountersAsHTML

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

resetAllMessageCounters

public void resetAllMessageCounters()

resetAllMessageCounterHistories

public void resetAllMessageCounterHistories()

retrievePreparedTransactions

public java.util.List retrievePreparedTransactions()

showPreparedTransactionsAsHTML

public java.lang.String showPreparedTransactionsAsHTML()

showActiveClientsAsHTML

public java.lang.String showActiveClientsAsHTML()
                                         throws java.lang.Exception
Throws:
java.lang.Exception

resetAllSuckers

public void resetAllSuckers()

getClientAOPStack

public byte[] getClientAOPStack()

getMessageCounterManager

public MessageCounterManager getMessageCounterManager()

getMessageIDManager

public IDManager getMessageIDManager()

getChannelIDManager

public IDManager getChannelIDManager()

getSession

public ServerSessionEndpoint getSession(java.lang.String sessionID)

getSessions

public java.util.Collection getSessions()

addSession

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

removeSession

public void removeSession(java.lang.String 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 SecurityStore 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

getClusterNotifier

public ClusterNotifier getClusterNotifier()

getFailoverWaiter

public FailoverWaiter getFailoverWaiter()

isSupportsFailover

public boolean isSupportsFailover()

setSupportsFailover

public void setSupportsFailover(boolean supportsFailover)
                         throws java.lang.Exception
Throws:
java.lang.Exception

toString

public java.lang.String toString()
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Copyright © 2006 JBoss Inc. All Rights Reserved.