org.jboss.messaging.core.management.impl
Class MessagingServerControlImpl

java.lang.Object
  extended by org.jboss.messaging.core.management.impl.MessagingServerControlImpl
All Implemented Interfaces:
javax.management.NotificationBroadcaster, javax.management.NotificationEmitter, MessagingServerControl

public class MessagingServerControlImpl
extends java.lang.Object
implements MessagingServerControl, javax.management.NotificationEmitter

Version:
$Revision$
Author:
Jeff Mesnil

Constructor Summary
MessagingServerControlImpl(PostOffice postOffice, Configuration configuration, ResourceManager resourceManager, RemotingService remotingService, MessagingServer messagingServer, MessageCounterManager messageCounterManager, javax.management.NotificationBroadcasterSupport broadcaster)
           
 
Method Summary
 void addNotificationListener(javax.management.NotificationListener listener, javax.management.NotificationFilter filter, java.lang.Object handback)
           
 boolean closeConnectionsForAddress(java.lang.String ipAddress)
           
 boolean commitPreparedTransaction(java.lang.String transactionAsBase64)
           
 void createQueue(java.lang.String address, java.lang.String name)
           
 void createQueue(java.lang.String address, java.lang.String name, java.lang.String filterStr, boolean durable)
           
 void deployQueue(java.lang.String address, java.lang.String name, java.lang.String filterString)
           
 void deployQueue(java.lang.String address, java.lang.String name, java.lang.String filterStr, boolean durable)
           
 void destroyQueue(java.lang.String name)
           
 void disableMessageCounters()
           
 void enableMessageCounters()
           
 int getAIOBufferSize()
           
 int getAIOBufferTimeout()
           
 java.lang.String getBackupConnectorName()
           
 java.lang.String getBindingsDirectory()
           
 Configuration getConfiguration()
           
 int getConnectionCount()
           
 long getConnectionTTLOverride()
           
 java.lang.Object[] getConnectors()
           
 java.lang.String getConnectorsAsJSON()
           
 int getGlobalPageSize()
           
 int getIDCacheSize()
           
 java.lang.String[] getInterceptorClassNames()
           
 java.lang.String getJournalDirectory()
           
 int getJournalFileSize()
           
 int getJournalMaxAIO()
           
 int getJournalMinFiles()
           
 java.lang.String getJournalType()
           
 java.lang.String getLargeMessagesDirectory()
           
 java.lang.String getManagementAddress()
           
 java.lang.String getManagementNotificationAddress()
           
 long getManagementRequestTimeout()
           
 int getMessageCounterMaxDayCount()
           
 long getMessageCounterSamplePeriod()
           
 long getMessageExpiryScanPeriod()
           
 long getMessageExpiryThreadPriority()
           
 javax.management.MBeanNotificationInfo[] getNotificationInfo()
           
 java.lang.String getPagingDirectory()
           
 long getPagingMaxGlobalSizeBytes()
           
 long getQueueActivationTimeout()
           
 int getScheduledThreadPoolMaxSize()
           
 long getSecurityInvalidationInterval()
           
 int getThreadPoolMaxSize()
           
 long getTransactionTimeout()
           
 long getTransactionTimeoutScanPeriod()
           
 java.lang.String getVersion()
           
 boolean isBackup()
           
 boolean isClustered()
           
 boolean isCreateBindingsDir()
           
 boolean isCreateJournalDir()
           
 boolean isJournalSyncNonTransactional()
           
 boolean isJournalSyncTransactional()
           
 boolean isMessageCounterEnabled()
           
 boolean isPersistDeliveryCountBeforeDelivery()
           
 boolean isPersistIDCache()
           
 boolean isSecurityEnabled()
           
 boolean isStarted()
           
 boolean isWildcardRoutingEnabled()
           
 java.lang.String[] listConnectionIDs()
           
 java.lang.String[] listPreparedTransactions()
           
 java.lang.String[] listRemoteAddresses()
           
 java.lang.String[] listRemoteAddresses(java.lang.String ipAddress)
           
 java.lang.String[] listSessions(java.lang.String connectionID)
           
 void removeNotificationListener(javax.management.NotificationListener listener)
           
 void removeNotificationListener(javax.management.NotificationListener listener, javax.management.NotificationFilter filter, java.lang.Object handback)
           
 void resetAllMessageCounterHistories()
           
 void resetAllMessageCounters()
           
 boolean rollbackPreparedTransaction(java.lang.String transactionAsBase64)
           
 void sendQueueInfoToQueue(java.lang.String queueName, java.lang.String address)
           
 void setMessageCounterMaxDayCount(int count)
           
 void setMessageCounterSamplePeriod(long newPeriod)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessagingServerControlImpl

