HornetQServerControlImpl (HornetQ Parent 2.4.7.Final API)

java.lang.Object
- javax.management.StandardMBean
- - org.hornetq.core.management.impl.AbstractControl
  - - org.hornetq.core.management.impl.HornetQServerControlImpl

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, NotificationBroadcaster, NotificationEmitter, HornetQServerControl, NotificationListener
```
public class HornetQServerControlImpl
extends AbstractControl
implements HornetQServerControl, NotificationEmitter, NotificationListener
```
Author:

Jeff Mesnil

Field Summary
- Fields inherited from class org.hornetq.core.management.impl.AbstractControl
  storageManager

Constructor Summary

Constructors
Constructor and Description
`HornetQServerControlImpl(PostOffice postOffice, Configuration configuration, ResourceManager resourceManager, RemotingService remotingService, HornetQServer messagingServer, MessageCounterManager messageCounterManager, StorageManager storageManager, NotificationBroadcasterSupport broadcaster)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addAddressSettings(String address, String DLA, String expiryAddress, long expiryDelay, boolean lastValueQueue, int deliveryAttempts, long maxSizeBytes, int pageSizeBytes, int pageMaxCacheSize, long redeliveryDelay, double redeliveryMultiplier, long maxRedeliveryDelay, long redistributionDelay, boolean sendToDLAOnNoRoute, String addressFullMessagePolicy, long slowConsumerThreshold, long slowConsumerCheckPeriod, String slowConsumerPolicy)` adds a new address setting for a specific address
`void`	`addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback)`
`void`	`addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles)`
`boolean`	`closeConnectionsForAddress(String ipAddress)` Closes all the connections of clients connected to this server which matches the specified IP address.
`boolean`	`closeConnectionsForUser(String userName)` Closes all the connections of sessions with a matching user name.
`boolean`	`closeConsumerConnectionsForAddress(String address)` Closes all the connections of clients connected to this server which matches the specified IP address.
`boolean`	`commitPreparedTransaction(String transactionAsBase64)` Heuristically commits a prepared transaction.
`void`	`createBridge(String name, String queueName, String forwardingAddress, String filterString, String transformerClassName, long retryInterval, double retryIntervalMultiplier, int initialConnectAttempts, int reconnectAttempts, boolean useDuplicateDetection, int confirmationWindowSize, long clientFailureCheckPeriod, String connectorNames, boolean useDiscoveryGroup, boolean ha, String user, String password)`
`void`	`createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName)`
`void`	`createQueue(String address, String name)` Create a durable queue.
`void`	`createQueue(String address, String name, boolean durable)` Create a queue.
`void`	`createQueue(String address, String name, String filterStr, boolean durable)` Create a queue.
`void`	`deployQueue(String address, String name, String filterString)` Deploy a durable queue.
`void`	`deployQueue(String address, String name, String filterStr, boolean durable)` Deploy a queue.
`void`	`destroyBridge(String name)`
`void`	`destroyDivert(String name)`
`void`	`destroyQueue(String name)` Destroys the queue corresponding to the specified name.
`void`	`disableMessageCounters()` Disables message counters for this server.
`void`	`enableMessageCounters()` Enables message counters for this server.
`protected MBeanOperationInfo[]`	`fillMBeanOperationInfo()`
`void`	`forceFailover()`
`String[]`	`getAddressNames()` Returns the addresses created on this server.
`String`	`getAddressSettingsAsJSON(String address)` returns the address settings as a JSON string
`String`	`getBindingsDirectory()` Returns the file system directory used to store bindings.
`String[]`	`getBridgeNames()`
`int`	`getConnectionCount()` Returns the number of connections connected to this server.
`long`	`getConnectionTTLOverride()` Returns the connection time to live.
`Object[]`	`getConnectors()` Returns the connectors configured for this server.
`String`	`getConnectorsAsJSON()` Returns the connectors configured for this server using JSON serialization.
`String[]`	`getDivertNames()`
`int`	`getIDCacheSize()` Returns the size of the cache for pre-creating message IDs.
`String[]`	`getIncomingInterceptorClassNames()` Returns the list of interceptors used by this server for incoming messages.
`String[]`	`getInterceptorClassNames()` Returns the list of interceptors used by this server.
`int`	`getJournalBufferSize()` Returns the size of the internal buffer on the journal.
`int`	`getJournalBufferTimeout()` Returns the timeout (in nanoseconds) used to flush internal buffers on the journal.
`int`	`getJournalCompactMinFiles()` Returns the minimal number of journal files before compacting.
`int`	`getJournalCompactPercentage()` Return the percentage of live data before compacting the journal.
`String`	`getJournalDirectory()` Returns the file system directory used to store journal log.
`int`	`getJournalFileSize()` Returns the size (in bytes) of each journal files.
`int`	`getJournalMaxIO()` Returns the maximum number of write requests that can be in the AIO queue at any given time.
`int`	`getJournalMinFiles()` Returns the number of journal files to pre-create.
`String`	`getJournalType()` Returns the type of journal used by this server (either `NIO` or `ASYNCIO`).
`String`	`getLargeMessagesDirectory()` Returns the file system directory used to store large messages.
`String`	`getManagementAddress()` Returns the management address of this server.
`String`	`getManagementNotificationAddress()` Returns the management notification address of this server.
`int`	`getMessageCounterMaxDayCount()` Returns the maximum number of days kept in memory for message counter.
`long`	`getMessageCounterSamplePeriod()` Returns the sample period (in milliseconds) to take message counter snapshot.
`long`	`getMessageExpiryScanPeriod()` Returns the frequency (in milliseconds) to scan messages to detect which messages have expired.
`long`	`getMessageExpiryThreadPriority()` Returns the priority of the thread used to scan message expiration.
`MBeanNotificationInfo[]`	`getNotificationInfo()`
`String[]`	`getOutgoingInterceptorClassNames()` Returns the list of interceptors used by this server for outgoing messages.
`String`	`getPagingDirectory()` Returns the file system directory used to store paging files.
`String[]`	`getQueueNames()` Returns the names of the queues created on this server.
`Object[]`	`getRoles(String addressMatch)`
`String`	`getRolesAsJSON(String addressMatch)`
`int`	`getScheduledThreadPoolMaxSize()` Returns the maximum number of threads in the scheduled thread pool.
`long`	`getSecurityInvalidationInterval()` Returns the interval time (in milliseconds) to invalidate security credentials.
`int`	`getThreadPoolMaxSize()` Returns the maximum number of threads in the thread pool.
`long`	`getTransactionTimeout()` Returns the timeout (in milliseconds) after which transactions is removed from the resource manager after it was created.
`long`	`getTransactionTimeoutScanPeriod()` Returns the frequency (in milliseconds) to scan transactions to detect which transactions have timed out.
`String`	`getVersion()` Returns this server's version.
`boolean`	`isAsyncConnectionExecutionEnabled()` Returns whether code coming from connection is executed asynchronously or not.
`boolean`	`isBackup()` Returns `true` if this server is a backup, `false` if it is a live server.
`boolean`	`isClustered()` Returns whether this server is clustered.
`boolean`	`isCreateBindingsDir()` Returns whether the bindings directory is created on this server startup.
`boolean`	`isCreateJournalDir()` Returns whether the journal directory is created on this server startup.
`boolean`	`isFailoverOnServerShutdown()` returns if clients failover on a server shutdown
`boolean`	`isJournalSyncNonTransactional()` Returns whether the journal is synchronized when receiving non-transactional data.
`boolean`	`isJournalSyncTransactional()` Returns whether the journal is synchronized when receiving transactional data.
`boolean`	`isMessageCounterEnabled()` Returns whether message counter is enabled for this server.
`boolean`	`isPersistDeliveryCountBeforeDelivery()` Returns whether delivery count is persisted before messages are delivered to the consumers.
`boolean`	`isPersistenceEnabled()` Returns whether this server is using persistence and store data.
`boolean`	`isPersistIDCache()` Returns whether message ID cache is persisted.
`boolean`	`isSecurityEnabled()` Returns whether security is enabled for this server.
`boolean`	`isSharedStore()` Returns whether this server shares its data store with a corresponding live or backup server.
`boolean`	`isStarted()` Return whether this server is started.
`boolean`	`isWildcardRoutingEnabled()` Returns whether wildcard routing is supported by this server.
`String[]`	`listConnectionIDs()` Lists all the IDs of the connections connected to this server.
`String[]`	`listHeuristicCommittedTransactions()` List transactions which have been heuristically committed.
`String[]`	`listHeuristicRolledBackTransactions()` List transactions which have been heuristically rolled back.
`String`	`listPreparedTransactionDetailsAsHTML()` List all the prepared transaction, sorted by date, oldest first, with details, in HTML format
`String`	`listPreparedTransactionDetailsAsJSON()` List all the prepared transaction, sorted by date, oldest first, with details, in text format.
`String[]`	`listPreparedTransactions()` List all the prepared transaction, sorted by date, oldest first.
`String`	`listProducersInfoAsJSON()`
`String[]`	`listRemoteAddresses()` Lists the addresses of all the clients connected to this address.
`String[]`	`listRemoteAddresses(String ipAddress)` Lists the addresses of the clients connected to this address which matches the specified IP address.
`String[]`	`listSessions(String connectionID)` Lists all the sessions IDs for the specified connection ID.
`String[]`	`listTargetAddresses(String sessionID)`
`void`	`onNotification(Notification notification)`
`void`	`removeAddressSettings(String addressMatch)`
`void`	`removeNotificationListener(NotificationListener listener)`
`void`	`removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback)`
`void`	`removeSecuritySettings(String addressMatch)`
`void`	`resetAllMessageCounterHistories()` Reset histories for all message counters.
`void`	`resetAllMessageCounters()` Reset all message counters.
`boolean`	`rollbackPreparedTransaction(String transactionAsBase64)` Heuristically rolls back a prepared transaction.
`void`	`sendQueueInfoToQueue(String queueName, String address)` This method is used by HornetQ clustering and must not be called by HornetQ clients.
`void`	`setFailoverOnServerShutdown(boolean failoverOnServerShutdown)` do any clients failover on a server shutdown
`void`	`setMessageCounterMaxDayCount(int count)` Sets the maximum number of days kept in memory for message counter.
`void`	`setMessageCounterSamplePeriod(long newPeriod)` Sets the sample period to take message counter snapshot.

