[hornetq-commits] JBoss hornetq SVN: r12270 - in trunk: hornetq-commons/src/main/java/org/hornetq/core/logging and 14 other directories.
do-not-reply at jboss.org
do-not-reply at jboss.org
Thu Mar 8 11:08:42 EST 2012
Author: borges
Date: 2012-03-08 11:08:38 -0500 (Thu, 08 Mar 2012)
New Revision: 12270
Modified:
trunk/hornetq-bootstrap/src/main/java/org/hornetq/integration/bootstrap/HornetQBootstrapServer.java
trunk/hornetq-commons/src/main/java/org/hornetq/core/logging/Logger.java
trunk/hornetq-commons/src/main/java/org/hornetq/utils/DataConstants.java
trunk/hornetq-commons/src/main/java/org/hornetq/utils/HornetQThreadFactory.java
trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/AddressSettingsInfo.java
trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/MessageCounterInfo.java
trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/ObjectNameBuilder.java
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientProducerCreditManagerImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/CompressedLargeMessageControllerImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/LargeMessageControllerImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/Topology.java
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/TopologyMember.java
trunk/hornetq-core/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/deployers/impl/FileConfigurationParser.java
trunk/hornetq-core/src/main/java/org/hornetq/core/filter/impl/Operator.java
trunk/hornetq-core/src/main/java/org/hornetq/core/message/impl/MessageImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/messagecounter/MessageCounter.java
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/impl/PagingManagerImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/paging/impl/PagingStoreImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/RemotingConnectionImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/LiveIsStoppingMessage.java
trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalTransaction.java
trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalCompleteRecordTX.java
trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalRollbackRecordTX.java
Log:
UCDetector: Reduce visibility of loads of fields/methods/classes
Modified: trunk/hornetq-bootstrap/src/main/java/org/hornetq/integration/bootstrap/HornetQBootstrapServer.java
===================================================================
--- trunk/hornetq-bootstrap/src/main/java/org/hornetq/integration/bootstrap/HornetQBootstrapServer.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-bootstrap/src/main/java/org/hornetq/integration/bootstrap/HornetQBootstrapServer.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -53,7 +53,7 @@
/**
* The arguments
*/
- protected String[] args;
+ private final String[] args;
private Properties properties;
@@ -77,7 +77,7 @@
/**
* Add a simple shutdown hook to stop the server.
*/
- public void addShutdownHook()
+ private void addShutdownHook()
{
String dirName = System.getProperty("hornetq.config.dir", ".");
final File file = new File(dirName + "/STOP_ME");
@@ -232,7 +232,7 @@
* @param url the deployment url
* @throws Throwable for any error
*/
- protected KernelDeployment deploy(final URL url) throws Throwable
+ private KernelDeployment deploy(final URL url) throws Throwable
{
HornetQBootstrapServer.log.debug("Deploying " + url);
KernelDeployment deployment = deployer.deploy(url);
@@ -271,7 +271,7 @@
properties = props;
}
- protected class Shutdown extends Thread
+ private final class Shutdown extends Thread
{
public Shutdown()
{
Modified: trunk/hornetq-commons/src/main/java/org/hornetq/core/logging/Logger.java
===================================================================
--- trunk/hornetq-commons/src/main/java/org/hornetq/core/logging/Logger.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-commons/src/main/java/org/hornetq/core/logging/Logger.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -24,11 +24,11 @@
import org.hornetq.utils.ClassloadingUtil;
/**
- *
+ *
* A Logger
- *
+ *
* This class allows us to isolate all our logging dependencies in one place
- *
+ *
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*/
@@ -118,7 +118,7 @@
private final LogDelegate delegate;
- Logger(final LogDelegate delegate)
+ private Logger(final LogDelegate delegate)
{
this.delegate = delegate;
}
@@ -202,8 +202,8 @@
{
delegate.trace(message, t);
}
-
-
+
+
private static Object safeInitNewInstance(final String className)
{
return AccessController.doPrivileged(new PrivilegedAction<Object>()
Modified: trunk/hornetq-commons/src/main/java/org/hornetq/utils/DataConstants.java
===================================================================
--- trunk/hornetq-commons/src/main/java/org/hornetq/utils/DataConstants.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-commons/src/main/java/org/hornetq/utils/DataConstants.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -14,13 +14,13 @@
package org.hornetq.utils;
/**
- *
+ *
* A DataConstants
- *
+ *
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*/
-public class DataConstants
+public final class DataConstants
{
public static final int SIZE_INT = 4;
@@ -36,7 +36,7 @@
public static final int SIZE_FLOAT = 4;
- public static final int SIZE_CHAR = 2;
+ static final int SIZE_CHAR = 2;
public static final byte TRUE = 1;
Modified: trunk/hornetq-commons/src/main/java/org/hornetq/utils/HornetQThreadFactory.java
===================================================================
--- trunk/hornetq-commons/src/main/java/org/hornetq/utils/HornetQThreadFactory.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-commons/src/main/java/org/hornetq/utils/HornetQThreadFactory.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -20,9 +20,9 @@
import org.hornetq.core.logging.Logger;
/**
- *
+ *
* A HornetQThreadFactory
- *
+ *
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*/
@@ -37,22 +37,17 @@
private final int threadPriority;
private final boolean daemon;
-
+
private final ClassLoader tccl;
public HornetQThreadFactory(final String groupName, final boolean daemon, final ClassLoader tccl)
{
- this(groupName, Thread.NORM_PRIORITY, daemon, tccl);
- }
-
- public HornetQThreadFactory(final String groupName, final int threadPriority, final boolean daemon, final ClassLoader tccl)
- {
group = new ThreadGroup(groupName + "-" + System.identityHashCode(this));
-
- this.threadPriority = threadPriority;
+ this.threadPriority = Thread.NORM_PRIORITY;
+
this.tccl = tccl;
-
+
this.daemon = daemon;
}
@@ -69,7 +64,7 @@
{
t = new Thread(command, "Thread-" + threadCount.getAndIncrement());
}
-
+
AccessController.doPrivileged(new PrivilegedAction<Object>()
{
public Object run()
@@ -79,7 +74,7 @@
return null;
}
});
-
+
try
{
AccessController.doPrivileged(new PrivilegedAction<Object>()
Modified: trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/AddressSettingsInfo.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/AddressSettingsInfo.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/AddressSettingsInfo.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -29,27 +29,27 @@
// Attributes ----------------------------------------------------
- private String addressFullMessagePolicy;
+ private final String addressFullMessagePolicy;
- private long maxSizeBytes;
+ private final long maxSizeBytes;
- private int pageSizeBytes;
-
+ private final int pageSizeBytes;
+
private int pageCacheMaxSize;
- private int maxDeliveryAttempts;
+ private final int maxDeliveryAttempts;
- private long redeliveryDelay;
+ private final long redeliveryDelay;
- private String deadLetterAddress;
+ private final String deadLetterAddress;
- private String expiryAddress;
+ private final String expiryAddress;
- private boolean lastValueQueue;
+ private final boolean lastValueQueue;
- private long redistributionDelay;
+ private final long redistributionDelay;
- private boolean sendToDLAOnNoRoute;
+ private final boolean sendToDLAOnNoRoute;
// Static --------------------------------------------------------
Modified: trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/MessageCounterInfo.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/MessageCounterInfo.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/MessageCounterInfo.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -23,7 +23,7 @@
/**
* Helper class to create Java Objects from the
* JSON serialization returned by {@link QueueControl#listMessageCounter()}.
- *
+ *
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*/
public class MessageCounterInfo
Modified: trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/ObjectNameBuilder.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/ObjectNameBuilder.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/api/core/management/ObjectNameBuilder.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -75,7 +75,7 @@
/**
* Returns the ObjectName used by AddressControl.
- *
+ *
* @see AddressControl
*/
public ObjectName getAddressObjectName(final SimpleString address) throws Exception
@@ -85,7 +85,7 @@
/**
* Returns the ObjectName used by QueueControl.
- *
+ *
* @see QueueControl
*/
public ObjectName getQueueObjectName(final SimpleString address, final SimpleString name) throws Exception
@@ -100,7 +100,7 @@
/**
* Returns the ObjectName used by DivertControl.
- *
+ *
* @see DivertControl
*/
public ObjectName getDivertObjectName(final String name) throws Exception
@@ -110,7 +110,7 @@
/**
* Returns the ObjectName used by AcceptorControl.
- *
+ *
* @see AcceptorControl
*/
public ObjectName getAcceptorObjectName(final String name) throws Exception
@@ -120,7 +120,7 @@
/**
* Returns the ObjectName used by BroadcastGroupControl.
- *
+ *
* @see BroadcastGroupControl
*/
public ObjectName getBroadcastGroupObjectName(final String name) throws Exception
@@ -130,7 +130,7 @@
/**
* Returns the ObjectName used by BridgeControl.
- *
+ *
* @see BridgeControl
*/
public ObjectName getBridgeObjectName(final String name) throws Exception
@@ -140,7 +140,7 @@
/**
* Returns the ObjectName used by ClusterConnectionControl.
- *
+ *
* @see ClusterConnectionControl
*/
public ObjectName getClusterConnectionObjectName(final String name) throws Exception
@@ -150,7 +150,7 @@
/**
* Returns the ObjectName used by DiscoveryGroupControl.
- *
+ *
* @see DiscoveryGroupControl
*/
public ObjectName getDiscoveryGroupObjectName(final String name) throws Exception
@@ -160,7 +160,7 @@
/**
* Returns the ObjectName used by JMSServerControl.
- *
+ *
* @see JMSServerControl
*/
public ObjectName getJMSServerObjectName() throws Exception
@@ -170,7 +170,7 @@
/**
* Returns the ObjectName used by JMSQueueControl.
- *
+ *
* @see JMSQueueControl
*/
public ObjectName getJMSQueueObjectName(final String name) throws Exception
@@ -180,7 +180,7 @@
/**
* Returns the ObjectName used by TopicControl.
- *
+ *
* @see TopicControl
*/
public ObjectName getJMSTopicObjectName(final String name) throws Exception
@@ -190,7 +190,7 @@
/**
* Returns the ObjectName used by ConnectionFactoryControl.
- *
+ *
* @see ConnectionFactoryControl
*/
public ObjectName getConnectionFactoryObjectName(final String name) throws Exception
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientConsumerImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -49,14 +49,14 @@
{
// Constants
// ------------------------------------------------------------------------------------
-
+
private static final Logger log = Logger.getLogger(ClientConsumerImpl.class);
-
+
private static final boolean isTrace = log.isTraceEnabled();
- public static final long CLOSE_TIMEOUT_MILLISECONDS = 10000;
+ private static final long CLOSE_TIMEOUT_MILLISECONDS = 10000;
- public static final int NUM_PRIORITIES = 10;
+ private static final int NUM_PRIORITIES = 10;
public static final SimpleString FORCED_DELIVERY_MESSAGE = new SimpleString("_hornetq.forced.delivery.seq");
@@ -76,11 +76,11 @@
private final boolean browseOnly;
private final Executor sessionExecutor;
-
+
// For failover we can't send credits back
// while holding a lock or failover could dead lock eventually
// And we can't use the sessionExecutor as that's being used for message handlers
- // for that reason we have a separate flowControlExecutor that's using the thread pool
+ // for that reason we have a separate flowControlExecutor that's using the thread pool
// Which is a OrderedExecutor
private final Executor flowControlExecutor;
@@ -111,7 +111,7 @@
private volatile boolean closed;
private volatile int creditsToSend;
-
+
private volatile boolean failedOver;
private volatile Exception lastException;
@@ -127,13 +127,13 @@
private final SessionQueueQueryResponseMessage queueInfo;
private volatile boolean ackIndividually;
-
+
private final ClassLoader contextClassLoader;
// Constructors
// ---------------------------------------------------------------------------------
- public ClientConsumerImpl(final ClientSessionInternal session,
+ ClientConsumerImpl(final ClientSessionInternal session,
final long id,
final SimpleString queueName,
final SimpleString filterString,
@@ -168,9 +168,9 @@
this.ackBatchSize = ackBatchSize;
this.queueInfo = queueInfo;
-
+
this.contextClassLoader = contextClassLoader;
-
+
this.flowControlExecutor = flowControlExecutor;
}
@@ -281,7 +281,7 @@
failedOver = false;
}
}
-
+
if (callForceDelivery)
{
if (isTrace)
@@ -309,7 +309,7 @@
{
// forced delivery messages are discarded, nothing has been delivered by the queue
resetIfSlowConsumer();
-
+
if (isTrace)
{
log.trace("There was nothing on the queue, leaving it now:: returning null");
@@ -335,7 +335,7 @@
if (expired)
{
m.discardBody();
-
+
session.expire(id, m.getMessageID());
if (clientWindowSize == 0)
@@ -357,7 +357,7 @@
{
largeMessageReceived = m;
}
-
+
if (isTrace)
{
log.trace("Returning " + m);
@@ -385,12 +385,12 @@
public ClientMessage receive(final long timeout) throws HornetQException
{
ClientMessage msg = receive(timeout, false);
-
+
if (msg == null && !closed)
{
msg = receive(0, true);
}
-
+
return msg;
}
@@ -493,7 +493,7 @@
lastAckedMessage = null;
creditsToSend = 0;
-
+
failedOver = true;
ackIndividually = false;
@@ -518,7 +518,7 @@
{
return session;
}
-
+
public SessionQueueQueryResponseMessage getQueueInfo()
{
return queueInfo;
@@ -568,7 +568,7 @@
// consumed in, which means that acking all up to won't work
ackIndividually = true;
}
-
+
// Add it to the buffer
buffer.addTail(messageToHandle, messageToHandle.getPriority());
@@ -658,7 +658,7 @@
try
{
ClientMessageInternal message = iter.next();
-
+
if (message.isLargeMessage())
{
ClientLargeMessageInternal largeMessage = (ClientLargeMessageInternal)message;
@@ -674,7 +674,7 @@
}
clearBuffer();
-
+
try
{
if (currentLargeMessageController != null)
@@ -741,11 +741,11 @@
}
}
- /**
- *
+ /**
+ *
* LargeMessageBuffer will call flowcontrol here, while other handleMessage will also be calling flowControl.
* So, this operation needs to be atomic.
- *
+ *
* @param discountSlowConsumer When dealing with slowConsumers, we need to discount one credit that was pre-sent when the first receive was called. For largeMessage that is only done at the latest packet
*/
public void flowControl(final int messageBytes, final boolean discountSlowConsumer) throws HornetQException
@@ -753,7 +753,7 @@
if (clientWindowSize >= 0)
{
creditsToSend += messageBytes;
-
+
if (creditsToSend >= clientWindowSize)
{
if (clientWindowSize == 0 && discountSlowConsumer)
@@ -806,7 +806,7 @@
// Private
// ---------------------------------------------------------------------------------------
- /**
+ /**
* Sending a initial credit for slow consumers
* */
private void startSlowConsumer()
@@ -833,7 +833,7 @@
latch.countDown();
}
});
-
+
try
{
latch.await(10, TimeUnit.SECONDS);
@@ -859,7 +859,7 @@
{
ClientConsumerImpl.log.trace("Adding Runner on Executor for delivery");
}
-
+
sessionExecutor.execute(runner);
}
@@ -916,7 +916,7 @@
{
return;
}
-
+
session.workDone();
// We pull the message from the buffer from inside the Runnable so we can ensure priority
@@ -935,7 +935,7 @@
{
rateLimiter.limit();
}
-
+
failedOver = false;
synchronized (this)
@@ -950,9 +950,9 @@
//Ignore, this could be a relic from a previous receiveImmediate();
return;
}
-
-
-
+
+
+
boolean expired = message.isExpired();
flowControlBeforeConsumption(message);
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientProducerCreditManagerImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientProducerCreditManagerImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientProducerCreditManagerImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -41,7 +41,7 @@
private final int windowSize;
- public ClientProducerCreditManagerImpl(final ClientSessionInternal session, final int windowSize)
+ ClientProducerCreditManagerImpl(final ClientSessionInternal session, final int windowSize)
{
this.session = session;
@@ -58,24 +58,24 @@
{
boolean needInit = false;
ClientProducerCredits credits;
-
+
synchronized(this)
{
credits = producerCredits.get(address);
-
+
if (credits == null)
{
// Doesn't need to be fair since session is single threaded
credits = new ClientProducerCreditsImpl(session, address, windowSize);
needInit = true;
-
+
producerCredits.put(address, credits);
}
-
+
if (!anon)
{
credits.incrementRefCount();
-
+
// Remove from anon credits (if there)
unReferencedCredits.remove(address);
}
@@ -84,7 +84,7 @@
addToUnReferencedCache(address, credits);
}
}
-
+
// The init is done outside of the lock
// otherwise packages may arrive with flow control
// while this is still sending requests causing a dead lock
@@ -92,7 +92,7 @@
{
credits.init();
}
-
+
return credits;
}
}
@@ -133,15 +133,15 @@
}
producerCredits.clear();
-
+
unReferencedCredits.clear();
}
-
+
public synchronized int creditsMapSize()
{
return producerCredits.size();
}
-
+
public synchronized int unReferencedCreditsSize()
{
return unReferencedCredits.size();
@@ -161,7 +161,7 @@
iter.remove();
- removeEntry(oldest.getKey(), oldest.getValue());
+ removeEntry(oldest.getKey(), oldest.getValue());
}
}
@@ -173,8 +173,8 @@
credits.close();
}
-
-
+
+
static class ClientProducerCreditsNoFlowControl implements ClientProducerCredits
{
static ClientProducerCreditsNoFlowControl instance = new ClientProducerCreditsNoFlowControl();
@@ -216,7 +216,7 @@
public void releaseOutstanding()
{
}
-
+
}
}
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -166,7 +166,7 @@
// Constructors
// ---------------------------------------------------------------------------------
- public ClientSessionFactoryImpl(final ServerLocatorInternal serverLocator,
+ ClientSessionFactoryImpl(final ServerLocatorInternal serverLocator,
final TransportConfiguration connectorConfig,
final long callTimeout,
final long callFailoverTimeout,
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -104,7 +104,7 @@
* $Id: ClientSessionImpl.java 3603 2008-01-21 18:49:20Z timfox $
*
*/
-public class ClientSessionImpl implements ClientSessionInternal, FailureListener, CommandConfirmationHandler
+class ClientSessionImpl implements ClientSessionInternal, FailureListener, CommandConfirmationHandler
{
// Constants ----------------------------------------------------------------------------
@@ -687,7 +687,7 @@
stop(true);
}
- public void stop(final boolean waitForOnMessage) throws HornetQException
+ private void stop(final boolean waitForOnMessage) throws HornetQException
{
checkClosed();
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/CompressedLargeMessageControllerImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/CompressedLargeMessageControllerImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/CompressedLargeMessageControllerImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -40,7 +40,7 @@
*
*
*/
-public class CompressedLargeMessageControllerImpl implements LargeMessageController
+class CompressedLargeMessageControllerImpl implements LargeMessageController
{
// Constants -----------------------------------------------------
@@ -49,7 +49,7 @@
// Attributes ----------------------------------------------------
- final LargeMessageController bufferDelegate;
+ private final LargeMessageController bufferDelegate;
// Static --------------------------------------------------------
@@ -115,7 +115,7 @@
{
return -1;
}
-
+
DataInputStream dataInput = null;
private DataInputStream getStream()
@@ -1002,14 +1002,6 @@
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#compareTo(org.hornetq.api.core.buffers.ChannelBuffer)
- */
- public int compareTo(final HornetQBuffer buffer)
- {
- return -1;
- }
-
public HornetQBuffer copy()
{
throw new UnsupportedOperationException();
@@ -1020,15 +1012,6 @@
throw new UnsupportedOperationException();
}
- // Package protected ---------------------------------------------
-
- // Protected -----------------------------------------------------
-
- // Private -------------------------------------------------------
-
- /**
- * @param body
- */
// Inner classes -------------------------------------------------
public ChannelBuffer channelBuffer()
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/LargeMessageControllerImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/LargeMessageControllerImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/LargeMessageControllerImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -62,7 +62,7 @@
private volatile SessionReceiveContinuationMessage currentPacket = null;
private final long totalSize;
-
+
private final int bufferSize;
private boolean streamEnded = false;
@@ -132,7 +132,7 @@
}
/**
- *
+ *
*/
public void discardUnusedPackets()
{
@@ -207,7 +207,7 @@
}
}
-
+
packets.offer(packet);
}
}
@@ -228,7 +228,7 @@
public synchronized void cancel()
{
-
+
int totalSize = 0;
Packet polledPacket = null;
while ((polledPacket = packets.poll()) != null)
@@ -245,7 +245,7 @@
// what else can we do here?
log.warn(ignored.getMessage(), ignored);
}
-
+
packets.offer(new SessionReceiveContinuationMessage());
streamEnded = true;
streamClosed = true;
@@ -308,7 +308,7 @@
}
/**
- *
+ *
* @param timeWait Milliseconds to Wait. 0 means forever
* @throws Exception
*/
@@ -453,9 +453,6 @@
dst.put(bytesToGet);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getBytes(int, java.io.OutputStream, int)
- */
public void getBytes(final int index, final OutputStream out, final int length) throws IOException
{
byte bytesToGet[] = new byte[length];
@@ -463,26 +460,21 @@
out.write(bytesToGet);
}
- public void getBytes(final long index, final OutputStream out, final int length) throws IOException
+ private void getBytes(final long index, final OutputStream out, final int length) throws IOException
{
byte bytesToGet[] = new byte[length];
getBytes(index, bytesToGet);
out.write(bytesToGet);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getBytes(int, java.nio.channels.GatheringByteChannel, int)
- */
- public int getBytes(final int index, final GatheringByteChannel out, final int length) throws IOException
+ private int getBytes(final int index, final GatheringByteChannel out, final int length) throws IOException
{
byte bytesToGet[] = new byte[length];
getBytes(index, bytesToGet);
return out.write(ByteBuffer.wrap(bytesToGet));
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getInt(int)
- */
+ @Override
public int getInt(final int index)
{
return (getByte(index) & 0xff) << 24 | (getByte(index + 1) & 0xff) << 16 |
@@ -1060,7 +1052,7 @@
{
return (char)readShort();
}
-
+
public char getChar(final int index)
{
return (char)getShort(index);
@@ -1344,7 +1336,7 @@
{
throw new IllegalAccessError("Can't read the messageBody after setting outputStream");
}
-
+
if (index >= totalSize)
{
throw new IndexOutOfBoundsException();
@@ -1410,7 +1402,7 @@
}
readCachePositionStart = position / bufferSize * bufferSize;
-
+
cachedChannel.position(readCachePositionStart);
if (readCache == null)
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/Topology.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/Topology.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/Topology.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -294,7 +294,7 @@
return listenersCopy;
}
- public boolean removeMember(final long uniqueEventID, final String nodeId)
+ boolean removeMember(final long uniqueEventID, final String nodeId)
{
TopologyMember member;
@@ -460,7 +460,7 @@
return members;
}
- public synchronized int nodes()
+ synchronized int nodes()
{
int count = 0;
for (TopologyMember member : topology.values())
@@ -482,7 +482,7 @@
return describe("");
}
- public synchronized String describe(final String text)
+ private synchronized String describe(final String text)
{
StringBuilder desc = new StringBuilder(text + "topology on " + this + ":\n");
for (Entry<String, TopologyMember> entry : new HashMap<String, TopologyMember>(topology).entrySet())
@@ -497,7 +497,7 @@
return desc.toString();
}
- public int members()
+ private int members()
{
return topology.size();
}
@@ -510,7 +510,7 @@
this.owner = owner;
}
- public TransportConfiguration getBackupForConnector(final TransportConfiguration connectorConfiguration)
+ TransportConfiguration getBackupForConnector(final TransportConfiguration connectorConfiguration)
{
for (TopologyMember member : topology.values())
{
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/TopologyMember.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/TopologyMember.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/TopologyMember.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -30,17 +30,12 @@
/** transient to avoid serialization changes */
private transient long uniqueEventID = System.currentTimeMillis();
- public TopologyMember(final Pair<TransportConfiguration, TransportConfiguration> connector)
+ public TopologyMember(final TransportConfiguration a, final TransportConfiguration b)
{
- this.connector = connector;
+ this.connector = new Pair<TransportConfiguration, TransportConfiguration>(a, b);
uniqueEventID = System.currentTimeMillis();
}
- public TopologyMember(final TransportConfiguration a, final TransportConfiguration b)
- {
- this(new Pair<TransportConfiguration, TransportConfiguration>(a, b));
- }
-
public TransportConfiguration getA()
{
return connector.getA();
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -49,21 +49,21 @@
private static final long serialVersionUID = 4077088945050267843L;
- public static final boolean DEFAULT_CLUSTERED = false;
+ static final boolean DEFAULT_CLUSTERED = false;
- public static final boolean DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY = false;
+ static final boolean DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY = false;
- public static final boolean DEFAULT_BACKUP = false;
+ static final boolean DEFAULT_BACKUP = false;
- public static final boolean DEFAULT_ALLOW_AUTO_FAILBACK = true;
+ private static final boolean DEFAULT_ALLOW_AUTO_FAILBACK = true;
- public static final boolean DEFAULT_SHARED_STORE = true;
+ static final boolean DEFAULT_SHARED_STORE = true;
- public static final boolean DEFAULT_FILE_DEPLOYMENT_ENABLED = false;
+ static final boolean DEFAULT_FILE_DEPLOYMENT_ENABLED = false;
- public static final boolean DEFAULT_PERSISTENCE_ENABLED = true;
+ static final boolean DEFAULT_PERSISTENCE_ENABLED = true;
- public static final long DEFAULT_FILE_DEPLOYER_SCAN_PERIOD = 5000;
+ static final long DEFAULT_FILE_DEPLOYER_SCAN_PERIOD = 5000;
public static final int DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE = 5;
@@ -79,7 +79,7 @@
public static final long DEFAULT_CONNECTION_TTL_OVERRIDE = -1;
- public static final boolean DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED = true;
+ static final boolean DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED = true;
public static final String DEFAULT_BINDINGS_DIRECTORY = "data/bindings";
@@ -90,7 +90,7 @@
public static final String DEFAULT_PAGING_DIR = "data/paging";
public static final String DEFAULT_LARGE_MESSAGES_DIR = "data/largemessages";
-
+
public static final int DEFAULT_MAX_CONCURRENT_PAGE_IO = 5;
public static final boolean DEFAULT_CREATE_JOURNAL_DIR = true;
@@ -161,7 +161,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;
@@ -171,13 +171,13 @@
public static final long DEFAULT_CLUSTER_RETRY_INTERVAL = 500;
public static final int DEFAULT_CLUSTER_RECONNECT_ATTEMPTS = -1;
-
+
public static final long DEFAULT_CLUSTER_FAILURE_CHECK_PERIOD = HornetQClient.DEFAULT_CLIENT_FAILURE_CHECK_PERIOD;
-
+
public static final long DEFAULT_CLUSTER_CONNECTION_TTL = HornetQClient.DEFAULT_CONNECTION_TTL;
-
+
public static final double DEFAULT_CLUSTER_RETRY_INTERVAL_MULTIPLIER = HornetQClient.DEFAULT_RETRY_INTERVAL_MULTIPLIER;
-
+
public static final long DEFAULT_CLUSTER_MAX_RETRY_INTERVAL = HornetQClient.DEFAULT_MAX_RETRY_INTERVAL;
public static final boolean DEFAULT_DIVERT_EXCLUSIVE = false;
@@ -199,32 +199,33 @@
public static final String DEFAULT_LOG_DELEGATE_FACTORY_CLASS_NAME = JULLogDelegateFactory.class.getCanonicalName();
// Attributes -----------------------------------------------------------------------------
-
- protected String name = "ConfigurationImpl::" + System.identityHashCode(this);
+ private String name = "ConfigurationImpl::" + System.identityHashCode(this);
+
protected boolean clustered = ConfigurationImpl.DEFAULT_CLUSTERED;
protected boolean backup = ConfigurationImpl.DEFAULT_BACKUP;
- protected boolean allowAutoFailBack = ConfigurationImpl.DEFAULT_ALLOW_AUTO_FAILBACK;
+ private boolean allowAutoFailBack = ConfigurationImpl.DEFAULT_ALLOW_AUTO_FAILBACK;
- protected boolean sharedStore = ConfigurationImpl.DEFAULT_SHARED_STORE;
+ private boolean sharedStore = ConfigurationImpl.DEFAULT_SHARED_STORE;
protected boolean fileDeploymentEnabled = ConfigurationImpl.DEFAULT_FILE_DEPLOYMENT_ENABLED;
- protected boolean persistenceEnabled = ConfigurationImpl.DEFAULT_PERSISTENCE_ENABLED;
+ private boolean persistenceEnabled = ConfigurationImpl.DEFAULT_PERSISTENCE_ENABLED;
protected long fileDeploymentScanPeriod = ConfigurationImpl.DEFAULT_FILE_DEPLOYER_SCAN_PERIOD;
- protected boolean persistDeliveryCountBeforeDelivery = ConfigurationImpl.DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY;
+ private boolean persistDeliveryCountBeforeDelivery =
+ ConfigurationImpl.DEFAULT_PERSIST_DELIVERY_COUNT_BEFORE_DELIVERY;
- protected int scheduledThreadPoolMaxSize = ConfigurationImpl.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE;
+ private int scheduledThreadPoolMaxSize = ConfigurationImpl.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE;
- protected int threadPoolMaxSize = ConfigurationImpl.DEFAULT_THREAD_POOL_MAX_SIZE;
+ private int threadPoolMaxSize = ConfigurationImpl.DEFAULT_THREAD_POOL_MAX_SIZE;
- protected long securityInvalidationInterval = ConfigurationImpl.DEFAULT_SECURITY_INVALIDATION_INTERVAL;
+ private long securityInvalidationInterval = ConfigurationImpl.DEFAULT_SECURITY_INVALIDATION_INTERVAL;
- protected boolean securityEnabled = ConfigurationImpl.DEFAULT_SECURITY_ENABLED;
+ private boolean securityEnabled = ConfigurationImpl.DEFAULT_SECURITY_ENABLED;
protected boolean jmxManagementEnabled = ConfigurationImpl.DEFAULT_JMX_MANAGEMENT_ENABLED;
@@ -234,21 +235,21 @@
protected boolean asyncConnectionExecutionEnabled = ConfigurationImpl.DEFAULT_ASYNC_CONNECTION_EXECUTION_ENABLED;
- protected long messageExpiryScanPeriod = ConfigurationImpl.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD;
+ private long messageExpiryScanPeriod = ConfigurationImpl.DEFAULT_MESSAGE_EXPIRY_SCAN_PERIOD;
- protected int messageExpiryThreadPriority = ConfigurationImpl.DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY;
+ private int messageExpiryThreadPriority = ConfigurationImpl.DEFAULT_MESSAGE_EXPIRY_THREAD_PRIORITY;
protected int idCacheSize = ConfigurationImpl.DEFAULT_ID_CACHE_SIZE;
- protected boolean persistIDCache = ConfigurationImpl.DEFAULT_PERSIST_ID_CACHE;
+ private boolean persistIDCache = ConfigurationImpl.DEFAULT_PERSIST_ID_CACHE;
protected String logDelegateFactoryClassName = ConfigurationImpl.DEFAULT_LOG_DELEGATE_FACTORY_CLASS_NAME;
- protected List<String> interceptorClassNames = new ArrayList<String>();
-
+ private List<String> interceptorClassNames = new ArrayList<String>();
+
protected Map<String, TransportConfiguration> connectorConfigs = new HashMap<String, TransportConfiguration>();
- protected Set<TransportConfiguration> acceptorConfigs = new HashSet<TransportConfiguration>();
+ private Set<TransportConfiguration> acceptorConfigs = new HashSet<TransportConfiguration>();
protected String liveConnectorName;
@@ -258,7 +259,7 @@
protected List<ClusterConnectionConfiguration> clusterConfigurations = new ArrayList<ClusterConnectionConfiguration>();
- protected List<CoreQueueConfiguration> queueConfigurations = new ArrayList<CoreQueueConfiguration>();
+ private List<CoreQueueConfiguration> queueConfigurations = new ArrayList<CoreQueueConfiguration>();
protected List<BroadcastGroupConfiguration> broadcastGroupConfigurations = new ArrayList<BroadcastGroupConfiguration>();
@@ -266,12 +267,12 @@
// Paging related attributes ------------------------------------------------------------
- protected String pagingDirectory = ConfigurationImpl.DEFAULT_PAGING_DIR;
+ private String pagingDirectory = ConfigurationImpl.DEFAULT_PAGING_DIR;
// File related attributes -----------------------------------------------------------
-
- protected int maxConcurrentPageIO = ConfigurationImpl.DEFAULT_MAX_CONCURRENT_PAGE_IO;
+ private int maxConcurrentPageIO = ConfigurationImpl.DEFAULT_MAX_CONCURRENT_PAGE_IO;
+
protected String largeMessagesDirectory = ConfigurationImpl.DEFAULT_LARGE_MESSAGES_DIR;
protected String bindingsDirectory = ConfigurationImpl.DEFAULT_BINDINGS_DIRECTORY;
@@ -316,34 +317,34 @@
protected boolean runSyncSpeedTest = ConfigurationImpl.DEFAULT_RUN_SYNC_SPEED_TEST;
- protected boolean wildcardRoutingEnabled = ConfigurationImpl.DEFAULT_WILDCARD_ROUTING_ENABLED;
+ private boolean wildcardRoutingEnabled = ConfigurationImpl.DEFAULT_WILDCARD_ROUTING_ENABLED;
- protected boolean messageCounterEnabled = ConfigurationImpl.DEFAULT_MESSAGE_COUNTER_ENABLED;
+ private boolean messageCounterEnabled = ConfigurationImpl.DEFAULT_MESSAGE_COUNTER_ENABLED;
- protected long messageCounterSamplePeriod = ConfigurationImpl.DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD;
+ private long messageCounterSamplePeriod = ConfigurationImpl.DEFAULT_MESSAGE_COUNTER_SAMPLE_PERIOD;
- protected int messageCounterMaxDayHistory = ConfigurationImpl.DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY;
+ private int messageCounterMaxDayHistory = ConfigurationImpl.DEFAULT_MESSAGE_COUNTER_MAX_DAY_HISTORY;
- protected long transactionTimeout = ConfigurationImpl.DEFAULT_TRANSACTION_TIMEOUT;
+ private long transactionTimeout = ConfigurationImpl.DEFAULT_TRANSACTION_TIMEOUT;
- protected long transactionTimeoutScanPeriod = ConfigurationImpl.DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD;
+ private long transactionTimeoutScanPeriod = ConfigurationImpl.DEFAULT_TRANSACTION_TIMEOUT_SCAN_PERIOD;
- protected SimpleString managementAddress = ConfigurationImpl.DEFAULT_MANAGEMENT_ADDRESS;
+ private SimpleString managementAddress = ConfigurationImpl.DEFAULT_MANAGEMENT_ADDRESS;
- protected SimpleString managementNotificationAddress = ConfigurationImpl.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS;
+ private SimpleString managementNotificationAddress = ConfigurationImpl.DEFAULT_MANAGEMENT_NOTIFICATION_ADDRESS;
protected String clusterUser = ConfigurationImpl.DEFAULT_CLUSTER_USER;
protected String clusterPassword = ConfigurationImpl.DEFAULT_CLUSTER_PASSWORD;
- protected long serverDumpInterval = ConfigurationImpl.DEFAULT_SERVER_DUMP_INTERVAL;
+ private long serverDumpInterval = ConfigurationImpl.DEFAULT_SERVER_DUMP_INTERVAL;
protected boolean failoverOnServerShutdown = ConfigurationImpl.DEFAULT_FAILOVER_ON_SERVER_SHUTDOWN;
// percentage of free memory which triggers warning from the memory manager
- protected int memoryWarningThreshold = ConfigurationImpl.DEFAULT_MEMORY_WARNING_THRESHOLD;
+ private int memoryWarningThreshold = ConfigurationImpl.DEFAULT_MEMORY_WARNING_THRESHOLD;
- protected long memoryMeasureInterval = ConfigurationImpl.DEFAULT_MEMORY_MEASURE_INTERVAL;
+ private long memoryMeasureInterval = ConfigurationImpl.DEFAULT_MEMORY_MEASURE_INTERVAL;
protected GroupingHandlerConfiguration groupingHandlerConfiguration;
@@ -529,7 +530,7 @@
{
this.liveConnectorName = liveConnectorName;
}
-
+
public GroupingHandlerConfiguration getGroupingHandlerConfiguration()
{
return groupingHandlerConfiguration;
@@ -629,8 +630,8 @@
{
bindingsDirectory = dir;
}
-
+
/* (non-Javadoc)
* @see org.hornetq.core.config.Configuration#getPageMaxConcurrentIO()
*/
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/deployers/impl/FileConfigurationParser.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/deployers/impl/FileConfigurationParser.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/deployers/impl/FileConfigurationParser.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -80,7 +80,7 @@
private static final String ROLES_ATTR_NAME = "roles";
- private static final String CREATEDURABLEQUEUE_NAME = "createDurableQueue";
+ static final String CREATEDURABLEQUEUE_NAME = "createDurableQueue";
private static final String DELETEDURABLEQUEUE_NAME = "deleteDurableQueue";
@@ -431,8 +431,8 @@
"journal-directory",
config.getJournalDirectory(),
Validators.NOT_NULL_OR_EMPTY));
-
-
+
+
config.setPageMaxConcurrentIO(XMLConfigurationUtil.getInteger(e,
"page-max-concurrent-io",
5,
@@ -1016,7 +1016,7 @@
"max-hops",
ConfigurationImpl.DEFAULT_CLUSTER_MAX_HOPS,
Validators.GE_ZERO);
-
+
long clientFailureCheckPeriod = XMLConfigurationUtil.getLong(e, "check-period",
ConfigurationImpl.DEFAULT_CLUSTER_FAILURE_CHECK_PERIOD, Validators.GT_ZERO) ;
@@ -1028,18 +1028,18 @@
"retry-interval",
ConfigurationImpl.DEFAULT_CLUSTER_RETRY_INTERVAL,
Validators.GT_ZERO);
-
+
long callTimeout = XMLConfigurationUtil.getLong(e, "call-timeout", HornetQClient.DEFAULT_CALL_TIMEOUT, Validators.GT_ZERO);
long callFailoverTimeout = XMLConfigurationUtil.getLong(e, "call-failover-timeout", HornetQClient.DEFAULT_CALL_FAILOVER_TIMEOUT, Validators.MINUS_ONE_OR_GT_ZERO);
-
- double retryIntervalMultiplier = XMLConfigurationUtil.getDouble(e, "retry-interval-multiplier",
+
+ double retryIntervalMultiplier = XMLConfigurationUtil.getDouble(e, "retry-interval-multiplier",
ConfigurationImpl.DEFAULT_CLUSTER_RETRY_INTERVAL_MULTIPLIER, Validators.GT_ZERO);
-
+
int minLargeMessageSize = XMLConfigurationUtil.getInteger(e, "min-large-message-size", HornetQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE, Validators.GT_ZERO);
-
+
long maxRetryInterval = XMLConfigurationUtil.getLong(e, "max-retry-interval", ConfigurationImpl.DEFAULT_CLUSTER_MAX_RETRY_INTERVAL, Validators.GT_ZERO);
-
+
int reconnectAttempts = XMLConfigurationUtil.getInteger(e, "reconnect-attempts", ConfigurationImpl.DEFAULT_CLUSTER_RECONNECT_ATTEMPTS, Validators.MINUS_ONE_OR_GE_ZERO);
@@ -1167,15 +1167,15 @@
long connectionTTL = XMLConfigurationUtil.getLong(brNode, "connection-ttl",
HornetQClient.DEFAULT_CONNECTION_TTL, Validators.GT_ZERO) ;
-
+
int minLargeMessageSize = XMLConfigurationUtil.getInteger(brNode,
"min-large-message-size",
HornetQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE,
Validators.GT_ZERO);
-
+
long maxRetryInterval = XMLConfigurationUtil.getLong(brNode, "max-retry-interval", HornetQClient.DEFAULT_MAX_RETRY_INTERVAL, Validators.GT_ZERO);
-
+
double retryIntervalMultiplier = XMLConfigurationUtil.getDouble(brNode,
"retry-interval-multiplier",
HornetQClient.DEFAULT_RETRY_INTERVAL_MULTIPLIER,
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/filter/impl/Operator.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/filter/impl/Operator.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/filter/impl/Operator.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -46,7 +46,7 @@
Object oper3;
- Object arg1;
+ private Object arg1;
Object arg2;
@@ -81,7 +81,7 @@
public final static int DIFFERENT = 8;
- public final static int ADD = 9;
+ final static int ADD = 9;
public final static int SUB = 10;
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/message/impl/MessageImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/message/impl/MessageImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/message/impl/MessageImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -24,7 +24,6 @@
import org.hornetq.api.core.PropertyConversionException;
import org.hornetq.api.core.SimpleString;
import org.hornetq.core.buffers.impl.ResetLimitWrappedHornetQBuffer;
-import org.hornetq.core.logging.Logger;
import org.hornetq.core.message.BodyEncoder;
import org.hornetq.core.protocol.core.impl.PacketImpl;
import org.hornetq.utils.DataConstants;
@@ -47,17 +46,13 @@
*/
public abstract class MessageImpl implements MessageInternal
{
- // Constants -----------------------------------------------------
-
- private static final Logger log = Logger.getLogger(MessageImpl.class);
-
public static final SimpleString HDR_ROUTE_TO_IDS = new SimpleString("_HQ_ROUTE_TO");
-
- // used by the bridges to set duplicates
+
+ // used by the bridges to set duplicates
public static final SimpleString HDR_BRIDGE_DUPLICATE_ID = new SimpleString("_HQ_BRIDGE_DUP");
public static final int BUFFER_HEADER_SPACE = PacketImpl.PACKET_HEADERS_SIZE;
-
+
public static final int BODY_OFFSET = BUFFER_HEADER_SPACE + DataConstants.SIZE_INT;
@@ -70,7 +65,7 @@
protected boolean durable;
/** GMT milliseconds at which this message expires. 0 means never expires * */
- protected long expiration;
+ private long expiration;
protected long timestamp;
@@ -91,7 +86,7 @@
private boolean copied = true;
private boolean bufferUsed;
-
+
private UUID userID;
// Constructors --------------------------------------------------
@@ -201,7 +196,7 @@
{
return DataConstants.SIZE_LONG + // Message ID
DataConstants.SIZE_BYTE + // user id null?
- (userID == null ? 0 : 16) +
+ (userID == null ? 0 : 16) +
/* address */SimpleString.sizeofNullableString(address) +
DataConstants./* Type */SIZE_BYTE +
DataConstants./* Durable */SIZE_BOOLEAN +
@@ -210,8 +205,8 @@
DataConstants./* Priority */SIZE_BYTE +
/* PropertySize and Properties */properties.getEncodeSize();
}
-
+
public void encodeHeadersAndProperties(final HornetQBuffer buffer)
{
buffer.writeLong(messageID);
@@ -254,7 +249,7 @@
priority = buffer.readByte();
properties.decode(buffer);
}
-
+
public void copyHeadersAndProperties(final MessageInternal msg)
{
messageID = msg.getMessageID();
@@ -267,7 +262,7 @@
priority = msg.getPriority();
properties = msg.getTypedProperties();
}
-
+
public HornetQBuffer getBodyBuffer()
{
if (bodyBuffer == null)
@@ -282,18 +277,18 @@
{
return messageID;
}
-
+
public UUID getUserID()
{
return userID;
}
-
+
public void setUserID(final UUID userID)
{
this.userID = userID;
}
- /** this doesn't need to be synchronized as setAddress is protecting the buffer,
+ /** this doesn't need to be synchronized as setAddress is protecting the buffer,
* not the address*/
public SimpleString getAddress()
{
@@ -313,7 +308,7 @@
if (this.address != address)
{
this.address = address;
-
+
bufferValid = false;
}
}
@@ -513,7 +508,7 @@
return buffer;
}
}
-
+
public void setAddressTransient(final SimpleString address)
{
this.address = address;
@@ -585,7 +580,7 @@
bufferValid = false;
}
-
+
public void putObjectProperty(final SimpleString key, final Object value) throws PropertyConversionException
{
if (value == null)
@@ -826,7 +821,7 @@
{
return properties.getSimpleStringProperty(new SimpleString(key));
}
-
+
public Object getObjectProperty(final String key)
{
return properties.getProperty(new SimpleString(key));
@@ -870,7 +865,7 @@
{
return new DecodingContext();
}
-
+
public TypedProperties getTypedProperties()
{
return this.properties;
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/messagecounter/MessageCounter.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/messagecounter/MessageCounter.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/messagecounter/MessageCounter.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -540,7 +540,7 @@
/**
* Finalize day counter hour array elements
*/
- void finalizeDayCounter()
+ private void finalizeDayCounter()
{
// a new day has began, so fill all array elements from index to end with
// '0' values
@@ -571,7 +571,7 @@
* "Date, hour counter 0, hour counter 1, ..., hour counter 23".
* @return String day counter data
*/
- String getDayCounterAsString()
+ private String getDayCounterAsString()
{
// first element day counter date
DateFormat dateFormat = DateFormat.getDateInstance(DateFormat.SHORT);
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -57,10 +57,10 @@
/**
* A PageCursorImpl
*
- * A page cursor will always store its
+ * A page cursor will always store its
* @author <a href="mailto:clebert.suconic at jboss.com">Clebert Suconic</a>
*/
-public class PageSubscriptionImpl implements PageSubscription
+class PageSubscriptionImpl implements PageSubscription
{
// Constants -----------------------------------------------------
private static final Logger log = Logger.getLogger(PageSubscriptionImpl.class);
@@ -97,21 +97,19 @@
private final SortedMap<Long, PageCursorInfo> consumedPages = Collections.synchronizedSortedMap(new TreeMap<Long, PageCursorInfo>());
private final PageSubscriptionCounter counter;
-
+
private final Executor executor;
private final AtomicLong deliveredCount = new AtomicLong(0);
// We only store the position for redeliveries. They will be read from the SoftCache again during delivery.
private final ConcurrentLinkedQueue<PagePosition> redeliveries = new ConcurrentLinkedQueue<PagePosition>();
-
-
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
- public PageSubscriptionImpl(final PageCursorProvider cursorProvider,
+ PageSubscriptionImpl(final PageCursorProvider cursorProvider,
final PagingStore pageStore,
final StorageManager store,
final Executor executor,
@@ -210,7 +208,7 @@
}
}
- /**
+ /**
* It will cleanup all the records for completed pages
* */
public void cleanupEntries(final boolean completeDelete) throws Exception
@@ -228,7 +226,7 @@
// First get the completed pages using a lock
synchronized (this)
{
- for (Entry<Long, PageCursorInfo> entry : consumedPages.entrySet())
+ for (Entry<Long, PageCursorInfo> entry : consumedPages.entrySet())
{
PageCursorInfo info = entry.getValue();
if (info.isDone() && !info.isPendingDelete() && lastAckedPosition != null)
@@ -294,7 +292,7 @@
}
}
- if (!completeDelete)
+ if (!completeDelete)
{
cursorProvider.scheduleCleanup();
}
@@ -380,7 +378,7 @@
}
/**
- *
+ *
*/
private synchronized PagePosition getStartPosition()
{
@@ -412,7 +410,7 @@
}
}
- if (isTrace)
+ if (isTrace)
{
trace("Returning initial position " + retValue);
}
@@ -535,7 +533,7 @@
}
}
- /**
+ /**
* Theres no need to synchronize this method as it's only called from journal load on startup
*/
public void reloadACK(final PagePosition position)
@@ -565,7 +563,7 @@
processACK(position);
}
-
+
public void lateDeliveryRollback(PagePosition position)
{
PageCursorInfo cursorInfo = processACK(position);
@@ -589,9 +587,9 @@
final long tx = store.generateUniqueID();
try
{
-
+
boolean isPersistent = false;
-
+
synchronized (PageSubscriptionImpl.this)
{
for (PageCursorInfo cursor : consumedPages.values())
@@ -606,12 +604,12 @@
}
}
}
-
+
if (isPersistent)
{
store.commit(tx);
}
-
+
cursorProvider.close(this);
}
catch (Exception e)
@@ -761,7 +759,7 @@
// Protected -----------------------------------------------------
- protected boolean match(final ServerMessage message)
+ private boolean match(final ServerMessage message)
{
if (filter == null)
{
@@ -791,7 +789,7 @@
{
log.trace("Scheduling cleanup on pageSubscription for address = " + pageStore.getAddress() + " queue = " + this.getQueue().getName());
}
-
+
// there's a different page being acked, we will do the check right away
if (autoCleanup)
{
@@ -803,7 +801,7 @@
PageCursorInfo info = getPageInfo(pos);
info.addACK(pos);
-
+
return info;
}
@@ -860,7 +858,7 @@
// Inner classes -------------------------------------------------
- /**
+ /**
* This will hold information about the pending ACKs towards a page.
* This instance will be released as soon as the entire page is consumed, releasing the memory at that point
* The ref counts are increased also when a message is ignored for any reason.
@@ -985,7 +983,7 @@
}
/**
- *
+ *
*/
protected void checkDone()
{
@@ -1019,11 +1017,12 @@
}
- static class PageCursorTX extends TransactionOperationAbstract
+ private static class PageCursorTX extends TransactionOperationAbstract
{
- HashMap<PageSubscriptionImpl, List<PagePosition>> pendingPositions = new HashMap<PageSubscriptionImpl, List<PagePosition>>();
+ private final Map<PageSubscriptionImpl, List<PagePosition>> pendingPositions =
+ new HashMap<PageSubscriptionImpl, List<PagePosition>>();
- public void addPositionConfirmation(final PageSubscriptionImpl cursor, final PagePosition position)
+ private void addPositionConfirmation(final PageSubscriptionImpl cursor, final PagePosition position)
{
List<PagePosition> list = pendingPositions.get(cursor);
@@ -1036,9 +1035,6 @@
list.add(position);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.transaction.TransactionOperation#afterCommit(org.hornetq.core.transaction.Transaction)
- */
@Override
public void afterCommit(final Transaction tx)
{
@@ -1057,9 +1053,6 @@
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.transaction.TransactionOperation#getRelatedMessageReferences()
- */
@Override
public List<MessageReference> getRelatedMessageReferences()
{
@@ -1068,7 +1061,7 @@
}
- class CursorIterator implements LinkedListIterator<PagedReference>
+ private class CursorIterator implements LinkedListIterator<PagedReference>
{
private PagePosition position = null;
@@ -1188,9 +1181,9 @@
{
ignored = true;
}
-
+
PageCursorInfo info = getPageInfo(message.getPosition(), false);
-
+
if (info != null && info.isRemoved(message.getPosition()))
{
continue;
@@ -1226,7 +1219,7 @@
// Say you have a Browser that will only read the files... there's no need to control PageCursors is
// nothing
// is being changed. That's why the false is passed as a parameter here
-
+
if (info != null && info.isRemoved(message.getPosition()))
{
valid = false;
@@ -1263,7 +1256,7 @@
}
}
- /** QueueImpl::deliver could be calling hasNext while QueueImpl.depage could be using next and hasNext as well.
+ /** QueueImpl::deliver could be calling hasNext while QueueImpl.depage could be using next and hasNext as well.
* It would be a rare race condition but I would prefer avoiding that scenario */
public synchronized boolean hasNext()
{
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/paging/impl/PagingManagerImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/paging/impl/PagingManagerImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/paging/impl/PagingManagerImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -32,7 +32,7 @@
import org.hornetq.core.settings.impl.AddressSettings;
/**
- *
+ *
* @author <a href="mailto:clebert.suconic at jboss.com">Clebert Suconic</a>
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
* @author <a href="mailto:andy.taylor at jboss.org>Andy Taylor</a>
@@ -63,7 +63,7 @@
private final StorageManager storageManager;
- private final ConcurrentMap</*TransactionID*/Long, PageTransactionInfo> transactions =
+ private final ConcurrentMap</*TransactionID*/Long, PageTransactionInfo> transactions =
new ConcurrentHashMap<Long, PageTransactionInfo>();
// Static
@@ -88,9 +88,9 @@
// Public
// ---------------------------------------------------------------------------------------------------------------------------
-
+
// Hierarchical changes listener
-
+
/* (non-Javadoc)
* @see org.hornetq.core.settings.HierarchicalRepositoryChangeListener#onChange()
*/
@@ -100,11 +100,11 @@
}
-
+
// PagingManager implementation
// -----------------------------------------------------------------------------------------------------
- public void reaplySettings()
+ private void reaplySettings()
{
for (PagingStore store : stores.values())
{
@@ -112,7 +112,7 @@
store.applySetting(settings);
}
}
-
+
public SimpleString[] getStoreNames()
{
Set<SimpleString> names = stores.keySet();
@@ -202,7 +202,7 @@
}
return transactions.get(id);
}
-
+
/* (non-Javadoc)
* @see org.hornetq.core.paging.PagingManager#getTransactions()
*/
@@ -302,12 +302,12 @@
syncLock.readLock().unlock();
}
}
-
+
protected PagingStoreFactory getStoreFactory()
{
return pagingStoreFactory;
}
-
+
public void unlock()
{
syncLock.writeLock().unlock();
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/paging/impl/PagingStoreImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/paging/impl/PagingStoreImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/paging/impl/PagingStoreImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -97,7 +97,7 @@
private long pageSize;
- private AddressFullMessagePolicy addressFullMessagePolicy;
+ private volatile AddressFullMessagePolicy addressFullMessagePolicy;
private boolean printedDropMessagesWarning;
@@ -217,6 +217,7 @@
// Public --------------------------------------------------------
+ @Override
public String toString()
{
return "PagingStoreImpl(" + this.address + ")";
@@ -389,18 +390,17 @@
return pagingManager;
}
- // HornetQComponent implementation
-
+ @Override
public boolean isStarted()
{
return running;
}
+ @Override
public synchronized void stop() throws Exception
{
if (running)
{
-
cursorProvider.stop();
running = false;
@@ -429,6 +429,7 @@
}
}
+ @Override
public void start() throws Exception
{
lock.writeLock().lock();
@@ -727,13 +728,13 @@
private final Runnable memoryFreedRunnablesExecutor = new MemoryFreedRunnablesExecutor();
- static final class OurRunnable implements Runnable
+ private static final class OurRunnable implements Runnable
{
- boolean ran;
+ private boolean ran;
- final Runnable runnable;
+ private final Runnable runnable;
- OurRunnable(final Runnable runnable)
+ private OurRunnable(final Runnable runnable)
{
this.runnable = runnable;
}
@@ -826,7 +827,10 @@
}
- protected boolean page(ServerMessage message, final RoutingContext ctx, RouteContextList listCtx, final boolean sync) throws Exception
+ private
+ boolean
+ page(ServerMessage message, final RoutingContext ctx, RouteContextList listCtx, final boolean sync)
+ throws Exception
{
if (!running)
{
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/PacketImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -333,7 +333,7 @@
// Protected -----------------------------------------------------
- protected int stringEncodeSize(final String str)
+ private int stringEncodeSize(final String str)
{
return DataConstants.SIZE_INT + str.length() * 2;
}
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/RemotingConnectionImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/RemotingConnectionImpl.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/RemotingConnectionImpl.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -49,7 +49,7 @@
// ------------------------------------------------------------------------------------
private static final Logger log = Logger.getLogger(RemotingConnectionImpl.class);
-
+
private static final boolean isTrace = log.isTraceEnabled();
// Static
@@ -75,7 +75,7 @@
private volatile boolean destroyed;
private final boolean client;
-
+
private int clientVersion;
// Channels 0-9 are reserved for the system
@@ -93,13 +93,13 @@
private volatile boolean dataReceived;
private final Executor executor;
-
+
private volatile boolean executing;
-
+
private final SimpleString nodeID;
private final long creationTime;
-
+
private String clientID;
// Constructors
@@ -119,7 +119,7 @@
/*
* Create a server side connection
*/
- public RemotingConnectionImpl(final Connection transportConnection,
+ RemotingConnectionImpl(final Connection transportConnection,
final List<Interceptor> interceptors,
final Executor executor,
final SimpleString nodeID)
@@ -148,21 +148,18 @@
this.client = client;
this.executor = executor;
-
+
this.nodeID = nodeID;
-
+
this.creationTime = System.currentTimeMillis();
}
-
-
-
+
+
+
// RemotingConnection implementation
// ------------------------------------------------------------
- /* (non-Javadoc)
- * @see java.lang.Object#toString()
- */
@Override
public String toString()
{
@@ -190,7 +187,7 @@
failureListeners.addAll(listeners);
}
-
+
/**
* @return the clientVersion
*/
@@ -216,7 +213,7 @@
{
return transportConnection.getRemoteAddress();
}
-
+
public long getCreationTime()
{
return creationTime;
@@ -289,26 +286,26 @@
public List<CloseListener> removeCloseListeners()
{
List<CloseListener> ret = new ArrayList<CloseListener>(closeListeners);
-
+
closeListeners.clear();
-
+
return ret;
}
public List<FailureListener> removeFailureListeners()
{
List<FailureListener> ret = new ArrayList<FailureListener>(failureListeners);
-
+
failureListeners.clear();
-
- return ret;
+
+ return ret;
}
public void setCloseListeners(List<CloseListener> listeners)
{
closeListeners.clear();
-
- closeListeners.addAll(listeners);
+
+ closeListeners.addAll(listeners);
}
public HornetQBuffer createBuffer(final int size)
@@ -365,7 +362,7 @@
callClosingListeners();
}
-
+
public void disconnect(final boolean criticalError)
{
Channel channel0 = getChannel(0, -1);
@@ -373,7 +370,7 @@
// And we remove all channels from the connection, this ensures no more packets will be processed after this
// method is
// complete
-
+
Set<Channel> allChannels = new HashSet<Channel>(channels.values());
if (!criticalError)
@@ -388,7 +385,7 @@
}
// Now we are 100% sure that no more packets will be processed we can flush then send the disconnect
-
+
if (!criticalError)
{
for (Channel channel: allChannels)
@@ -468,7 +465,7 @@
}
}
}
-
+
public void checkFlushBatchBuffer()
{
transportConnection.checkFlushBatchBuffer();
@@ -487,16 +484,16 @@
try
{
final Packet packet = PacketDecoder.decode(buffer);
-
+
if (isTrace)
{
log.trace("handling packet " + packet);
}
-
+
if (packet.isAsyncExec() && executor != null)
{
executing = true;
-
+
executor.execute(new Runnable()
{
public void run()
@@ -509,7 +506,7 @@
{
RemotingConnectionImpl.log.error("Unexpected error", t);
}
-
+
executing = false;
}
});
@@ -521,13 +518,13 @@
{
Thread.yield();
}
-
+
// Pings must always be handled out of band so we can send pings back to the client quickly
// otherwise they would get in the queue with everything else which might give an intolerable delay
doBufferReceived(packet);
}
-
- dataReceived = true;
+
+ dataReceived = true;
}
catch (Exception e)
{
@@ -585,8 +582,8 @@
{
channels.clear();
}
- }
-
+ }
+
private void callFailureListeners(final HornetQException me)
{
final List<FailureListener> listenersClone = new ArrayList<FailureListener>(failureListeners);
@@ -642,7 +639,7 @@
{
clientID = cID;
}
-
+
public String getClientID()
{
return clientID;
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/LiveIsStoppingMessage.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/LiveIsStoppingMessage.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/wireformat/LiveIsStoppingMessage.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -17,5 +17,4 @@
{
super(PacketImpl.REPLICATION_SCHEDULED_FAILOVER);
}
-
}
Modified: trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalTransaction.java
===================================================================
--- trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalTransaction.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalTransaction.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -425,9 +425,9 @@
}
}
- static class JournalUpdate
+ private static class JournalUpdate
{
- JournalFile file;
+ private final JournalFile file;
long id;
@@ -438,7 +438,7 @@
* @param id
* @param size
*/
- public JournalUpdate(final JournalFile file, final long id, final int size)
+ private JournalUpdate(final JournalFile file, final long id, final int size)
{
super();
this.file = file;
Modified: trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalCompleteRecordTX.java
===================================================================
--- trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalCompleteRecordTX.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalCompleteRecordTX.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -37,7 +37,7 @@
{
private final boolean isCommit;
- public final long txID;
+ private final long txID;
private final EncodingSupport transactionData;
Modified: trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalRollbackRecordTX.java
===================================================================
--- trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalRollbackRecordTX.java 2012-03-08 16:07:11 UTC (rev 12269)
+++ trunk/hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalRollbackRecordTX.java 2012-03-08 16:08:38 UTC (rev 12270)
@@ -25,7 +25,7 @@
*/
public class JournalRollbackRecordTX extends JournalInternalRecord
{
- public final long txID;
+ private final long txID;
public JournalRollbackRecordTX(final long txID)
{
More information about the hornetq-commits
mailing list