public MessagingServerControlImpl(PostOffice postOffice,
                                  Configuration configuration,
                                  ResourceManager resourceManager,
                                  RemotingService remotingService,
                                  MessagingServer messagingServer,
                                  MessageCounterManager messageCounterManager,
                                  javax.management.NotificationBroadcasterSupport broadcaster)
                           throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

getConfiguration

public Configuration getConfiguration()
Specified by:
getConfiguration in interface MessagingServerControl

isStarted

public boolean isStarted()
Specified by:
isStarted in interface MessagingServerControl

getVersion

public java.lang.String getVersion()
Specified by:
getVersion in interface MessagingServerControl

isBackup

public boolean isBackup()
Specified by:
isBackup in interface MessagingServerControl

getBackupConnectorName

public java.lang.String getBackupConnectorName()
Specified by:
getBackupConnectorName in interface MessagingServerControl

getBindingsDirectory

public java.lang.String getBindingsDirectory()
Specified by:
getBindingsDirectory in interface MessagingServerControl

getInterceptorClassNames

public java.lang.String[] getInterceptorClassNames()
Specified by:
getInterceptorClassNames in interface MessagingServerControl

getAIOBufferSize

public int getAIOBufferSize()
Specified by:
getAIOBufferSize in interface MessagingServerControl

getAIOBufferTimeout

public int getAIOBufferTimeout()
Specified by:
getAIOBufferTimeout in interface MessagingServerControl

getJournalDirectory

public java.lang.String getJournalDirectory()
Specified by:
getJournalDirectory in interface MessagingServerControl

getJournalFileSize

public int getJournalFileSize()
Specified by:
getJournalFileSize in interface MessagingServerControl

getJournalMaxAIO

public int getJournalMaxAIO()
Specified by:
getJournalMaxAIO in interface MessagingServerControl

getJournalMinFiles

public int getJournalMinFiles()
Specified by:
getJournalMinFiles in interface MessagingServerControl

getJournalType

public java.lang.String getJournalType()
Specified by:
getJournalType in interface MessagingServerControl

getPagingMaxGlobalSizeBytes

public long getPagingMaxGlobalSizeBytes()
Specified by:
getPagingMaxGlobalSizeBytes in interface MessagingServerControl

getPagingDirectory

public java.lang.String getPagingDirectory()
Specified by:
getPagingDirectory in interface MessagingServerControl

getScheduledThreadPoolMaxSize

public int getScheduledThreadPoolMaxSize()
Specified by:
getScheduledThreadPoolMaxSize in interface MessagingServerControl

getThreadPoolMaxSize

public int getThreadPoolMaxSize()
Specified by:
getThreadPoolMaxSize in interface MessagingServerControl

getSecurityInvalidationInterval

public long getSecurityInvalidationInterval()
Specified by:
getSecurityInvalidationInterval in interface MessagingServerControl

isClustered

public boolean isClustered()
Specified by:
isClustered in interface MessagingServerControl

isCreateBindingsDir

public boolean isCreateBindingsDir()
Specified by:
isCreateBindingsDir in interface MessagingServerControl

isCreateJournalDir

public boolean isCreateJournalDir()
Specified by:
isCreateJournalDir in interface MessagingServerControl

isJournalSyncNonTransactional

public boolean isJournalSyncNonTransactional()
Specified by:
isJournalSyncNonTransactional in interface MessagingServerControl

isJournalSyncTransactional

public boolean isJournalSyncTransactional()
Specified by:
isJournalSyncTransactional in interface MessagingServerControl

isSecurityEnabled