Methods inherited from class org.hornetq.core.management.impl.AbstractControl
blockOnIO, clearIO, getMBeanInfo

Methods inherited from class javax.management.StandardMBean
cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - HornetQServerControlImpl
```
public HornetQServerControlImpl(PostOffice postOffice,
                                Configuration configuration,
                                ResourceManager resourceManager,
                                RemotingService remotingService,
                                HornetQServer messagingServer,
                                MessageCounterManager messageCounterManager,
                                StorageManager storageManager,
                                NotificationBroadcasterSupport broadcaster)
                         throws Exception
```
    Throws:
    
    Exception
- Method Detail
  - isStarted
```
public boolean isStarted()
```
    Description copied from interface: HornetQServerControl
    
    Return whether this server is started.
    
    Specified by:
    
    isStarted in interface HornetQServerControl
  - getVersion
```
public String getVersion()
```
    Description copied from interface: HornetQServerControl
    
    Returns this server's version.
    
    Specified by:
    
    getVersion in interface HornetQServerControl
  - isBackup
```
public boolean isBackup()
```
    Description copied from interface: HornetQServerControl
    
    Returns true if this server is a backup, false if it is a live server.
    If a backup server has been activated, returns false.
    
    Specified by:
    
    isBackup in interface HornetQServerControl
  - isSharedStore
