org.jboss.messaging.core.management.impl
Class MessagingServerControlImpl
java.lang.Object
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
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 |
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
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.