public boolean isSecurityEnabled()
Specified by:
isSecurityEnabled in interface MessagingServerControl

deployQueue

public void deployQueue(java.lang.String address,
                        java.lang.String name,
                        java.lang.String filterString)
                 throws java.lang.Exception
Specified by:
deployQueue in interface MessagingServerControl
Throws:
java.lang.Exception

deployQueue

public void deployQueue(java.lang.String address,
                        java.lang.String name,
                        java.lang.String filterStr,
                        boolean durable)
                 throws java.lang.Exception
Specified by:
deployQueue in interface MessagingServerControl
Throws:
java.lang.Exception

createQueue

public void createQueue(java.lang.String address,
                        java.lang.String name)
                 throws java.lang.Exception
Specified by:
createQueue in interface MessagingServerControl
Throws:
java.lang.Exception

createQueue

public void createQueue(java.lang.String address,
                        java.lang.String name,
                        java.lang.String filterStr,
                        boolean durable)
                 throws java.lang.Exception
Specified by:
createQueue in interface MessagingServerControl
Throws:
java.lang.Exception

destroyQueue

public void destroyQueue(java.lang.String name)
                  throws java.lang.Exception
Specified by:
destroyQueue in interface MessagingServerControl
Throws:
java.lang.Exception

getConnectionCount

public int getConnectionCount()
Specified by:
getConnectionCount in interface MessagingServerControl

enableMessageCounters

public void enableMessageCounters()
Specified by:
enableMessageCounters in interface MessagingServerControl

disableMessageCounters

public void disableMessageCounters()
Specified by:
disableMessageCounters in interface MessagingServerControl

resetAllMessageCounters

public void resetAllMessageCounters()
Specified by:
resetAllMessageCounters in interface MessagingServerControl

resetAllMessageCounterHistories

public void resetAllMessageCounterHistories()
Specified by:
resetAllMessageCounterHistories in interface MessagingServerControl

isMessageCounterEnabled

public boolean isMessageCounterEnabled()
Specified by:
isMessageCounterEnabled in interface MessagingServerControl

getMessageCounterSamplePeriod

public long getMessageCounterSamplePeriod()
Specified by:
getMessageCounterSamplePeriod in interface MessagingServerControl

setMessageCounterSamplePeriod

public void setMessageCounterSamplePeriod(long newPeriod)
Specified by:
setMessageCounterSamplePeriod in interface MessagingServerControl

getMessageCounterMaxDayCount

public int getMessageCounterMaxDayCount()
Specified by:
getMessageCounterMaxDayCount in interface MessagingServerControl

setMessageCounterMaxDayCount

public void setMessageCounterMaxDayCount(int count)
Specified by:
setMessageCounterMaxDayCount in interface MessagingServerControl

listPreparedTransactions

public java.lang.String[] listPreparedTransactions()
Specified by:
listPreparedTransactions in interface MessagingServerControl

commitPreparedTransaction

public boolean commitPreparedTransaction(java.lang.String transactionAsBase64)
                                  throws java.lang.Exception
Specified by:
commitPreparedTransaction in interface MessagingServerControl
Throws:
java.lang.Exception

rollbackPreparedTransaction

public boolean rollbackPreparedTransaction(java.lang.String transactionAsBase64)
                                    throws java.lang.Exception
Specified by:
rollbackPreparedTransaction in interface MessagingServerControl
Throws:
java.lang.Exception

listRemoteAddresses

public java.lang.String[] listRemoteAddresses()
Specified by:
listRemoteAddresses in interface MessagingServerControl

listRemoteAddresses

public java.lang.String[] listRemoteAddresses(java.lang.String ipAddress)
Specified by:
listRemoteAddresses in interface MessagingServerControl

closeConnectionsForAddress

public boolean closeConnectionsForAddress(java.lang.String ipAddress)
Specified by:
closeConnectionsForAddress in interface MessagingServerControl

listConnectionIDs

public java.lang.String[] listConnectionIDs()
Specified by:
listConnectionIDs in interface MessagingServerControl

listSessions

public java.lang.String[] listSessions(java.lang.String connectionID)
Specified by:
listSessions in interface MessagingServerControl