```
public boolean isSharedStore()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether this server shares its data store with a corresponding live or backup server.
    
    Specified by:
    
    isSharedStore in interface HornetQServerControl
  - getBindingsDirectory
```
public String getBindingsDirectory()
```
    Description copied from interface: HornetQServerControl
    
    Returns the file system directory used to store bindings.
    
    Specified by:
    
    getBindingsDirectory in interface HornetQServerControl
  - getInterceptorClassNames
```
public String[] getInterceptorClassNames()
```
    Description copied from interface: HornetQServerControl
    
    Returns the list of interceptors used by this server. Invoking this method is the same as invoking getIncomingInterceptorClassNames().
    
    Specified by:
    
    getInterceptorClassNames in interface HornetQServerControl
    
    See Also:
    
    Interceptor
  - getIncomingInterceptorClassNames
```
public String[] getIncomingInterceptorClassNames()
```
    Description copied from interface: HornetQServerControl
    
    Returns the list of interceptors used by this server for incoming messages.
    
    Specified by:
    
    getIncomingInterceptorClassNames in interface HornetQServerControl
    
    See Also:
    
    Interceptor
  - getOutgoingInterceptorClassNames
```
public String[] getOutgoingInterceptorClassNames()
```
    Description copied from interface: HornetQServerControl
    
    Returns the list of interceptors used by this server for outgoing messages.
    
    Specified by:
    
    getOutgoingInterceptorClassNames in interface HornetQServerControl
    
    See Also:
    
    Interceptor
  - getJournalBufferSize
```
public int getJournalBufferSize()
```
    Description copied from interface: HornetQServerControl
    
    Returns the size of the internal buffer on the journal.
    
    Specified by:
    
    getJournalBufferSize in interface HornetQServerControl
  - getJournalBufferTimeout
```
public int getJournalBufferTimeout()
```
    Description copied from interface: HornetQServerControl
    
    Returns the timeout (in nanoseconds) used to flush internal buffers on the journal.
    
    Specified by:
    
    getJournalBufferTimeout in interface HornetQServerControl
  - setFailoverOnServerShutdown
```
public void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
```
    Description copied from interface: HornetQServerControl
    
    do any clients failover on a server shutdown
    
    Specified by:
    
    setFailoverOnServerShutdown in interface HornetQServerControl
  - isFailoverOnServerShutdown
```
public boolean isFailoverOnServerShutdown()
```
    Description copied from interface: HornetQServerControl
    
    returns if clients failover on a server shutdown
    
    Specified by:
    
    isFailoverOnServerShutdown in interface HornetQServerControl
  - getJournalMaxIO
```
public int getJournalMaxIO()
```
    Description copied from interface: HornetQServerControl
    
    Returns the maximum number of write requests that can be in the AIO queue at any given time.
    
    Specified by:
    
    getJournalMaxIO in interface HornetQServerControl
  - getJournalDirectory
```
public String getJournalDirectory()
```
    Description copied from interface: HornetQServerControl
    
    Returns the file system directory used to store journal log.
    
    Specified by:
    
    getJournalDirectory in interface HornetQServerControl
  - getJournalFileSize
```
public int getJournalFileSize()
```
    Description copied from interface: HornetQServerControl
    
    Returns the size (in bytes) of each journal files.
    
    Specified by:
    
    getJournalFileSize in interface HornetQServerControl
  - getJournalMinFiles
```
public int getJournalMinFiles()
```
    Description copied from interface: HornetQServerControl
    
    Returns the number of journal files to pre-create.
    
    Specified by:
    
    getJournalMinFiles in interface HornetQServerControl
  - getJournalCompactMinFiles
```
public int getJournalCompactMinFiles()
```
    Description copied from interface: HornetQServerControl
    
    Returns the minimal number of journal files before compacting.
    
    Specified by:
    
    getJournalCompactMinFiles in interface HornetQServerControl
  - getJournalCompactPercentage
```
public int getJournalCompactPercentage()
```
    Description copied from interface: HornetQServerControl
    
    Return the percentage of live data before compacting the journal.
    
    Specified by:
    
    getJournalCompactPercentage in interface HornetQServerControl
  - isPersistenceEnabled
```
public boolean isPersistenceEnabled()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether this server is using persistence and store data.
    
    Specified by:
    
    isPersistenceEnabled in interface HornetQServerControl
  - getJournalType
