[hornetq-commits] JBoss hornetq SVN: r10709 - in branches/HORNETQ-698_SplitJournal: hornetq-journal/src/main/java/org/hornetq/core/journal/impl and 1 other directory.
do-not-reply at jboss.org
do-not-reply at jboss.org
Fri May 20 11:47:32 EDT 2011
Author: borges
Date: 2011-05-20 11:47:32 -0400 (Fri, 20 May 2011)
New Revision: 10709
Modified:
branches/HORNETQ-698_SplitJournal/hornetq-core/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java
branches/HORNETQ-698_SplitJournal/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalConstants.java
Log:
Fix compilation issue
Modified: branches/HORNETQ-698_SplitJournal/hornetq-core/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java
===================================================================
--- branches/HORNETQ-698_SplitJournal/hornetq-core/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java 2011-05-20 15:46:40 UTC (rev 10708)
+++ branches/HORNETQ-698_SplitJournal/hornetq-core/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java 2011-05-20 15:47:32 UTC (rev 10709)
@@ -31,6 +31,7 @@
import org.hornetq.core.config.ConnectorServiceConfiguration;
import org.hornetq.core.config.CoreQueueConfiguration;
import org.hornetq.core.config.DivertConfiguration;
+import org.hornetq.core.journal.impl.JournalConstants;
import org.hornetq.core.logging.impl.JULLogDelegateFactory;
import org.hornetq.core.security.Role;
import org.hornetq.core.server.JournalType;
@@ -150,7 +151,7 @@
public static final int DEFAULT_ID_CACHE_SIZE = 2000;
public static final boolean DEFAULT_PERSIST_ID_CACHE = true;
-
+
public static final boolean DEFAULT_CLUSTER_DUPLICATE_DETECTION = true;
public static final boolean DEFAULT_CLUSTER_FORWARD_WHEN_NO_CONSUMERS = false;
@@ -178,7 +179,7 @@
public static final String DEFAULT_LOG_DELEGATE_FACTORY_CLASS_NAME = JULLogDelegateFactory.class.getCanonicalName();
// Attributes -----------------------------------------------------------------------------
-
+
protected String name = "ConfigurationImpl::" + System.identityHashCode(this);
protected boolean clustered = ConfigurationImpl.DEFAULT_CLUSTERED;
@@ -224,7 +225,7 @@
protected String logDelegateFactoryClassName = ConfigurationImpl.DEFAULT_LOG_DELEGATE_FACTORY_CLASS_NAME;
protected List<String> interceptorClassNames = new ArrayList<String>();
-
+
protected Map<String, TransportConfiguration> connectorConfigs = new HashMap<String, TransportConfiguration>();
protected Set<TransportConfiguration> acceptorConfigs = new HashSet<TransportConfiguration>();
@@ -277,15 +278,15 @@
protected int journalMaxIO_AIO = ConfigurationImpl.DEFAULT_JOURNAL_MAX_IO_AIO;
- protected int journalBufferTimeout_AIO = ConfigurationImpl.DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO;
+ protected int journalBufferTimeout_AIO = JournalConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO;
- protected int journalBufferSize_AIO = ConfigurationImpl.DEFAULT_JOURNAL_BUFFER_SIZE_AIO;
+ protected int journalBufferSize_AIO = JournalConstants.DEFAULT_JOURNAL_BUFFER_SIZE_AIO;
protected int journalMaxIO_NIO = ConfigurationImpl.DEFAULT_JOURNAL_MAX_IO_NIO;
- protected int journalBufferTimeout_NIO = ConfigurationImpl.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO;
+ protected int journalBufferTimeout_NIO = JournalConstants.DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO;
- protected int journalBufferSize_NIO = ConfigurationImpl.DEFAULT_JOURNAL_BUFFER_SIZE_NIO;
+ protected int journalBufferSize_NIO = JournalConstants.DEFAULT_JOURNAL_BUFFER_SIZE_NIO;
protected boolean logJournalWriteRate = ConfigurationImpl.DEFAULT_JOURNAL_LOG_WRITE_RATE;
@@ -349,7 +350,7 @@
return allowAutoFailBack;
}
- public void setAllowAutoFailBack(boolean allowAutoFailBack)
+ public void setAllowAutoFailBack(final boolean allowAutoFailBack)
{
this.allowAutoFailBack = allowAutoFailBack;
}
@@ -506,7 +507,7 @@
{
this.liveConnectorName = liveConnectorName;
}
-
+
public GroupingHandlerConfiguration getGroupingHandlerConfiguration()
{
return groupingHandlerConfiguration;
@@ -887,7 +888,7 @@
return failoverOnServerShutdown;
}
- public void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
+ public void setFailoverOnServerShutdown(final boolean failoverOnServerShutdown)
{
this.failoverOnServerShutdown = failoverOnServerShutdown;
}
@@ -1352,7 +1353,7 @@
public List<ConnectorServiceConfiguration> getConnectorServiceConfigurations()
{
- return this.connectorServiceConfigurations;
+ return connectorServiceConfigurations;
}
public long getFailbackDelay()
@@ -1360,14 +1361,14 @@
return failbackDelay;
}
- public void setFailbackDelay(long failbackDelay)
+ public void setFailbackDelay(final long failbackDelay)
{
this.failbackDelay = failbackDelay;
}
public void setConnectorServiceConfigurations(final List<ConnectorServiceConfiguration> configs)
{
- this.connectorServiceConfigurations = configs;
+ connectorServiceConfigurations = configs;
}
/* (non-Javadoc)
@@ -1381,7 +1382,7 @@
/* (non-Javadoc)
* @see org.hornetq.core.config.Configuration#setName(java.lang.String)
*/
- public void setName(String name)
+ public void setName(final String name)
{
this.name = name;
}
Modified: branches/HORNETQ-698_SplitJournal/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalConstants.java
===================================================================
--- branches/HORNETQ-698_SplitJournal/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalConstants.java 2011-05-20 15:46:40 UTC (rev 10708)
+++ branches/HORNETQ-698_SplitJournal/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalConstants.java 2011-05-20 15:47:32 UTC (rev 10709)
@@ -1,8 +1,9 @@
package org.hornetq.core.journal.impl;
-final class JournalConstants {
+public final class JournalConstants
+{
- public static final int DEFAULT_JOURNAL_BUFFER_SIZE_AIO = 490 * 1024;
+ public static final int DEFAULT_JOURNAL_BUFFER_SIZE_AIO = 490 * 1024;
public static final int DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO = (int)(1000000000d / 2000);
public static final int DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO = (int)(1000000000d / 300);
public static final int DEFAULT_JOURNAL_BUFFER_SIZE_NIO = 490 * 1024;
More information about the hornetq-commits
mailing list