getConnectors

public java.lang.Object[] getConnectors()
                                 throws java.lang.Exception
Specified by:
getConnectors in interface MessagingServerControl
Throws:
java.lang.Exception

getConnectorsAsJSON

public java.lang.String getConnectorsAsJSON()
                                     throws java.lang.Exception
Specified by:
getConnectorsAsJSON in interface MessagingServerControl
Throws:
java.lang.Exception

sendQueueInfoToQueue

public void sendQueueInfoToQueue(java.lang.String queueName,
                                 java.lang.String address)
                          throws java.lang.Exception
Specified by:
sendQueueInfoToQueue in interface MessagingServerControl
Throws:
java.lang.Exception

removeNotificationListener

public void removeNotificationListener(javax.management.NotificationListener listener,
                                       javax.management.NotificationFilter filter,
                                       java.lang.Object handback)
                                throws javax.management.ListenerNotFoundException
Specified by:
removeNotificationListener in interface javax.management.NotificationEmitter
Throws:
javax.management.ListenerNotFoundException

removeNotificationListener

public void removeNotificationListener(javax.management.NotificationListener listener)
                                throws javax.management.ListenerNotFoundException
Specified by:
removeNotificationListener in interface javax.management.NotificationBroadcaster
Throws:
javax.management.ListenerNotFoundException

addNotificationListener

public void addNotificationListener(javax.management.NotificationListener listener,
                                    javax.management.NotificationFilter filter,
                                    java.lang.Object handback)
                             throws java.lang.IllegalArgumentException
Specified by:
addNotificationListener in interface javax.management.NotificationBroadcaster
Throws:
java.lang.IllegalArgumentException

getNotificationInfo

public javax.management.MBeanNotificationInfo[] getNotificationInfo()
Specified by:
getNotificationInfo in interface javax.management.NotificationBroadcaster

getConnectionTTLOverride

public long getConnectionTTLOverride()
Specified by:
getConnectionTTLOverride in interface MessagingServerControl

getIDCacheSize

public int getIDCacheSize()
Specified by:
getIDCacheSize in interface MessagingServerControl

getLargeMessagesDirectory

public java.lang.String getLargeMessagesDirectory()
Specified by:
getLargeMessagesDirectory in interface MessagingServerControl

getManagementAddress

public java.lang.String getManagementAddress()
Specified by:
getManagementAddress in interface MessagingServerControl

getManagementNotificationAddress

public java.lang.String getManagementNotificationAddress()
Specified by:
getManagementNotificationAddress in interface MessagingServerControl

getManagementRequestTimeout

public long getManagementRequestTimeout()
Specified by:
getManagementRequestTimeout in interface MessagingServerControl

getMessageExpiryScanPeriod

public long getMessageExpiryScanPeriod()
Specified by:
getMessageExpiryScanPeriod in interface MessagingServerControl

getMessageExpiryThreadPriority

public long getMessageExpiryThreadPriority()
Specified by:
getMessageExpiryThreadPriority in interface MessagingServerControl

getGlobalPageSize

public int getGlobalPageSize()
Specified by:
getGlobalPageSize in interface MessagingServerControl

getQueueActivationTimeout

public long getQueueActivationTimeout()
Specified by:
getQueueActivationTimeout in interface MessagingServerControl

getTransactionTimeout

public long getTransactionTimeout()
Specified by:
getTransactionTimeout in interface MessagingServerControl

getTransactionTimeoutScanPeriod

public long getTransactionTimeoutScanPeriod()
Specified by:
getTransactionTimeoutScanPeriod in interface MessagingServerControl

isPersistDeliveryCountBeforeDelivery

public boolean isPersistDeliveryCountBeforeDelivery()
Specified by:
isPersistDeliveryCountBeforeDelivery in interface MessagingServerControl

isPersistIDCache

public boolean isPersistIDCache()
Specified by:
isPersistIDCache in interface MessagingServerControl

isWildcardRoutingEnabled

public boolean isWildcardRoutingEnabled()
Specified by:
isWildcardRoutingEnabled in interface MessagingServerControl


Copyright © 2006 JBoss Inc. All Rights Reserved.