```
public String getJournalType()
```
    Description copied from interface: HornetQServerControl
    
    Returns the type of journal used by this server (either NIO or ASYNCIO).
    
    Specified by:
    
    getJournalType in interface HornetQServerControl
  - getPagingDirectory
```
public String getPagingDirectory()
```
    Description copied from interface: HornetQServerControl
    
    Returns the file system directory used to store paging files.
    
    Specified by:
    
    getPagingDirectory in interface HornetQServerControl
  - getScheduledThreadPoolMaxSize
```
public int getScheduledThreadPoolMaxSize()
```
    Description copied from interface: HornetQServerControl
    
    Returns the maximum number of threads in the scheduled thread pool.
    
    Specified by:
    
    getScheduledThreadPoolMaxSize in interface HornetQServerControl
  - getThreadPoolMaxSize
```
public int getThreadPoolMaxSize()
```
    Description copied from interface: HornetQServerControl
    
    Returns the maximum number of threads in the thread pool.
    
    Specified by:
    
    getThreadPoolMaxSize in interface HornetQServerControl
  - getSecurityInvalidationInterval
```
public long getSecurityInvalidationInterval()
```
    Description copied from interface: HornetQServerControl
    
    Returns the interval time (in milliseconds) to invalidate security credentials.
    
    Specified by:
    
    getSecurityInvalidationInterval in interface HornetQServerControl
  - isClustered
```
public boolean isClustered()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether this server is clustered.
    
    Specified by:
    
    isClustered in interface HornetQServerControl
  - isCreateBindingsDir
```
public boolean isCreateBindingsDir()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether the bindings directory is created on this server startup.
    
    Specified by:
    
    isCreateBindingsDir in interface HornetQServerControl
  - isCreateJournalDir
```
public boolean isCreateJournalDir()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether the journal directory is created on this server startup.
    
    Specified by:
    
    isCreateJournalDir in interface HornetQServerControl
  - isJournalSyncNonTransactional
```
public boolean isJournalSyncNonTransactional()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether the journal is synchronized when receiving non-transactional data.
    
    Specified by:
    
    isJournalSyncNonTransactional in interface HornetQServerControl
  - isJournalSyncTransactional
```
public boolean isJournalSyncTransactional()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether the journal is synchronized when receiving transactional data.
    
    Specified by:
    
    isJournalSyncTransactional in interface HornetQServerControl
  - isSecurityEnabled
```
public boolean isSecurityEnabled()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether security is enabled for this server.
    
    Specified by:
    
    isSecurityEnabled in interface HornetQServerControl
  - isAsyncConnectionExecutionEnabled
```
public boolean isAsyncConnectionExecutionEnabled()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether code coming from connection is executed asynchronously or not.
    
    Specified by:
    
    isAsyncConnectionExecutionEnabled in interface HornetQServerControl
  - deployQueue
```
public void deployQueue(String address,
                        String name,
                        String filterString)
                 throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Deploy a durable queue.
    This method will do nothing if the queue with the given name already exists on the server.
    
    Specified by:
    
    deployQueue in interface HornetQServerControl
    
    Parameters:
    
    address - address to bind the queue to
    
    name - name of the queue
    
    filterString - of the queue
    
    Throws:
    
    Exception
  - deployQueue
```
public void deployQueue(String address,
                        String name,
                        String filterStr,
                        boolean durable)
                 throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Deploy a queue.
    This method will do nothing if the queue with the given name already exists on the server.
    
    Specified by:
    
    deployQueue in interface HornetQServerControl
    
    Parameters:
    
    address - address to bind the queue to
    
    name - name of the queue
    
    filterStr - of the queue
    
    durable - whether the queue is durable
    
    Throws:
    
    Exception
  - createQueue
```
public void createQueue(String address,
                        String name)
                 throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Create a durable queue.
    This method throws a HornetQQueueExistsException) exception if the queue already exits.
    
    Specified by:
    
    createQueue in interface HornetQServerControl
    
    Parameters:
    
    address - address to bind the queue to
    
    name - name of the queue
    
    Throws:
    
    Exception
  - createQueue
```
public void createQueue(String address,
                        String name,
                        boolean durable)
                 throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Create a queue.
    This method throws a HornetQQueueExistsException) exception if the queue already exits.
    
    Specified by:
    
    createQueue in interface HornetQServerControl
    
    Parameters:
    
    address - address to bind the queue to
    
    name - name of the queue
    
    durable - whether the queue is durable
    
    Throws:
    
    Exception
  - createQueue
```
public void createQueue(String address,
                        String name,
                        String filterStr,
                        boolean durable)
                 throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Create a queue.
    This method throws a HornetQQueueExistsException) exception if the queue already exits.
    
    Specified by:
    
    createQueue in interface HornetQServerControl
    
    Parameters:
    
    address - address to bind the queue to
    
    name - name of the queue
    
    filterStr - of the queue
    
    durable - whether the queue is durable
    
    Throws:
    
    Exception
  - getQueueNames
