[hornetq-commits] JBoss hornetq SVN: r8710 - in trunk: src/main/org/hornetq/core/config and 4 other directories.

Author: jmesnil Date: 2010-01-05 04:26:41 -0500 (Tue, 05 Jan 2010) New Revision: 8710 Modified: trunk/build-hornetq.xml trunk/src/main/org/hornetq/core/config/Configuration.java trunk/src/main/org/hornetq/core/management/HornetQServerControl.java trunk/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlUsingCoreTest.java trunk/tests/src/org/hornetq/tests/unit/core/deployers/impl/QueueDeployerTest.java Log: HORNETQ-185 + HORNETQ-186: API review + javadoc * added missing javadoc to Configuration interface * added missing attribute asyncConnectionExecutionEnabled to HornetQServerControl * added org.hornetq.core.config.cluster to api javadoc in build-hornetq.xml Modified: trunk/build-hornetq.xml =================================================================== --- trunk/build-hornetq.xml 2010-01-04 17:12:31 UTC (rev 8709) +++ trunk/build-hornetq.xml 2010-01-05 09:26:41 UTC (rev 8710) @@ -1014,6 +1014,7 @@ <include name="org/hornetq"/> <include name="org/hornetq/core/buffers"/> <include name="org/hornetq/core/config"/> + <include name="org/hornetq/core/config/cluster"/> <include name="org/hornetq/core/client"/> <include name="org/hornetq/core/exception"/> <include name="org/hornetq/core/management"/> @@ -1027,7 +1028,7 @@ <classpath refid="javadoc.classpath"/> <doctitle><![CDATA[<h2>HornetQ ${module.version}</h2>]]></doctitle> <bottom><![CDATA[<i>Copyright &#169; 2009 Red Hat Inc. All Rights Reserved.</i>]]></bottom> - <group title="HornetQ Core API" packages="org.hornetq, org.hornetq.core.buffers, org.hornetq.core.client, org.hornetq.core.config, org.hornetq.core.exception, org.hornetq.core.message, org.hornetq.utils"/> + <group title="HornetQ Core API" packages="org.hornetq, org.hornetq.core.buffers, org.hornetq.core.client, org.hornetq.core.config, org.hornetq.core.config.cluster, org.hornetq.core.exception, org.hornetq.core.message, org.hornetq.utils"/> <group title="HornetQ Management API" packages="org.hornetq.core.management"/> <group title="HornetQ Remoting API &amp; SPI " packages="org.hornetq.core.remoting, org.hornetq.core.remoting.spi"/> <group title="JMS Facade" packages="org.hornetq.jms, org.hornetq.jms.client"/> Modified: trunk/src/main/org/hornetq/core/config/Configuration.java =================================================================== --- trunk/src/main/org/hornetq/core/config/Configuration.java 2010-01-04 17:12:31 UTC (rev 8709) +++ trunk/src/main/org/hornetq/core/config/Configuration.java 2010-01-05 09:26:41 UTC (rev 8710) @@ -25,6 +25,7 @@ import org.hornetq.core.config.cluster.DiscoveryGroupConfiguration; import org.hornetq.core.config.cluster.DivertConfiguration; import org.hornetq.core.config.cluster.QueueConfiguration; +import org.hornetq.core.logging.LogDelegateFactory; import org.hornetq.core.remoting.Interceptor; import org.hornetq.core.server.JournalType; import org.hornetq.core.server.group.impl.GroupingHandlerConfiguration; @@ -42,109 +43,211 @@ /** * Returns whether this server is clustered. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_CLUSTERED}. */ boolean isClustered(); + /** + * Sets whether this server is clustered or not. + */ void setClustered(boolean clustered); /** * Returns whether delivery count is persisted before messages are delivered to the consumers. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY}. */ boolean isPersistDeliveryCountBeforeDelivery(); + /** + * Sets whether delivery count is persisted before messages are delivered to consumers. + */ void setPersistDeliveryCountBeforeDelivery(boolean persistDeliveryCountBeforeDelivery); /** * Returns {@code true} if this server is a backup, {@code false} if it is a live server. * <br> * If a backup server has been activated, returns {@code false}. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_BACKUP}. */ boolean isBackup(); + /** + * Sets whether this server is a backup or not. + */ void setBackup(boolean backup); /** * Returns whether this server shares its data store with a corresponding live or backup server. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_SHARED_STORE}. */ boolean isSharedStore(); + /** + * Sets whether this server shares its data store with a backup or live server. + */ void setSharedStore(boolean sharedStore); + /** + * Returns whether this server will use files to configure and deploy its resources. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_FILE_DEPLOYMENT_ENABLED}. + */ boolean isFileDeploymentEnabled(); + /** + * Sets whether this server will use files to configure and deploy its resources. + */ void setFileDeploymentEnabled(boolean enable); /** * Returns whether this server is using persistence and store data. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_PERSISTENCE_ENABLED}. */ boolean isPersistenceEnabled(); + /** + * Sets whether this server is using persistence and store data. + */ void setPersistenceEnabled(boolean enable); + /** + * Returns the period (in milliseconds) to scan configuration files used by deployment. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_FILE_DEPLOYER_SCAN_PERIOD}. + */ long getFileDeployerScanPeriod(); + /** + * Sets the period to scan configuration files used by deployment. + */ void setFileDeployerScanPeriod(long period); /** - * Returns the maximum number of threads in the thread pool. + * Returns the maximum number of threads in the thread pool of this server. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_THREAD_POOL_MAX_SIZE}. */ int getThreadPoolMaxSize(); + /** + * Sets the maximum number of threads in the thread pool of this server. + */ void setThreadPoolMaxSize(int maxSize); /** - * Returns the maximum number of threads in the <em>scheduled</em> thread pool. + * Returns the maximum number of threads in the <em>scheduled</em> thread pool of this server. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE}. */ int getScheduledThreadPoolMaxSize(); + /** + * Sets the maximum number of threads in the <em>scheduled</em> thread pool of this server. + */ void setScheduledThreadPoolMaxSize(int maxSize); /** * Returns the interval time (in milliseconds) to invalidate security credentials. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_SECURITY_INVALIDATION_INTERVAL}. */ long getSecurityInvalidationInterval(); + /** + * Sets the interval time (in milliseconds) to invalidate security credentials. + */ void setSecurityInvalidationInterval(long interval); /** * Returns whether security is enabled for this server. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_SECURITY_ENABLED}. */ boolean isSecurityEnabled(); + /** + * Sets whether security is enabled for this server. + */ void setSecurityEnabled(boolean enabled); + /** + * Returns whether this server is manageable using JMX or not. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JMX_MANAGEMENT_ENABLED}. + */ boolean isJMXManagementEnabled(); + /** + * Sets whether this server is manageable using JMX or not. + */ void setJMXManagementEnabled(boolean enabled); + /** + * Returns the domain used by JMX MBeans (provided JMX management is enabled). + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JMX_DOMAIN}. + */ String getJMXDomain(); + /** + * Sets the domain used by JMX MBeans (provided JMX management is enabled). + * + * Changing this JMX domain is required if multiple HornetQ servers are run inside + * the same JVM and all servers are using the same MBeanServer. + */ void setJMXDomain(String domain); /** - * Returns the list of interceptors used by this server. - * - * @see Interceptor + * Returns the list of interceptors classes used by this server. */ List<String> getInterceptorClassNames(); + /** + * Sets the list of interceptors classes used by this server. + * <br /> + * Classes must implement {@link Interceptor}. + */ void setInterceptorClassNames(List<String> interceptors); /** * Returns the connection time to live. * <br> * This value overrides the connection time to live <em>sent by the client</em>. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_CONNECTION_TTL_OVERRIDE}. */ long getConnectionTTLOverride(); + /** + * Sets the connection time to live. + */ void setConnectionTTLOverride(long ttl); + /** + * Returns whether code coming from connection is executed asynchronously or not. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED}. + */ boolean isAsyncConnectionExecutionEnabled(); + /** + * Sets whether code coming from connection is executed asynchronously or not. + */ void setEnabledAsyncConnectionExecution(boolean enabled); + /** + * Returns the acceptors configured for this server. + */ Set<TransportConfiguration> getAcceptorConfigurations(); + /** + * Sets the acceptors configured for this server. + */ void setAcceptorConfigurations(Set<TransportConfiguration> infos); /** @@ -152,6 +255,9 @@ */ Map<String, TransportConfiguration> getConnectorConfigurations(); + /** + * Sets the connectors configured for this server. + */ void setConnectorConfigurations(Map<String, TransportConfiguration> infos); /** @@ -161,197 +267,385 @@ */ String getBackupConnectorName(); + /** + * Sets the name of the connector used to connect to the backup. + */ void setBackupConnectorName(String name); + /** + * Returns the broadcast groups configured for this server. + */ List<BroadcastGroupConfiguration> getBroadcastGroupConfigurations(); + /** + * Sets the broadcast groups configured for this server. + */ void setBroadcastGroupConfigurations(List<BroadcastGroupConfiguration> configs); + /** + * Returns the discovery groups configured for this server. + */ Map<String, DiscoveryGroupConfiguration> getDiscoveryGroupConfigurations(); + /** + * Sets the discovery groups configured for this server. + */ void setDiscoveryGroupConfigurations(Map<String, DiscoveryGroupConfiguration> configs); + /** + * Returns the grouping handler configured for this server. + */ GroupingHandlerConfiguration getGroupingHandlerConfiguration(); + /** + * Sets the grouping handler configured for this server. + */ void setGroupingHandlerConfiguration(GroupingHandlerConfiguration groupingHandlerConfiguration); + /** + * Returns the bridges configured for this server. + */ List<BridgeConfiguration> getBridgeConfigurations(); + /** + * Sets the bridges configured for this server. + */ void setBridgeConfigurations(final List<BridgeConfiguration> configs); + /** + * Returns the diverts configured for this server. + */ List<DivertConfiguration> getDivertConfigurations(); + /** + * Sets the diverts configured for this server. + */ void setDivertConfigurations(final List<DivertConfiguration> configs); + /** + * Returns the cluster connections configured for this server. + */ List<ClusterConnectionConfiguration> getClusterConfigurations(); + /** + * Sets the cluster connections configured for this server. + */ void setClusterConfigurations(final List<ClusterConnectionConfiguration> configs); + /** + * Returns the queues configured for this server. + */ List<QueueConfiguration> getQueueConfigurations(); + /** + * Sets the queues configured for this server. + */ void setQueueConfigurations(final List<QueueConfiguration> configs); /** * Returns the management address of this server. * <br> * Clients can send management messages to this address to manage this server. + * <br> + * Default value is "hornetq.management". */ SimpleString getManagementAddress(); + /** + * Sets the management address of this server. + */ void setManagementAddress(SimpleString address); /** * Returns the management notification address of this server. * <br> * Clients can bind queues to this address to receive management notifications emitted by this server. + * <br> + * Default value is "hornetq.notifications". */ SimpleString getManagementNotificationAddress(); + /** + * Sets the management notification address of this server. + */ void setManagementNotificationAddress(SimpleString address); + /** + * Returns the management cluster user for this server. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_MANAGEMENT_CLUSTER_USER}. + */ String getManagementClusterUser(); + /** + * Sets the management cluster user for this server. + */ void setManagementClusterUser(String user); + /** + * Returns the management cluster password for this server. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_MANAGEMENT_CLUSTER_PASSWORD}. + */ String getManagementClusterPassword(); + /** + * Sets the management cluster password for this server. + */ void setManagementClusterPassword(String password); /** * Returns the size of the cache for pre-creating message IDs. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_ID_CACHE_SIZE}. */ int getIDCacheSize(); + /** + * Sets the size of the cache for pre-creating message IDs. + */ void setIDCacheSize(int idCacheSize); /** * Returns whether message ID cache is persisted. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_PERSIST_ID_CACHE}. */ boolean isPersistIDCache(); + /** + * Sets whether message ID cache is persisted. + */ void setPersistIDCache(boolean persist); + /** + * Returns the name of the {@link LogDelegateFactory} implementation used by this server + * for logging. + * <br> + * Default value is "org.hornetq.core.logging.impl.JULLogDelegateFactory" + */ String getLogDelegateFactoryClassName(); + /** + * Sets the name of the {@link LogDelegateFactory} implementation used by this server + * for logging. + */ void setLogDelegateFactoryClassName(String className); // Journal related attributes ------------------------------------------------------------ /** * Returns the file system directory used to store bindings. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_BINDINGS_DIRECTORY}. */ String getBindingsDirectory(); + /** + * Sets the file system directory used to store bindings. + */ void setBindingsDirectory(String dir); /** * Returns the file system directory used to store journal log. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_DIR}. */ String getJournalDirectory(); + /** + * Sets the file system directory used to store journal log. + */ void setJournalDirectory(String dir); /** * Returns the type of journal used by this server (either {@code NIO} or {@code ASYNCIO}). + * <br> + * Default value is ASYNCIO. */ JournalType getJournalType(); + /** + * Sets the type of journal used by this server (either {@code NIO} or {@code ASYNCIO}). + */ void setJournalType(JournalType type); /** * Returns whether the journal is synchronized when receiving transactional data. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_SYNC_TRANSACTIONAL}. */ boolean isJournalSyncTransactional(); + /** + * Sets whether the journal is synchronized when receiving transactional data. + */ void setJournalSyncTransactional(boolean sync); /** * Returns whether the journal is synchronized when receiving non-transactional data. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_SYNC_NON_TRANSACTIONAL}. */ boolean isJournalSyncNonTransactional(); + /** + * Sets whether the journal is synchronized when receiving non-transactional data. + */ void setJournalSyncNonTransactional(boolean sync); /** * Returns the size (in bytes) of each journal files. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_FILE_SIZE}. */ int getJournalFileSize(); + /** + * Sets the size (in bytes) of each journal files. + */ void setJournalFileSize(int size); /** * Returns the minimal number of journal files before compacting. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_COMPACT_MIN_FILES}. */ int getJournalCompactMinFiles(); + /** + * Sets the minimal number of journal files before compacting. + */ void setJournalCompactMinFiles(int minFiles); /** - * Return the percentage of live data before compacting the journal. + * Returns the percentage of live data before compacting the journal. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_COMPACT_PERCENTAGE}. */ int getJournalCompactPercentage(); + /** + * Sets the percentage of live data before compacting the journal. + */ void setJournalCompactPercentage(int percentage); /** * Returns the number of journal files to pre-create. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_MIN_FILES}. */ int getJournalMinFiles(); + /** + * Sets the number of journal files to pre-create. + */ void setJournalMinFiles(int files); // AIO and NIO need different values for these params /** * Returns the maximum number of write requests that can be in the AIO queue at any given time. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_MAX_IO_AIO}. */ int getJournalMaxIO_AIO(); + /** + * Sets the maximum number of write requests that can be in the AIO queue at any given time. + */ void setJournalMaxIO_AIO(int journalMaxIO); /** - * Returns the timeout (in nanoseconds) used to flush buffers in the AIO queueu. + * Returns the timeout (in nanoseconds) used to flush buffers in the AIO queue. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO}. */ int getJournalBufferTimeout_AIO(); + /** + * Sets the timeout (in nanoseconds) used to flush buffers in the AIO queue. + */ void setJournalBufferTimeout_AIO(int journalBufferTimeout); + /** + * Returns the buffer size (in bytes) for AIO. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_BUFFER_SIZE_AIO}. + */ int getJournalBufferSize_AIO(); + /** + * Sets the buffer size (in bytes) for AIO. + */ void setJournalBufferSize_AIO(int journalBufferSize); + /** + * Returns the maximum number of write requests for NIO journal. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_MAX_IO_NIO}. + */ int getJournalMaxIO_NIO(); + /** + * Sets the maximum number of write requests for NIO journal. + */ void setJournalMaxIO_NIO(int journalMaxIO); + /** + * Returns the timeout (in nanoseconds) used to flush buffers in the NIO. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO}. + */ int getJournalBufferTimeout_NIO(); + /** + * Sets the timeout (in nanoseconds) used to flush buffers in the NIO. + */ void setJournalBufferTimeout_NIO(int journalBufferTimeout); + /** + * Returns the buffer size (in bytes) for NIO. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_JOURNAL_BUFFER_SIZE_NIO}. + */ int getJournalBufferSize_NIO(); + /** + * Sets the buffer size (in bytes) for NIO. + */ void setJournalBufferSize_NIO(int journalBufferSize); /** * Returns whether the bindings directory is created on this server startup. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_CREATE_BINDINGS_DIR}. */ boolean isCreateBindingsDir(); + /** + * Sets whether the bindings directory is created on this server startup. + */ void setCreateBindingsDir(boolean create); /** * Returns whether the journal directory is created on this server startup. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_CREATE_JOURNAL_DIR}. */ boolean isCreateJournalDir(); + /** + * Sets whether the journal directory is created on this server startup. + */ void setCreateJournalDir(boolean create); + // Undocumented attributes + boolean isLogJournalWriteRate(); void setLogJournalWriteRate(boolean rate); - // Undocumented attributes - int getJournalPerfBlastPages(); void setJournalPerfBlastPages(int pages); @@ -376,89 +670,136 @@ /** * Returns the file system directory used to store paging files. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_PAGING_DIR}. */ String getPagingDirectory(); + /** + * Sets the file system directory used to store paging files. + */ void setPagingDirectory(String dir); // Large Messages Properties ------------------------------------------------------------ /** * Returns the file system directory used to store large messages. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_LARGE_MESSAGES_DIR}. */ String getLargeMessagesDirectory(); + /** + * Sets the file system directory used to store large messages. + */ void setLargeMessagesDirectory(String directory); // Other Properties --------------------------------------------------------------------- /** * Returns whether wildcard routing is supported by this server. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_WILDCARD_ROUTING_ENABLED}. */ boolean isWildcardRoutingEnabled(); + /** + * Sets whether wildcard routing is supported by this server. + */ void setWildcardRoutingEnabled(boolean enabled); /** * Returns the timeout (in milliseconds) after which transactions is removed * from the resource manager after it was created. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_TRANSACTION_TIMEOUT}. */ long getTransactionTimeout(); + /** + * Sets the timeout (in milliseconds) after which transactions is removed + * from the resource manager after it was created. + */ void setTransactionTimeout(long timeout); /** * Returns whether message counter is enabled for this server. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_MESSAGE_COUNTER_ENABLED}. */ boolean isMessageCounterEnabled(); + /** + * Sets whether message counter is enabled for this server. + */ void setMessageCounterEnabled(boolean enabled); /** * Returns the sample period (in milliseconds) to take message counter snapshot. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD}. */ long getMessageCounterSamplePeriod(); /** * Sets the sample period to take message counter snapshot. * - * @param newPeriod value must be greater than 1000ms + * @param period value must be greater than 1000ms */ void setMessageCounterSamplePeriod(long period); /** * Returns the maximum number of days kept in memory for message counter. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY}. */ int getMessageCounterMaxDayHistory(); /** * Sets the maximum number of days kept in memory for message counter. * - * @param count value must be greater than 0 + * @param maxDayHistory value must be greater than 0 */ void setMessageCounterMaxDayHistory(int maxDayHistory); /** * Returns the frequency (in milliseconds) to scan transactions to detect which transactions * have timed out. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD}. */ long getTransactionTimeoutScanPeriod(); + /** + * Sets the frequency (in milliseconds) to scan transactions to detect which transactions + * have timed out. + */ void setTransactionTimeoutScanPeriod(long period); /** * Returns the frequency (in milliseconds) to scan messages to detect which messages * have expired. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD}. */ long getMessageExpiryScanPeriod(); + /** + * Sets the frequency (in milliseconds) to scan messages to detect which messages + * have expired. + */ void setMessageExpiryScanPeriod(long messageExpiryScanPeriod); /** * Returns the priority of the thread used to scan message expiration. + * <br> + * Default value is {@value org.hornetq.core.config.impl.ConfigurationImpl#DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY}. */ int getMessageExpiryThreadPriority(); + /** + * Sets the priority of the thread used to scan message expiration. + */ void setMessageExpiryThreadPriority(int messageExpiryThreadPriority); } Modified: trunk/src/main/org/hornetq/core/management/HornetQServerControl.java =================================================================== --- trunk/src/main/org/hornetq/core/management/HornetQServerControl.java 2010-01-04 17:12:31 UTC (rev 8709) +++ trunk/src/main/org/hornetq/core/management/HornetQServerControl.java 2010-01-05 09:26:41 UTC (rev 8710) @@ -262,6 +262,11 @@ long getMessageExpiryThreadPriority(); /** + * @see Configuration#isAsyncConnectionExecutionEnabled() + */ + boolean isAsyncConnectionExecutionEnabled(); + + /** * @see Configuration#getConnectorConfigurations() */ Object[] getConnectors() throws Exception; Modified: trunk/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java =================================================================== --- trunk/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java 2010-01-04 17:12:31 UTC (rev 8709) +++ trunk/src/main/org/hornetq/core/management/impl/HornetQServerControlImpl.java 2010-01-05 09:26:41 UTC (rev 8710) @@ -472,6 +472,18 @@ } } + public boolean isAsyncConnectionExecutionEnabled() + { + clearIO(); + try + { + return configuration.isAsyncConnectionExecutionEnabled(); + } + finally + { + blockOnIO(); + } + } public void deployQueue(final String address, final String name, final String filterString) throws Exception { clearIO(); Modified: trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java 2010-01-04 17:12:31 UTC (rev 8709) +++ trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java 2010-01-05 09:26:41 UTC (rev 8710) @@ -91,6 +91,7 @@ Assert.assertEquals(conf.getThreadPoolMaxSize(), serverControl.getThreadPoolMaxSize()); Assert.assertEquals(conf.getSecurityInvalidationInterval(), serverControl.getSecurityInvalidationInterval()); Assert.assertEquals(conf.isSecurityEnabled(), serverControl.isSecurityEnabled()); + Assert.assertEquals(conf.isAsyncConnectionExecutionEnabled(), serverControl.isAsyncConnectionExecutionEnabled()); Assert.assertEquals(conf.getInterceptorClassNames().size(), serverControl.getInterceptorClassNames().length); Assert.assertEquals(conf.getConnectionTTLOverride(), serverControl.getConnectionTTLOverride()); Assert.assertEquals(conf.getBackupConnectorName(), serverControl.getBackupConnectorName()); Modified: trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlUsingCoreTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlUsingCoreTest.java 2010-01-04 17:12:31 UTC (rev 8709) +++ trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlUsingCoreTest.java 2010-01-05 09:26:41 UTC (rev 8710) @@ -332,6 +332,11 @@ return (Boolean)proxy.retrieveAttributeValue("persistDeliveryCountBeforeDelivery"); } + public boolean isAsyncConnectionExecutionEnabled() + { + return (Boolean)proxy.retrieveAttributeValue("asyncConnectionExecutionEnabled"); + } + public boolean isPersistIDCache() { return (Boolean)proxy.retrieveAttributeValue("persistIDCache"); Modified: trunk/tests/src/org/hornetq/tests/unit/core/deployers/impl/QueueDeployerTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/unit/core/deployers/impl/QueueDeployerTest.java 2010-01-04 17:12:31 UTC (rev 8709) +++ trunk/tests/src/org/hornetq/tests/unit/core/deployers/impl/QueueDeployerTest.java 2010-01-05 09:26:41 UTC (rev 8710) @@ -435,6 +435,11 @@ return false; } + public boolean isAsyncConnectionExecutionEnabled() + { + return false; + } + public boolean isPersistIDCache() {