[hornetq-commits] JBoss hornetq SVN: r8710 - in trunk: src/main/org/hornetq/core/config and 4 other directories.
do-not-reply at jboss.org
do-not-reply at jboss.org
Tue Jan 5 04:26:41 EST 2010
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 © 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 & 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()
{
More information about the hornetq-commits
mailing list