```
public String[] getQueueNames()
```
    Description copied from interface: HornetQServerControl
    
    Returns the names of the queues created on this server.
    
    Specified by:
    
    getQueueNames in interface HornetQServerControl
  - getAddressNames
```
public String[] getAddressNames()
```
    Description copied from interface: HornetQServerControl
    
    Returns the addresses created on this server.
    
    Specified by:
    
    getAddressNames in interface HornetQServerControl
  - destroyQueue
```
public void destroyQueue(String name)
                  throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Destroys the queue corresponding to the specified name.
    
    Specified by:
    
    destroyQueue in interface HornetQServerControl
    
    Throws:
    
    Exception
  - getConnectionCount
```
public int getConnectionCount()
```
    Description copied from interface: HornetQServerControl
    
    Returns the number of connections connected to this server.
    
    Specified by:
    
    getConnectionCount in interface HornetQServerControl
  - enableMessageCounters
```
public void enableMessageCounters()
```
    Description copied from interface: HornetQServerControl
    
    Enables message counters for this server.
    
    Specified by:
    
    enableMessageCounters in interface HornetQServerControl
  - disableMessageCounters
```
public void disableMessageCounters()
```
    Description copied from interface: HornetQServerControl
    
    Disables message counters for this server.
    
    Specified by:
    
    disableMessageCounters in interface HornetQServerControl
  - resetAllMessageCounters
```
public void resetAllMessageCounters()
```
    Description copied from interface: HornetQServerControl
    
    Reset all message counters.
    
    Specified by:
    
    resetAllMessageCounters in interface HornetQServerControl
  - resetAllMessageCounterHistories
```
public void resetAllMessageCounterHistories()
```
    Description copied from interface: HornetQServerControl
    
    Reset histories for all message counters.
    
    Specified by:
    
    resetAllMessageCounterHistories in interface HornetQServerControl
  - isMessageCounterEnabled
```
public boolean isMessageCounterEnabled()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether message counter is enabled for this server.
    
    Specified by:
    
    isMessageCounterEnabled in interface HornetQServerControl
  - getMessageCounterSamplePeriod
```
public long getMessageCounterSamplePeriod()
```
    Description copied from interface: HornetQServerControl
    
    Returns the sample period (in milliseconds) to take message counter snapshot.
    
    Specified by:
    
    getMessageCounterSamplePeriod in interface HornetQServerControl
  - setMessageCounterSamplePeriod
```
public void setMessageCounterSamplePeriod(long newPeriod)
```
    Description copied from interface: HornetQServerControl
    
    Sets the sample period to take message counter snapshot.
    
    Specified by:
    
    setMessageCounterSamplePeriod in interface HornetQServerControl
    
    Parameters:
    
    newPeriod - value must be greater than 1000ms
  - getMessageCounterMaxDayCount
```
public int getMessageCounterMaxDayCount()
```
    Description copied from interface: HornetQServerControl
    
    Returns the maximum number of days kept in memory for message counter.
    
    Specified by:
    
    getMessageCounterMaxDayCount in interface HornetQServerControl
  - setMessageCounterMaxDayCount
```
public void setMessageCounterMaxDayCount(int count)
```
    Description copied from interface: HornetQServerControl
    
    Sets the maximum number of days kept in memory for message counter.
    
    Specified by:
    
    setMessageCounterMaxDayCount in interface HornetQServerControl
    
    Parameters:
    
    count - value must be greater than 0
  - listPreparedTransactions
```
public String[] listPreparedTransactions()
```
    Description copied from interface: HornetQServerControl
    
    List all the prepared transaction, sorted by date, oldest first.
    The Strings are Base-64 representation of the transaction XID and can be used to heuristically commit or rollback the transactions.
    
    Specified by:
    
    listPreparedTransactions in interface HornetQServerControl
    
    See Also:
    
    HornetQServerControl.commitPreparedTransaction(String), HornetQServerControl.rollbackPreparedTransaction(String)
  - listPreparedTransactionDetailsAsJSON
```
public String listPreparedTransactionDetailsAsJSON()
                                            throws Exception
```
    Description copied from interface: HornetQServerControl
    
    List all the prepared transaction, sorted by date, oldest first, with details, in text format.
    
    Specified by:
    
    listPreparedTransactionDetailsAsJSON in interface HornetQServerControl
    
    Throws:
    
    Exception
  - listPreparedTransactionDetailsAsHTML
```
public String listPreparedTransactionDetailsAsHTML()
                                            throws Exception
```
    Description copied from interface: HornetQServerControl
    
    List all the prepared transaction, sorted by date, oldest first, with details, in HTML format
    
    Specified by:
    
    listPreparedTransactionDetailsAsHTML in interface HornetQServerControl
    
    Throws:
    
    Exception
  - listHeuristicCommittedTransactions
```
public String[] listHeuristicCommittedTransactions()
```
    Description copied from interface: HornetQServerControl
    
    List transactions which have been heuristically committed.
    
    Specified by:
    
    listHeuristicCommittedTransactions in interface HornetQServerControl
  - listHeuristicRolledBackTransactions
```
public String[] listHeuristicRolledBackTransactions()
```
    Description copied from interface: HornetQServerControl
    
    List transactions which have been heuristically rolled back.
    
    Specified by:
    
    listHeuristicRolledBackTransactions in interface HornetQServerControl
  - commitPreparedTransaction
```
public boolean commitPreparedTransaction(String transactionAsBase64)
                                  throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Heuristically commits a prepared transaction.
    
    Specified by:
    
    commitPreparedTransaction in interface HornetQServerControl
    
    Parameters:
    
    transactionAsBase64 - base 64 representation of a prepare transaction
    
    Returns:
    
    true if the transaction was successfully committed, false else
    
    Throws:
    
    Exception
    
    See Also:
    
    HornetQServerControl.listPreparedTransactions()
  - rollbackPreparedTransaction
```
public boolean rollbackPreparedTransaction(String transactionAsBase64)
                                    throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Heuristically rolls back a prepared transaction.
    
    Specified by:
    
    rollbackPreparedTransaction in interface HornetQServerControl
    
    Parameters:
    
    transactionAsBase64 - base 64 representation of a prepare transaction
    
    Returns:
    
    true if the transaction was successfully rolled back, false else
    
    Throws:
    
    Exception
    
    See Also:
    
    HornetQServerControl.listPreparedTransactions()
  - listRemoteAddresses
```
public String[] listRemoteAddresses()
```
    Description copied from interface: HornetQServerControl
    
    Lists the addresses of all the clients connected to this address.
    
    Specified by:
    
    listRemoteAddresses in interface HornetQServerControl
  - listRemoteAddresses
```
public String[] listRemoteAddresses(String ipAddress)
```
    Description copied from interface: HornetQServerControl
    
    Lists the addresses of the clients connected to this address which matches the specified IP address.
    
    Specified by:
    
    listRemoteAddresses in interface HornetQServerControl
  - closeConnectionsForAddress
```
public boolean closeConnectionsForAddress(String ipAddress)
```
    Description copied from interface: HornetQServerControl
    
    Closes all the connections of clients connected to this server which matches the specified IP address.
    
    Specified by:
    
    closeConnectionsForAddress in interface HornetQServerControl
  - closeConsumerConnectionsForAddress
```
public boolean closeConsumerConnectionsForAddress(String address)
```
    Description copied from interface: HornetQServerControl
    
    Closes all the connections of clients connected to this server which matches the specified IP address.
    
    Specified by:
    
    closeConsumerConnectionsForAddress in interface HornetQServerControl
  - closeConnectionsForUser
```
public boolean closeConnectionsForUser(String userName)
```
    Description copied from interface: HornetQServerControl
    
    Closes all the connections of sessions with a matching user name.
    
    Specified by:
    
    closeConnectionsForUser in interface HornetQServerControl
  - listConnectionIDs
```
public String[] listConnectionIDs()
```
    Description copied from interface: HornetQServerControl
    
    Lists all the IDs of the connections connected to this server.
    
    Specified by:
    
    listConnectionIDs in interface HornetQServerControl
  - listSessions
```
public String[] listSessions(String connectionID)
```
    Description copied from interface: HornetQServerControl
    
    Lists all the sessions IDs for the specified connection ID.
    
    Specified by:
    
    listSessions in interface HornetQServerControl
  - listProducersInfoAsJSON
```
public String listProducersInfoAsJSON()
                               throws Exception
```
    Specified by:
    
    listProducersInfoAsJSON in interface HornetQServerControl
    
    Throws:
    
    Exception
  - getConnectors
```
public Object[] getConnectors()
                       throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Returns the connectors configured for this server.
    
    Specified by:
    
    getConnectors in interface HornetQServerControl
    
    Throws:
    
    Exception
  - getConnectorsAsJSON
```
public String getConnectorsAsJSON()
                           throws Exception
```
    Description copied from interface: HornetQServerControl
    
    Returns the connectors configured for this server using JSON serialization.
    
    Specified by:
    
    getConnectorsAsJSON in interface HornetQServerControl
    
    Throws:
    
    Exception
  - addSecuritySettings
```
public void addSecuritySettings(String addressMatch,
                                String sendRoles,
                                String consumeRoles,
                                String createDurableQueueRoles,
                                String deleteDurableQueueRoles,
                                String createNonDurableQueueRoles,
                                String deleteNonDurableQueueRoles,
                                String manageRoles)
                         throws Exception
```
    Specified by:
    
    addSecuritySettings in interface HornetQServerControl
    
    Throws:
    
    Exception
  - removeSecuritySettings
```
public void removeSecuritySettings(String addressMatch)
                            throws Exception
```
    Specified by:
    
    removeSecuritySettings in interface HornetQServerControl
    
    Throws:
    
    Exception
  - getRoles
```
public Object[] getRoles(String addressMatch)
                  throws Exception
```
    Specified by:
    
    getRoles in interface HornetQServerControl
    
    Throws:
    
    Exception
  - getRolesAsJSON
```
public String getRolesAsJSON(String addressMatch)
                      throws Exception
```
    Specified by:
    
    getRolesAsJSON in interface HornetQServerControl
    
    Throws:
    
    Exception
  - getAddressSettingsAsJSON
```
public String getAddressSettingsAsJSON(String address)
                                throws Exception
```
    Description copied from interface: HornetQServerControl
    
    returns the address settings as a JSON string
    
    Specified by:
    
    getAddressSettingsAsJSON in interface HornetQServerControl
    
    Throws:
    
    Exception
  - addAddressSettings
```
public void addAddressSettings(String address,
                               String DLA,
                               String expiryAddress,
                               long expiryDelay,
                               boolean lastValueQueue,
                               int deliveryAttempts,
                               long maxSizeBytes,
                               int pageSizeBytes,
                               int pageMaxCacheSize,
                               long redeliveryDelay,
                               double redeliveryMultiplier,
                               long maxRedeliveryDelay,
                               long redistributionDelay,
                               boolean sendToDLAOnNoRoute,
                               String addressFullMessagePolicy,
                               long slowConsumerThreshold,
                               long slowConsumerCheckPeriod,
                               String slowConsumerPolicy)
                        throws Exception
```
    Description copied from interface: HornetQServerControl
    
    adds a new address setting for a specific address
    
    Specified by:
    
    addAddressSettings in interface HornetQServerControl
    
    Throws:
    
    Exception
  - removeAddressSettings
```
public void removeAddressSettings(String addressMatch)
                           throws Exception
```
    Specified by:
    
    removeAddressSettings in interface HornetQServerControl
    
    Throws:
    
    Exception
  - sendQueueInfoToQueue
```
public void sendQueueInfoToQueue(String queueName,
                                 String address)
                          throws Exception
```
    Description copied from interface: HornetQServerControl
    
    This method is used by HornetQ clustering and must not be called by HornetQ clients.
    
    Specified by:
    
    sendQueueInfoToQueue in interface HornetQServerControl
    
    Throws:
    
    Exception
  - getDivertNames
```
public String[] getDivertNames()
```
    Specified by:
    
    getDivertNames in interface HornetQServerControl
  - createDivert
```
public void createDivert(String name,
                         String routingName,
                         String address,
                         String forwardingAddress,
                         boolean exclusive,
                         String filterString,
                         String transformerClassName)
                  throws Exception
```
    Specified by:
    
    createDivert in interface HornetQServerControl
    
    Throws:
    
    Exception
  - destroyDivert
```
public void destroyDivert(String name)
                   throws Exception
```
    Specified by:
    
    destroyDivert in interface HornetQServerControl
    
    Throws:
    
    Exception
  - getBridgeNames
```
public String[] getBridgeNames()
```
    Specified by:
    
    getBridgeNames in interface HornetQServerControl
  - createBridge
```
public void createBridge(String name,
                         String queueName,
                         String forwardingAddress,
                         String filterString,
                         String transformerClassName,
                         long retryInterval,
                         double retryIntervalMultiplier,
                         int initialConnectAttempts,
                         int reconnectAttempts,
                         boolean useDuplicateDetection,
                         int confirmationWindowSize,
                         long clientFailureCheckPeriod,
                         String connectorNames,
                         boolean useDiscoveryGroup,
                         boolean ha,
                         String user,
                         String password)
                  throws Exception
```
    Specified by:
    
    createBridge in interface HornetQServerControl
    
    Throws:
    
    Exception
  - destroyBridge
```
public void destroyBridge(String name)
                   throws Exception
```
    Specified by:
    
    destroyBridge in interface HornetQServerControl
    
    Throws:
    
    Exception
  - forceFailover
```
public void forceFailover()
                   throws Exception
```
    Specified by:
    
    forceFailover in interface HornetQServerControl
    
    Throws:
    
    Exception
  - removeNotificationListener
```
public void removeNotificationListener(NotificationListener listener,
                                       NotificationFilter filter,
                                       Object handback)
                                throws ListenerNotFoundException
```
    Specified by:
    
    removeNotificationListener in interface NotificationEmitter
    
    Throws:
    
    ListenerNotFoundException
  - removeNotificationListener
```
public void removeNotificationListener(NotificationListener listener)
                                throws ListenerNotFoundException
```
    Specified by:
    
    removeNotificationListener in interface NotificationBroadcaster
    
    Throws:
    
    ListenerNotFoundException
  - addNotificationListener
```
public void addNotificationListener(NotificationListener listener,
                                    NotificationFilter filter,
                                    Object handback)
                             throws IllegalArgumentException
```
    Specified by:
    
    addNotificationListener in interface NotificationBroadcaster
    
    Throws:
    
    IllegalArgumentException
  - getNotificationInfo
```
public MBeanNotificationInfo[] getNotificationInfo()
```
    Specified by:
    
    getNotificationInfo in interface NotificationBroadcaster
  - getConnectionTTLOverride
```
public long getConnectionTTLOverride()
```
    Description copied from interface: HornetQServerControl
    
    Returns the connection time to live.
    This value overrides the connection time to live sent by the client.
    
    Specified by:
    
    getConnectionTTLOverride in interface HornetQServerControl
  - getIDCacheSize
```
public int getIDCacheSize()
```
    Description copied from interface: HornetQServerControl
    
    Returns the size of the cache for pre-creating message IDs.
    
    Specified by:
    
    getIDCacheSize in interface HornetQServerControl
  - getLargeMessagesDirectory
```
public String getLargeMessagesDirectory()
```
    Description copied from interface: HornetQServerControl
    
    Returns the file system directory used to store large messages.
    
    Specified by:
    
    getLargeMessagesDirectory in interface HornetQServerControl
  - getManagementAddress
```
public String getManagementAddress()
```
    Description copied from interface: HornetQServerControl
    
    Returns the management address of this server.
    Clients can send management messages to this address to manage this server.
    
    Specified by:
    
    getManagementAddress in interface HornetQServerControl
  - getManagementNotificationAddress
```
public String getManagementNotificationAddress()
```
    Description copied from interface: HornetQServerControl
    
    Returns the management notification address of this server.
    Clients can bind queues to this address to receive management notifications emitted by this server.
    
    Specified by:
    
    getManagementNotificationAddress in interface HornetQServerControl
  - getMessageExpiryScanPeriod
```
public long getMessageExpiryScanPeriod()
```
    Description copied from interface: HornetQServerControl
    
    Returns the frequency (in milliseconds) to scan messages to detect which messages have expired.
    
    Specified by:
    
    getMessageExpiryScanPeriod in interface HornetQServerControl
  - getMessageExpiryThreadPriority
```
public long getMessageExpiryThreadPriority()
```
    Description copied from interface: HornetQServerControl
    
    Returns the priority of the thread used to scan message expiration.
    
    Specified by:
    
    getMessageExpiryThreadPriority in interface HornetQServerControl
  - getTransactionTimeout
```
public long getTransactionTimeout()
```
    Description copied from interface: HornetQServerControl
    
    Returns the timeout (in milliseconds) after which transactions is removed from the resource manager after it was created.
    
    Specified by:
    
    getTransactionTimeout in interface HornetQServerControl
  - getTransactionTimeoutScanPeriod
```
public long getTransactionTimeoutScanPeriod()
```
    Description copied from interface: HornetQServerControl
    
    Returns the frequency (in milliseconds) to scan transactions to detect which transactions have timed out.
    
    Specified by:
    
    getTransactionTimeoutScanPeriod in interface HornetQServerControl
  - isPersistDeliveryCountBeforeDelivery
```
public boolean isPersistDeliveryCountBeforeDelivery()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether delivery count is persisted before messages are delivered to the consumers.
    
    Specified by:
    
    isPersistDeliveryCountBeforeDelivery in interface HornetQServerControl
  - isPersistIDCache
```
public boolean isPersistIDCache()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether message ID cache is persisted.
    
    Specified by:
    
    isPersistIDCache in interface HornetQServerControl
  - isWildcardRoutingEnabled
```
public boolean isWildcardRoutingEnabled()
```
    Description copied from interface: HornetQServerControl
    
    Returns whether wildcard routing is supported by this server.
    
    Specified by:
    
    isWildcardRoutingEnabled in interface HornetQServerControl
  - fillMBeanOperationInfo
```
protected MBeanOperationInfo[] fillMBeanOperationInfo()
```
    Specified by:
    
    fillMBeanOperationInfo in class AbstractControl
  - listTargetAddresses
```
public String[] listTargetAddresses(String sessionID)
```
  - onNotification
```
public void onNotification(Notification notification)
```
    Specified by:
    
    onNotification in interface NotificationListener

Class HornetQServerControlImpl

Field Summary

Fields inherited from class org.hornetq.core.management.impl.AbstractControl

Constructor Summary

Method Summary

Methods inherited from class org.hornetq.core.management.impl.AbstractControl

Methods inherited from class javax.management.StandardMBean

Methods inherited from class java.lang.Object

Constructor Detail

HornetQServerControlImpl

Method Detail

isStarted

getVersion

isBackup

isSharedStore

getBindingsDirectory

getInterceptorClassNames

getIncomingInterceptorClassNames

getOutgoingInterceptorClassNames

getJournalBufferSize

getJournalBufferTimeout

setFailoverOnServerShutdown

isFailoverOnServerShutdown

getJournalMaxIO

getJournalDirectory

getJournalFileSize

getJournalMinFiles

getJournalCompactMinFiles

getJournalCompactPercentage

isPersistenceEnabled

getJournalType

getPagingDirectory

getScheduledThreadPoolMaxSize

getThreadPoolMaxSize

getSecurityInvalidationInterval

isClustered

isCreateBindingsDir

isCreateJournalDir

isJournalSyncNonTransactional

isJournalSyncTransactional

isSecurityEnabled

isAsyncConnectionExecutionEnabled

deployQueue

deployQueue

createQueue

createQueue

createQueue

getQueueNames

getAddressNames

destroyQueue

getConnectionCount

enableMessageCounters

disableMessageCounters

resetAllMessageCounters

resetAllMessageCounterHistories

isMessageCounterEnabled

getMessageCounterSamplePeriod

setMessageCounterSamplePeriod

getMessageCounterMaxDayCount

setMessageCounterMaxDayCount

listPreparedTransactions

listPreparedTransactionDetailsAsJSON

listPreparedTransactionDetailsAsHTML

listHeuristicCommittedTransactions

listHeuristicRolledBackTransactions

commitPreparedTransaction

rollbackPreparedTransaction

listRemoteAddresses

listRemoteAddresses

closeConnectionsForAddress

closeConsumerConnectionsForAddress

closeConnectionsForUser

listConnectionIDs

listSessions

listProducersInfoAsJSON

getConnectors

getConnectorsAsJSON

addSecuritySettings

removeSecuritySettings

getRoles