You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2016/06/13 18:21:27 UTC
[6/7] activemq-artemis git commit: Fix checkstyle redundant modifier
violations
Fix checkstyle redundant modifier violations
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/3923ae45
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3923ae45
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3923ae45
Branch: refs/heads/master
Commit: 3923ae45f42c34778b12863be7cafe360e379276
Parents: d0d023b
Author: Ville Skytt� <vi...@iki.fi>
Authored: Mon Jun 13 18:49:01 2016 +0300
Committer: Ville Skytt� <vi...@iki.fi>
Committed: Mon Jun 13 20:03:54 2016 +0300
----------------------------------------------------------------------
.../artemis/cli/commands/tools/PrintData.java | 2 +-
.../cli/commands/tools/XmlDataExporter.java | 2 +-
.../activemq/artemis/utils/ReusableLatch.java | 2 +-
.../activemq/artemis/utils/TypedProperties.java | 42 ++++++++++----------
.../api/core/UDPBroadcastEndpointFactory.java | 2 +-
.../core/management/CoreNotificationType.java | 2 +-
.../core/client/impl/ClientMessageImpl.java | 2 +-
.../CompressedLargeMessageControllerImpl.java | 2 +-
.../client/impl/LargeMessageControllerImpl.java | 6 +--
.../core/client/impl/ServerLocatorImpl.java | 2 +-
.../artemis/core/message/impl/MessageImpl.java | 2 +-
.../remoting/impl/netty/NettyConnector.java | 4 +-
.../artemis/utils/OrderedExecutorFactory.java | 2 +-
.../artemis/utils/SoftValueHashMap.java | 2 +-
.../apache/activemq/artemis/dto/XmlUtil.java | 2 +-
.../jdbc/store/journal/TransactionHolder.java | 2 +-
.../file/JDBCSequentialFileFactoryTest.java | 2 +-
.../artemis/jms/client/ActiveMQJMSConsumer.java | 2 +-
.../artemis/jms/client/ActiveMQJMSProducer.java | 2 +-
.../jms/client/ActiveMQMessageProducer.java | 6 +--
.../artemis/jms/bridge/impl/JMSBridgeImpl.java | 4 +-
.../server/management/JMSNotificationType.java | 2 +-
.../core/io/aio/AIOSequentialFileFactory.java | 2 +-
.../artemis/core/journal/impl/JournalBase.java | 2 +-
.../core/journal/impl/JournalCompactor.java | 8 ++--
.../artemis/core/journal/impl/JournalImpl.java | 2 +-
.../artemis/jlibaio/test/LibaioTest.java | 2 +-
.../core/protocol/mqtt/MQTTProtocolManager.java | 2 +-
.../org/proton/plug/util/CreditsSemaphore.java | 2 +-
.../org/proton/plug/util/ReusableLatch.java | 2 +-
.../context/AbstractConnectionContextTest.java | 2 +-
.../plug/test/minimalserver/MinimalServer.java | 2 +-
.../protocol/stomp/ActiveMQStompException.java | 2 +-
.../protocol/stomp/StompProtocolManager.java | 8 ++--
.../core/protocol/stomp/StompVersions.java | 2 +-
.../stomp/v11/StompFrameHandlerV11.java | 2 +-
.../artemis/rest/test/AutoAckTopicTest.java | 4 +-
.../selector/filter/ComparisonExpression.java | 2 +-
.../selector/filter/ConstantExpression.java | 2 +-
.../selector/filter/UnaryExpression.java | 2 +-
.../artemis/osgi/ProtocolTrackerTest.java | 2 +-
.../core/config/HAPolicyConfiguration.java | 2 +-
.../artemis/core/config/StoreConfiguration.java | 2 +-
.../artemis/core/filter/impl/FilterImpl.java | 2 +-
.../core/paging/cursor/impl/PageCacheImpl.java | 2 +-
.../impl/PageSubscriptionCounterImpl.java | 2 +-
.../cursor/impl/PageSubscriptionImpl.java | 4 +-
.../paging/impl/PageTransactionInfoImpl.java | 4 +-
.../core/paging/impl/PagingStoreImpl.java | 6 +--
.../core/persistence/StorageManager.java | 2 +-
.../nullpm/NullStorageLargeServerMessage.java | 4 +-
.../artemis/core/protocol/ProtocolHandler.java | 2 +-
.../protocol/core/impl/CoreProtocolManager.java | 10 ++---
.../BackupReplicationStartFailedMessage.java | 2 +-
.../ReplicationLiveIsStoppingMessage.java | 2 +-
.../wireformat/ReplicationStartSyncMessage.java | 2 +-
.../wireformat/ReplicationSyncFileMessage.java | 2 +-
.../impl/netty/HttpAcceptorHandler.java | 6 +--
.../core/server/cluster/BackupManager.java | 28 ++++++-------
.../core/server/cluster/ClusterController.java | 10 ++---
.../core/server/cluster/impl/BridgeImpl.java | 4 +-
.../cluster/impl/ClusterConnectionImpl.java | 16 ++++----
.../server/cluster/qourum/QuorumManager.java | 4 +-
.../server/impl/BackupTopologyListener.java | 2 +-
.../core/server/impl/ColocatedActivation.java | 6 +--
.../artemis/core/server/impl/QueueImpl.java | 6 +--
.../core/server/impl/ReplicationError.java | 2 +-
.../impl/ScheduledDeliveryHandlerImpl.java | 2 +-
.../core/server/impl/ServerConsumerImpl.java | 2 +-
.../impl/SharedNothingLiveActivation.java | 2 +-
.../artemis/core/transaction/Transaction.java | 2 +-
.../transaction/impl/ResourceManagerImpl.java | 2 +-
.../jaas/PropertiesLoginModuleTest.java | 2 +-
.../cluster/impl/BroadcastGroupImplTest.java | 2 +-
.../impl/ScheduledDeliveryHandlerTest.java | 2 +-
.../artemis/core/settings/RepositoryTest.java | 2 +-
.../artemis/tests/util/ActiveMQTestBase.java | 2 +-
.../cli/test/WebServerComponentTest.java | 2 +-
.../activemq/artemis/jms/example/PerfBase.java | 2 +-
.../jms/example/MessageGroupExample.java | 2 +-
.../jms/example/MessageGroup2Example.java | 2 +-
.../jms/example/MessagePriorityExample.java | 2 +-
.../jms/example/QueueSelectorExample.java | 2 +-
.../jms/example/StaticSelectorExample.java | 2 +-
.../jms/example/TopicSelectorExample2.java | 2 +-
.../artemis/jms/example/XASendExample.java | 2 +-
.../aerogear/AeroGearConnectorService.java | 2 +-
.../HierarchicalObjectRepositoryTest.java | 2 +-
.../aerogear/AeroGearBasicServerTest.java | 2 +-
.../integration/client/AutogroupIdTest.java | 2 +-
.../integration/client/CommitRollbackTest.java | 2 +-
.../client/DeadLetterAddressTest.java | 2 +-
.../integration/client/DeliveryOrderTest.java | 2 +-
.../integration/client/HangConsumerTest.java | 42 ++++++++++----------
.../client/InterruptedLargeMessageTest.java | 38 +++++++++---------
.../client/MessageConsumerRollbackTest.java | 2 +-
.../MessageGroupingConnectionFactoryTest.java | 2 +-
.../integration/client/MessageGroupingTest.java | 2 +-
.../integration/client/MessageHandlerTest.java | 6 +--
.../client/MultipleThreadFilterOneTest.java | 4 +-
.../tests/integration/client/PagingTest.java | 10 ++---
.../client/ServerLocatorConnectTest.java | 2 +-
.../client/SessionStopStartTest.java | 8 ++--
.../integration/client/TemporaryQueueTest.java | 2 +-
.../integration/cluster/NodeManagerTest.java | 2 +-
.../distribution/ClusteredGroupingTest.java | 12 +++---
.../cluster/failover/FailBackManualTest.java | 2 +-
.../cluster/failover/QuorumFailOverTest.java | 2 +-
.../MultiThreadReattachSupportTestBase.java | 2 +-
.../cluster/reattach/RandomReattachTest.java | 2 +-
.../jms/client/NewQueueRequestorTest.java | 2 +-
.../jms/connection/ExceptionListenerTest.java | 2 +-
.../jms/jms2client/JmsContextTest.java | 6 +--
.../server/management/JMSServerControlTest.java | 2 +-
.../journal/ValidateTransactionHealthTest.java | 10 ++---
.../ManagementWithPagingServerTest.java | 6 +--
.../openwire/amq/JMSConsumer2Test.java | 2 +-
.../amq/MessageListenerRedeliveryTest.java | 2 +-
.../PagingWithFailoverAndCountersTest.java | 6 +--
.../ra/ActiveMQMessageHandlerTest.java | 4 +-
.../ra/ActiveMQMessageHandlerXATest.java | 4 +-
.../integration/server/ExpiryRunnerTest.java | 2 +-
.../stomp/StompOverWebsocketTest.java | 2 +-
.../stomp/util/AbstractClientStompFrame.java | 2 +-
.../util/AbstractStompClientConnection.java | 2 +-
.../tests/integration/xa/BasicXaTest.java | 2 +-
.../tests/integration/xa/XaTimeoutTest.java | 2 +-
.../jms/tests/AutoAckMesageListenerTest.java | 2 +-
.../artemis/jms/tests/MessageConsumerTest.java | 30 +++++++-------
.../artemis/jms/tests/MessageProducerTest.java | 6 +--
.../artemis/jms/tests/MiscellaneousTest.java | 2 +-
.../jms/tests/TransactedSessionTest.java | 2 +-
.../jms/tests/message/MessageHeaderTest.java | 2 +-
.../paging/MeasurePagingMultiThreadTest.java | 2 +-
.../sends/AbstractSendReceivePerfTest.java | 4 +-
.../JournalCleanupCompactStressTest.java | 6 +--
.../tests/stress/remote/PingStressTest.java | 2 +-
.../jms/bridge/impl/JMSBridgeImplTest.java | 2 +-
.../MultiThreadAsynchronousFileTest.java | 8 ++--
.../core/paging/impl/PagingStoreImplTest.java | 8 ++--
.../impl/WildcardAddressManagerUnitTest.java | 4 +-
.../unit/core/server/impl/QueueImplTest.java | 8 ++--
142 files changed, 310 insertions(+), 310 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/PrintData.java
----------------------------------------------------------------------
diff --git a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/PrintData.java b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/PrintData.java
index 9256acc..7c5fddf 100644
--- a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/PrintData.java
+++ b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/PrintData.java
@@ -289,7 +289,7 @@ public class PrintData extends LockAbstract {
private final Map<Long, Set<Long>> completePages = new HashMap<>();
- public PageCursorsInfo() {
+ private PageCursorsInfo() {
}
/**
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/XmlDataExporter.java
----------------------------------------------------------------------
diff --git a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/XmlDataExporter.java b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/XmlDataExporter.java
index c3deae4..3aec34f 100644
--- a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/XmlDataExporter.java
+++ b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/tools/XmlDataExporter.java
@@ -935,7 +935,7 @@ public final class XmlDataExporter extends LockAbstract {
boolean wrap = true;
- public PrettyPrintHandler(XMLStreamWriter target) {
+ PrettyPrintHandler(XMLStreamWriter target) {
this.target = target;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ReusableLatch.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ReusableLatch.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ReusableLatch.java
index 4f04f22..19023ed 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ReusableLatch.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ReusableLatch.java
@@ -43,7 +43,7 @@ public class ReusableLatch {
@SuppressWarnings("serial")
private static class CountSync extends AbstractQueuedSynchronizer {
- public CountSync(int count) {
+ private CountSync(int count) {
setState(count);
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/TypedProperties.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/TypedProperties.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/TypedProperties.java
index 166f39e..eeb5783 100644
--- a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/TypedProperties.java
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/TypedProperties.java
@@ -598,7 +598,7 @@ public final class TypedProperties {
private static final class NullValue extends PropertyValue {
- public NullValue() {
+ private NullValue() {
}
@Override
@@ -622,11 +622,11 @@ public final class TypedProperties {
final boolean val;
- public BooleanValue(final boolean val) {
+ private BooleanValue(final boolean val) {
this.val = val;
}
- public BooleanValue(final ActiveMQBuffer buffer) {
+ private BooleanValue(final ActiveMQBuffer buffer) {
val = buffer.readBoolean();
}
@@ -652,11 +652,11 @@ public final class TypedProperties {
final byte val;
- public ByteValue(final byte val) {
+ private ByteValue(final byte val) {
this.val = val;
}
- public ByteValue(final ActiveMQBuffer buffer) {
+ private ByteValue(final ActiveMQBuffer buffer) {
val = buffer.readByte();
}
@@ -681,11 +681,11 @@ public final class TypedProperties {
final byte[] val;
- public BytesValue(final byte[] val) {
+ private BytesValue(final byte[] val) {
this.val = val;
}
- public BytesValue(final ActiveMQBuffer buffer) {
+ private BytesValue(final ActiveMQBuffer buffer) {
int len = buffer.readInt();
val = new byte[len];
buffer.readBytes(val);
@@ -714,11 +714,11 @@ public final class TypedProperties {
final short val;
- public ShortValue(final short val) {
+ private ShortValue(final short val) {
this.val = val;
}
- public ShortValue(final ActiveMQBuffer buffer) {
+ private ShortValue(final ActiveMQBuffer buffer) {
val = buffer.readShort();
}
@@ -743,11 +743,11 @@ public final class TypedProperties {
final int val;
- public IntValue(final int val) {
+ private IntValue(final int val) {
this.val = val;
}
- public IntValue(final ActiveMQBuffer buffer) {
+ private IntValue(final ActiveMQBuffer buffer) {
val = buffer.readInt();
}
@@ -772,11 +772,11 @@ public final class TypedProperties {
final long val;
- public LongValue(final long val) {
+ private LongValue(final long val) {
this.val = val;
}
- public LongValue(final ActiveMQBuffer buffer) {
+ private LongValue(final ActiveMQBuffer buffer) {
val = buffer.readLong();
}
@@ -801,11 +801,11 @@ public final class TypedProperties {
final float val;
- public FloatValue(final float val) {
+ private FloatValue(final float val) {
this.val = val;
}
- public FloatValue(final ActiveMQBuffer buffer) {
+ private FloatValue(final ActiveMQBuffer buffer) {
val = Float.intBitsToFloat(buffer.readInt());
}
@@ -831,11 +831,11 @@ public final class TypedProperties {
final double val;
- public DoubleValue(final double val) {
+ private DoubleValue(final double val) {
this.val = val;
}
- public DoubleValue(final ActiveMQBuffer buffer) {
+ private DoubleValue(final ActiveMQBuffer buffer) {
val = Double.longBitsToDouble(buffer.readLong());
}
@@ -860,11 +860,11 @@ public final class TypedProperties {
final char val;
- public CharValue(final char val) {
+ private CharValue(final char val) {
this.val = val;
}
- public CharValue(final ActiveMQBuffer buffer) {
+ private CharValue(final ActiveMQBuffer buffer) {
val = (char) buffer.readShort();
}
@@ -889,11 +889,11 @@ public final class TypedProperties {
final SimpleString val;
- public StringValue(final SimpleString val) {
+ private StringValue(final SimpleString val) {
this.val = val;
}
- public StringValue(final ActiveMQBuffer buffer) {
+ private StringValue(final ActiveMQBuffer buffer) {
val = buffer.readSimpleString();
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/UDPBroadcastEndpointFactory.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/UDPBroadcastEndpointFactory.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/UDPBroadcastEndpointFactory.java
index dff18a5..e5cc1ff 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/UDPBroadcastEndpointFactory.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/UDPBroadcastEndpointFactory.java
@@ -113,7 +113,7 @@ public final class UDPBroadcastEndpointFactory implements BroadcastEndpointFacto
private volatile boolean open;
- public UDPBroadcastEndpoint() {
+ private UDPBroadcastEndpoint() {
}
public UDPBroadcastEndpoint setGroupAddress(InetAddress groupAddress) {
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/CoreNotificationType.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/CoreNotificationType.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/CoreNotificationType.java
index 1821962..ff514ad 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/CoreNotificationType.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/CoreNotificationType.java
@@ -43,7 +43,7 @@ public enum CoreNotificationType implements NotificationType {
private final int value;
- private CoreNotificationType(final int value) {
+ CoreNotificationType(final int value) {
this.value = value;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientMessageImpl.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientMessageImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientMessageImpl.java
index 926ac1b..a6a2231 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientMessageImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientMessageImpl.java
@@ -318,7 +318,7 @@ public class ClientMessageImpl extends MessageImpl implements ClientMessageInter
private final class DecodingContext implements BodyEncoder {
- public DecodingContext() {
+ private DecodingContext() {
}
@Override
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java
index e7cc173..0e826b5 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java
@@ -40,7 +40,7 @@ final class CompressedLargeMessageControllerImpl implements LargeMessageControll
private final LargeMessageController bufferDelegate;
- public CompressedLargeMessageControllerImpl(final LargeMessageController bufferDelegate) {
+ CompressedLargeMessageControllerImpl(final LargeMessageController bufferDelegate) {
this.bufferDelegate = bufferDelegate;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java
index c3b18a3..da4d6bd 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageControllerImpl.java
@@ -1141,7 +1141,7 @@ public class LargeMessageControllerImpl implements LargeMessageController {
private final class FileCache {
- public FileCache(final File cachedFile) {
+ private FileCache(final File cachedFile) {
this.cachedFile = cachedFile;
}
@@ -1323,13 +1323,13 @@ public class LargeMessageControllerImpl implements LargeMessageController {
final int flowControlSize;
final boolean continues;
- public LargeData() {
+ private LargeData() {
continues = false;
flowControlSize = 0;
chunk = null;
}
- public LargeData(byte[] chunk, int flowControlSize, boolean continues) {
+ private LargeData(byte[] chunk, int flowControlSize, boolean continues) {
this.chunk = chunk;
this.flowControlSize = flowControlSize;
this.continues = continues;
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ServerLocatorImpl.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ServerLocatorImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ServerLocatorImpl.java
index 8c71002..e7c67cf 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ServerLocatorImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ServerLocatorImpl.java
@@ -1784,7 +1784,7 @@ public final class ServerLocatorImpl implements ServerLocatorInternal, Discovery
private volatile ClientSessionFactoryInternal factory;
- public Connector(TransportConfiguration initialConnector, ClientSessionFactoryInternal factory) {
+ private Connector(TransportConfiguration initialConnector, ClientSessionFactoryInternal factory) {
this.initialConnector = initialConnector;
this.factory = factory;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/MessageImpl.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/MessageImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/MessageImpl.java
index df77132..10818fa 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/MessageImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/MessageImpl.java
@@ -1013,7 +1013,7 @@ public abstract class MessageImpl implements MessageInternal {
private int lastPos = 0;
- public DecodingContext() {
+ private DecodingContext() {
}
@Override
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java
index b209f89..62c405b 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnector.java
@@ -725,7 +725,7 @@ public class NettyConnector extends AbstractConnector {
private final CountDownLatch latch = new CountDownLatch(1);
private boolean handshakeComplete = false;
- public HttpUpgradeHandler(ChannelPipeline pipeline, HttpClientCodec httpClientCodec) {
+ private HttpUpgradeHandler(ChannelPipeline pipeline, HttpClientCodec httpClientCodec) {
this.pipeline = pipeline;
this.httpClientCodec = httpClientCodec;
}
@@ -798,7 +798,7 @@ public class NettyConnector extends AbstractConnector {
private String cookie;
- public HttpHandler() throws Exception {
+ HttpHandler() throws Exception {
url = new URI("http", null, host, port, servletPath, null, null).toString();
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java
index b0b13ae..d80d7bd 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/OrderedExecutorFactory.java
@@ -74,7 +74,7 @@ public final class OrderedExecutorFactory implements ExecutorFactory {
private static final int STATE_NOT_RUNNING = 0;
private static final int STATE_RUNNING = 1;
- public OrderedExecutor(Executor delegate) {
+ private OrderedExecutor(Executor delegate) {
this.delegate = delegate;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/SoftValueHashMap.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/SoftValueHashMap.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/SoftValueHashMap.java
index b499910..17228c2 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/SoftValueHashMap.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/utils/SoftValueHashMap.java
@@ -342,7 +342,7 @@ public class SoftValueHashMap<K, V extends SoftValueHashMap.ValueCache> implemen
used = usedCounter.incrementAndGet();
}
- public AggregatedSoftReference(final K key, final V referent) {
+ AggregatedSoftReference(final K key, final V referent) {
super(referent, refQueue);
this.key = key;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-dto/src/main/java/org/apache/activemq/artemis/dto/XmlUtil.java
----------------------------------------------------------------------
diff --git a/artemis-dto/src/main/java/org/apache/activemq/artemis/dto/XmlUtil.java b/artemis-dto/src/main/java/org/apache/activemq/artemis/dto/XmlUtil.java
index c49dbe5..5fa8667 100644
--- a/artemis-dto/src/main/java/org/apache/activemq/artemis/dto/XmlUtil.java
+++ b/artemis-dto/src/main/java/org/apache/activemq/artemis/dto/XmlUtil.java
@@ -42,7 +42,7 @@ public class XmlUtil {
static final Pattern pattern = Pattern.compile("\\$\\{([^\\}]+)\\}");
private final Properties props;
- public PropertiesFilter(XMLStreamReader parent, Properties props) {
+ PropertiesFilter(XMLStreamReader parent, Properties props) {
super(parent);
this.props = props;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/TransactionHolder.java
----------------------------------------------------------------------
diff --git a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/TransactionHolder.java b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/TransactionHolder.java
index c03e747..348c823 100644
--- a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/TransactionHolder.java
+++ b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/journal/TransactionHolder.java
@@ -24,7 +24,7 @@ import org.apache.activemq.artemis.core.journal.RecordInfo;
final class TransactionHolder {
- public TransactionHolder(final long id) {
+ TransactionHolder(final long id) {
transactionID = id;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-jdbc-store/src/test/java/org/apache/activemq/artemis/jdbc/file/JDBCSequentialFileFactoryTest.java
----------------------------------------------------------------------
diff --git a/artemis-jdbc-store/src/test/java/org/apache/activemq/artemis/jdbc/file/JDBCSequentialFileFactoryTest.java b/artemis-jdbc-store/src/test/java/org/apache/activemq/artemis/jdbc/file/JDBCSequentialFileFactoryTest.java
index 1a8fba4..5f7d7e6 100644
--- a/artemis-jdbc-store/src/test/java/org/apache/activemq/artemis/jdbc/file/JDBCSequentialFileFactoryTest.java
+++ b/artemis-jdbc-store/src/test/java/org/apache/activemq/artemis/jdbc/file/JDBCSequentialFileFactoryTest.java
@@ -169,7 +169,7 @@ public class JDBCSequentialFileFactoryTest {
private final CountDownLatch countDownLatch;
- public IOCallbackCountdown(int size) {
+ private IOCallbackCountdown(int size) {
this.countDownLatch = new CountDownLatch(size);
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSConsumer.java
----------------------------------------------------------------------
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSConsumer.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSConsumer.java
index f3ba6e2..c59812b 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSConsumer.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSConsumer.java
@@ -143,7 +143,7 @@ public class ActiveMQJMSConsumer implements JMSConsumer {
private final MessageListener wrapped;
- public MessageListenerWrapper(MessageListener wrapped) {
+ MessageListenerWrapper(MessageListener wrapped) {
this.wrapped = wrapped;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSProducer.java
----------------------------------------------------------------------
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSProducer.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSProducer.java
index 6e37a86..17d6c3c 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSProducer.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQJMSProducer.java
@@ -628,7 +628,7 @@ public final class ActiveMQJMSProducer implements JMSProducer {
private final CompletionListener wrapped;
- public CompletionListenerWrapper(CompletionListener wrapped) {
+ CompletionListenerWrapper(CompletionListener wrapped) {
this.wrapped = wrapped;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java
----------------------------------------------------------------------
diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java
index 112b535..5a0d5c3 100644
--- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java
+++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageProducer.java
@@ -533,9 +533,9 @@ public class ActiveMQMessageProducer implements MessageProducer, QueueSender, To
* @param jmsMessage
* @param producer
*/
- public CompletionListenerWrapper(CompletionListener listener,
- Message jmsMessage,
- ActiveMQMessageProducer producer) {
+ private CompletionListenerWrapper(CompletionListener listener,
+ Message jmsMessage,
+ ActiveMQMessageProducer producer) {
this.completionListener = listener;
this.jmsMessage = jmsMessage;
this.producer = producer;
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
index 46cc0d4..7987320 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
@@ -1900,7 +1900,7 @@ public final class JMSBridgeImpl implements JMSBridge {
BridgeFailoverListener failoverListener;
private final boolean isSource;
- public BridgeExceptionListener(boolean ha, BridgeFailoverListener failoverListener, boolean isSource) {
+ private BridgeExceptionListener(boolean ha, BridgeFailoverListener failoverListener, boolean isSource) {
this.ha = ha;
this.failoverListener = failoverListener;
this.isSource = isSource;
@@ -1992,7 +1992,7 @@ public final class JMSBridgeImpl implements JMSBridge {
private final boolean isSource;
volatile FailoverEventType lastEvent;
- public BridgeFailoverListener(boolean isSource) {
+ private BridgeFailoverListener(boolean isSource) {
this.isSource = isSource;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/management/JMSNotificationType.java
----------------------------------------------------------------------
diff --git a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/management/JMSNotificationType.java b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/management/JMSNotificationType.java
index 68ec9ed..5f71eff 100644
--- a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/management/JMSNotificationType.java
+++ b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/server/management/JMSNotificationType.java
@@ -31,7 +31,7 @@ public enum JMSNotificationType implements NotificationType {
private int type;
- private JMSNotificationType(int type) {
+ JMSNotificationType(int type) {
this.type = type;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFileFactory.java
----------------------------------------------------------------------
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFileFactory.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFileFactory.java
index 2a79e6e..f3f12a5 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFileFactory.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/aio/AIOSequentialFileFactory.java
@@ -359,7 +359,7 @@ public final class AIOSequentialFileFactory extends AbstractSequentialFileFactor
private class PollerThread extends Thread {
- public PollerThread() {
+ private PollerThread() {
super("Apache ActiveMQ Artemis libaio poller");
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalBase.java
----------------------------------------------------------------------
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalBase.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalBase.java
index 50632fa..e2ca84d 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalBase.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalBase.java
@@ -28,7 +28,7 @@ abstract class JournalBase implements Journal {
protected final int fileSize;
private final boolean supportsCallback;
- public JournalBase(boolean supportsCallback, int fileSize) {
+ JournalBase(boolean supportsCallback, int fileSize) {
if (fileSize < JournalImpl.MIN_FILE_SIZE) {
throw new IllegalArgumentException("File size cannot be less than " + JournalImpl.MIN_FILE_SIZE + " bytes");
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java
----------------------------------------------------------------------
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java
index 1acbcaa..40926e0 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalCompactor.java
@@ -444,7 +444,7 @@ public class JournalCompactor extends AbstractJournalUpdateTask implements Journ
JournalFile usedFile;
- public DeleteCompactCommand(final long id, final JournalFile usedFile) {
+ private DeleteCompactCommand(final long id, final JournalFile usedFile) {
this.id = id;
this.usedFile = usedFile;
}
@@ -479,7 +479,7 @@ public class JournalCompactor extends AbstractJournalUpdateTask implements Journ
private final int size;
- public UpdateCompactCommand(final long id, final JournalFile usedFile, final int size) {
+ private UpdateCompactCommand(final long id, final JournalFile usedFile, final int size) {
this.id = id;
this.usedFile = usedFile;
this.size = size;
@@ -501,7 +501,7 @@ public class JournalCompactor extends AbstractJournalUpdateTask implements Journ
*/
private final JournalFile commitFile;
- public CommitCompactCommand(final JournalTransaction liveTransaction, final JournalFile commitFile) {
+ private CommitCompactCommand(final JournalTransaction liveTransaction, final JournalFile commitFile) {
this.liveTransaction = liveTransaction;
this.commitFile = commitFile;
}
@@ -526,7 +526,7 @@ public class JournalCompactor extends AbstractJournalUpdateTask implements Journ
*/
private final JournalFile rollbackFile;
- public RollbackCompactCommand(final JournalTransaction liveTransaction, final JournalFile rollbackFile) {
+ private RollbackCompactCommand(final JournalTransaction liveTransaction, final JournalFile rollbackFile) {
this.liveTransaction = liveTransaction;
this.rollbackFile = rollbackFile;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
----------------------------------------------------------------------
diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
index e19e728..61d6800 100644
--- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
+++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
@@ -2578,7 +2578,7 @@ public class JournalImpl extends JournalBase implements TestableJournal, Journal
// Used on Load
private static final class TransactionHolder {
- public TransactionHolder(final long id) {
+ private TransactionHolder(final long id) {
transactionID = id;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-native/src/test/java/org/apache/activemq/artemis/jlibaio/test/LibaioTest.java
----------------------------------------------------------------------
diff --git a/artemis-native/src/test/java/org/apache/activemq/artemis/jlibaio/test/LibaioTest.java b/artemis-native/src/test/java/org/apache/activemq/artemis/jlibaio/test/LibaioTest.java
index 617553c..71f7516 100644
--- a/artemis-native/src/test/java/org/apache/activemq/artemis/jlibaio/test/LibaioTest.java
+++ b/artemis-native/src/test/java/org/apache/activemq/artemis/jlibaio/test/LibaioTest.java
@@ -721,7 +721,7 @@ public class LibaioTest {
String errorMessage;
int errno;
- public TestInfo() {
+ TestInfo() {
count.incrementAndGet();
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolManager.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolManager.java b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolManager.java
index e99272f..d2c0793 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolManager.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolManager.java
@@ -43,7 +43,7 @@ class MQTTProtocolManager implements ProtocolManager, NotificationListener {
private MQTTLogger log = MQTTLogger.LOGGER;
- public MQTTProtocolManager(ActiveMQServer server) {
+ MQTTProtocolManager(ActiveMQServer server) {
this.server = server;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java b/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java
index 170e875..a175805 100644
--- a/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java
+++ b/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java
@@ -23,7 +23,7 @@ public class CreditsSemaphore {
@SuppressWarnings("serial")
private static class Sync extends AbstractQueuedSynchronizer {
- public Sync(int initial) {
+ private Sync(int initial) {
setState(initial);
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java b/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java
index 87e00e0..beccc03 100644
--- a/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java
+++ b/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java
@@ -38,7 +38,7 @@ public class ReusableLatch {
@SuppressWarnings("serial")
private static class CountSync extends AbstractQueuedSynchronizer {
- public CountSync(int count) {
+ private CountSync(int count) {
setState(count);
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/context/AbstractConnectionContextTest.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/context/AbstractConnectionContextTest.java b/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/context/AbstractConnectionContextTest.java
index 1cf7bb2..bfa0bad 100644
--- a/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/context/AbstractConnectionContextTest.java
+++ b/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/context/AbstractConnectionContextTest.java
@@ -50,7 +50,7 @@ public class AbstractConnectionContextTest {
private class TestConnectionContext extends AbstractConnectionContext {
- public TestConnectionContext(AMQPConnectionCallback connectionCallback) {
+ private TestConnectionContext(AMQPConnectionCallback connectionCallback) {
super(connectionCallback, Executors.newSingleThreadExecutor(ActiveMQThreadFactory.defaultThreadFactory()), null);
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java b/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java
index 7cb7861..8729cb4 100644
--- a/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java
+++ b/artemis-protocols/artemis-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java
@@ -120,7 +120,7 @@ public class MinimalServer {
AMQPServerConnectionContext connection;
- public ProtocolDecoder() {
+ ProtocolDecoder() {
}
@Override
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/ActiveMQStompException.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/ActiveMQStompException.java b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/ActiveMQStompException.java
index 9fb0786..7966037 100644
--- a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/ActiveMQStompException.java
+++ b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/ActiveMQStompException.java
@@ -97,7 +97,7 @@ public class ActiveMQStompException extends Exception {
public final String key;
public final String val;
- public Header(String key, String val) {
+ private Header(String key, String val) {
this.key = key;
this.val = val;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompProtocolManager.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompProtocolManager.java b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompProtocolManager.java
index b3e52af..4b6f5ba 100644
--- a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompProtocolManager.java
+++ b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompProtocolManager.java
@@ -75,10 +75,10 @@ class StompProtocolManager implements ProtocolManager<StompFrameInterceptor> {
// Constructors --------------------------------------------------
- public StompProtocolManager(final StompProtocolManagerFactory factory,
- final ActiveMQServer server,
- final List<StompFrameInterceptor> incomingInterceptors,
- final List<StompFrameInterceptor> outgoingInterceptors) {
+ StompProtocolManager(final StompProtocolManagerFactory factory,
+ final ActiveMQServer server,
+ final List<StompFrameInterceptor> incomingInterceptors,
+ final List<StompFrameInterceptor> outgoingInterceptors) {
this.factory = factory;
this.server = server;
this.executor = server.getExecutorFactory().getExecutor();
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompVersions.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompVersions.java b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompVersions.java
index adf360c..a41726f 100644
--- a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompVersions.java
+++ b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompVersions.java
@@ -26,7 +26,7 @@ public enum StompVersions {
private String version;
- private StompVersions(String ver) {
+ StompVersions(String ver) {
this.version = ver;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/v11/StompFrameHandlerV11.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/v11/StompFrameHandlerV11.java b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/v11/StompFrameHandlerV11.java
index 6874173..91d0119 100644
--- a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/v11/StompFrameHandlerV11.java
+++ b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/v11/StompFrameHandlerV11.java
@@ -251,7 +251,7 @@ public class StompFrameHandlerV11 extends VersionedStompFrameHandler implements
AtomicLong lastAccepted = new AtomicLong(0);
StompFrame pingFrame;
- public HeartBeater(long clientPing, long clientAcceptPing) {
+ private HeartBeater(long clientPing, long clientAcceptPing) {
if (clientPing != 0) {
serverAcceptPing = clientPing > MIN_CLIENT_PING ? clientPing : MIN_CLIENT_PING;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/AutoAckTopicTest.java
----------------------------------------------------------------------
diff --git a/artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/AutoAckTopicTest.java b/artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/AutoAckTopicTest.java
index d8fe822..baf464f 100644
--- a/artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/AutoAckTopicTest.java
+++ b/artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/AutoAckTopicTest.java
@@ -150,7 +150,7 @@ public class AutoAckTopicTest extends MessageTestBase {
private boolean isFinished = false;
private boolean failed = false;
- public NewPullSubscriber(String url) {
+ private NewPullSubscriber(String url) {
this.url = url;
}
@@ -187,7 +187,7 @@ public class AutoAckTopicTest extends MessageTestBase {
private boolean isFinished = false;
private boolean failed = false;
- public AcceptWaitListener(String url) {
+ private AcceptWaitListener(String url) {
this.url = url;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ComparisonExpression.java
----------------------------------------------------------------------
diff --git a/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ComparisonExpression.java b/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ComparisonExpression.java
index 05cbbe5..bc3b333 100755
--- a/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ComparisonExpression.java
+++ b/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ComparisonExpression.java
@@ -79,7 +79,7 @@ public abstract class ComparisonExpression extends BinaryExpression implements B
/**
*/
- public LikeExpression(Expression right, String like, int escape) {
+ LikeExpression(Expression right, String like, int escape) {
super(right);
StringBuffer regexp = new StringBuffer(like.length() * 2);
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ConstantExpression.java
----------------------------------------------------------------------
diff --git a/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ConstantExpression.java b/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ConstantExpression.java
index 010b736..8d88bbd 100755
--- a/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ConstantExpression.java
+++ b/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/ConstantExpression.java
@@ -27,7 +27,7 @@ public class ConstantExpression implements Expression {
static class BooleanConstantExpression extends ConstantExpression implements BooleanExpression {
- public BooleanConstantExpression(Object value) {
+ BooleanConstantExpression(Object value) {
super(value);
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/UnaryExpression.java
----------------------------------------------------------------------
diff --git a/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/UnaryExpression.java b/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/UnaryExpression.java
index fb9832a..3121ac2 100755
--- a/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/UnaryExpression.java
+++ b/artemis-selector/src/main/java/org/apache/activemq/artemis/selector/filter/UnaryExpression.java
@@ -125,7 +125,7 @@ public abstract class UnaryExpression implements Expression {
abstract static class BooleanUnaryExpression extends UnaryExpression implements BooleanExpression {
- public BooleanUnaryExpression(Expression left) {
+ BooleanUnaryExpression(Expression left) {
super(left);
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server-osgi/src/test/java/org/apache/activemq/artemis/osgi/ProtocolTrackerTest.java
----------------------------------------------------------------------
diff --git a/artemis-server-osgi/src/test/java/org/apache/activemq/artemis/osgi/ProtocolTrackerTest.java b/artemis-server-osgi/src/test/java/org/apache/activemq/artemis/osgi/ProtocolTrackerTest.java
index 46435cd..18e1f76 100644
--- a/artemis-server-osgi/src/test/java/org/apache/activemq/artemis/osgi/ProtocolTrackerTest.java
+++ b/artemis-server-osgi/src/test/java/org/apache/activemq/artemis/osgi/ProtocolTrackerTest.java
@@ -64,7 +64,7 @@ public class ProtocolTrackerTest {
ServiceReference<ProtocolManagerFactory<Interceptor>> ref;
ProtocolManagerFactory factory;
- public RefFact(IMocksControl c, BundleContext context, String[] protocols) {
+ RefFact(IMocksControl c, BundleContext context, String[] protocols) {
ref = c.createMock(ServiceReference.class);
factory = c.createMock(ProtocolManagerFactory.class);
expect(factory.getProtocols()).andReturn(protocols).atLeastOnce();
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/HAPolicyConfiguration.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/HAPolicyConfiguration.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/HAPolicyConfiguration.java
index c1510d1..3ffd56a 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/HAPolicyConfiguration.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/HAPolicyConfiguration.java
@@ -20,7 +20,7 @@ import java.io.Serializable;
public interface HAPolicyConfiguration extends Serializable {
- public enum TYPE {
+ enum TYPE {
LIVE_ONLY,
REPLICATED,
REPLICA,
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/StoreConfiguration.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/StoreConfiguration.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/StoreConfiguration.java
index d25cdd9..553ece5 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/StoreConfiguration.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/config/StoreConfiguration.java
@@ -20,7 +20,7 @@ import java.io.Serializable;
public interface StoreConfiguration extends Serializable {
- public enum StoreType {
+ enum StoreType {
FILE,
DATABASE
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java
index dd9f7dd..9cacff0 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java
@@ -172,7 +172,7 @@ public class FilterImpl implements Filter {
private final ServerMessage message;
- public FilterableServerMessage(ServerMessage message) {
+ private FilterableServerMessage(ServerMessage message) {
this.message = message;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCacheImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCacheImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCacheImpl.java
index 8d9b872..8fd59d7 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCacheImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageCacheImpl.java
@@ -37,7 +37,7 @@ class PageCacheImpl implements PageCache {
// Constructors --------------------------------------------------
- public PageCacheImpl(final Page page) {
+ PageCacheImpl(final Page page) {
this.page = page;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
index a28288a..54dc7e9 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionCounterImpl.java
@@ -351,7 +351,7 @@ public class PageSubscriptionCounterImpl implements PageSubscriptionCounter {
private static class ItemOper {
- public ItemOper(PageSubscriptionCounterImpl counter, long id, int add) {
+ private ItemOper(PageSubscriptionCounterImpl counter, long id, int add) {
this.counter = counter;
this.id = id;
this.amount = add;
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
index 9eac4ce..c89161a 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java
@@ -942,7 +942,7 @@ final class PageSubscriptionImpl implements PageSubscription {
}
}
- public PageCursorInfo(final long pageId, final int numberOfMessages, final PageCache cache) {
+ private PageCursorInfo(final long pageId, final int numberOfMessages, final PageCache cache) {
logger.tracef("Created PageCursorInfo for pageNr=%d, numberOfMessages=%d, cache=%s", pageId, numberOfMessages, cache);
this.pageId = pageId;
this.numberOfMessages = numberOfMessages;
@@ -1130,7 +1130,7 @@ final class PageSubscriptionImpl implements PageSubscription {
*/
private volatile PagedReference cachedNext;
- public CursorIterator() {
+ private CursorIterator() {
}
@Override
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java
index 1502855..1dde309 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PageTransactionInfoImpl.java
@@ -303,7 +303,7 @@ public final class PageTransactionInfoImpl implements PageTransactionInfo {
final PagePosition pagePosition;
final PageIterator iterator;
- public LateDelivery(PageSubscription subscription, PagePosition pagePosition, PageIterator iterator) {
+ private LateDelivery(PageSubscription subscription, PagePosition pagePosition, PageIterator iterator) {
this.subscription = subscription;
this.pagePosition = pagePosition;
this.iterator = iterator;
@@ -332,7 +332,7 @@ public final class PageTransactionInfoImpl implements PageTransactionInfo {
private final PagingManager pagingManager;
- public UpdatePageTXOperation(final StorageManager storageManager, final PagingManager pagingManager) {
+ private UpdatePageTXOperation(final StorageManager storageManager, final PagingManager pagingManager) {
this.storageManager = storageManager;
this.pagingManager = pagingManager;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreImpl.java
index 8fec06c..f57f1b8 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreImpl.java
@@ -937,9 +937,9 @@ public class PagingStoreImpl implements PagingStore {
this.usedStores.add(store);
}
- public FinishPageMessageOperation(final PageTransactionInfo pageTransaction,
- final StorageManager storageManager,
- final PagingManager pagingManager) {
+ private FinishPageMessageOperation(final PageTransactionInfo pageTransaction,
+ final StorageManager storageManager,
+ final PagingManager pagingManager) {
this.pageTransaction = pageTransaction;
this.storageManager = storageManager;
this.pagingManager = pagingManager;
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/StorageManager.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/StorageManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/StorageManager.java
index f92d0d8..d08b84d 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/StorageManager.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/StorageManager.java
@@ -223,7 +223,7 @@ public interface StorageManager extends IDGenerator, ActiveMQComponent {
DURABLE(".msg"), TEMPORARY(".tmp"), SYNC(".sync");
final String extension;
- private LargeMessageExtension(String extension) {
+ LargeMessageExtension(String extension) {
this.extension = extension;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java
index 365954c..5b325b6 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java
@@ -24,11 +24,11 @@ import org.apache.activemq.artemis.core.server.impl.ServerMessageImpl;
class NullStorageLargeServerMessage extends ServerMessageImpl implements LargeServerMessage {
- public NullStorageLargeServerMessage() {
+ NullStorageLargeServerMessage() {
super();
}
- public NullStorageLargeServerMessage(NullStorageLargeServerMessage other) {
+ NullStorageLargeServerMessage(NullStorageLargeServerMessage other) {
super(other);
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/ProtocolHandler.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/ProtocolHandler.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/ProtocolHandler.java
index fed7a75..f4fef21 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/ProtocolHandler.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/ProtocolHandler.java
@@ -94,7 +94,7 @@ public class ProtocolHandler {
private final boolean httpEnabled;
- public ProtocolDecoder(boolean http, boolean httpEnabled) {
+ ProtocolDecoder(boolean http, boolean httpEnabled) {
this.http = http;
this.httpEnabled = httpEnabled;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/CoreProtocolManager.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/CoreProtocolManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/CoreProtocolManager.java
index 32edb93..410b0c0 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/CoreProtocolManager.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/CoreProtocolManager.java
@@ -204,11 +204,11 @@ public class CoreProtocolManager implements ProtocolManager<Interceptor> {
private final Acceptor acceptorUsed;
private final CoreRemotingConnection rc;
- public LocalChannelHandler(final Configuration config,
- final ConnectionEntry entry,
- final Channel channel0,
- final Acceptor acceptorUsed,
- final CoreRemotingConnection rc) {
+ private LocalChannelHandler(final Configuration config,
+ final ConnectionEntry entry,
+ final Channel channel0,
+ final Acceptor acceptorUsed,
+ final CoreRemotingConnection rc) {
this.config = config;
this.entry = entry;
this.channel0 = channel0;
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/BackupReplicationStartFailedMessage.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/BackupReplicationStartFailedMessage.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/BackupReplicationStartFailedMessage.java
index 91830f8..0564220 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/BackupReplicationStartFailedMessage.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/BackupReplicationStartFailedMessage.java
@@ -36,7 +36,7 @@ public final class BackupReplicationStartFailedMessage extends PacketImpl {
final int code;
- private BackupRegistrationProblem(int code) {
+ BackupRegistrationProblem(int code) {
this.code = code;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationLiveIsStoppingMessage.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationLiveIsStoppingMessage.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationLiveIsStoppingMessage.java
index 28e03cf..339cfa8 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationLiveIsStoppingMessage.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationLiveIsStoppingMessage.java
@@ -39,7 +39,7 @@ public final class ReplicationLiveIsStoppingMessage extends PacketImpl {
FAIL_OVER(1);
private final int code;
- private LiveStopping(int code) {
+ LiveStopping(int code) {
this.code = code;
}
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationStartSyncMessage.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationStartSyncMessage.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationStartSyncMessage.java
index d31db8b..157e02b 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationStartSyncMessage.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationStartSyncMessage.java
@@ -46,7 +46,7 @@ public class ReplicationStartSyncMessage extends PacketImpl {
private byte code;
- private SyncDataType(byte code) {
+ SyncDataType(byte code) {
this.code = code;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationSyncFileMessage.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationSyncFileMessage.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationSyncFileMessage.java
index ed5901f..6999741 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationSyncFileMessage.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/ReplicationSyncFileMessage.java
@@ -53,7 +53,7 @@ public final class ReplicationSyncFileMessage extends PacketImpl {
private byte code;
private static final Set<FileType> ALL_OF = EnumSet.allOf(FileType.class);
- private FileType(int code) {
+ FileType(int code) {
this.code = (byte) code;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/HttpAcceptorHandler.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/HttpAcceptorHandler.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/HttpAcceptorHandler.java
index 7be3bac..f92a303 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/HttpAcceptorHandler.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/HttpAcceptorHandler.java
@@ -123,13 +123,13 @@ public class HttpAcceptorHandler extends ChannelDuplexHandler {
private final ChannelPromise promise;
- public ResponseRunner(final ByteBuf buffer, ChannelPromise promise) {
+ ResponseRunner(final ByteBuf buffer, ChannelPromise promise) {
this.buffer = buffer;
bogusResponse = false;
this.promise = promise;
}
- public ResponseRunner() {
+ ResponseRunner() {
bogusResponse = true;
buffer = Unpooled.buffer(0);
promise = channel.newPromise();
@@ -211,7 +211,7 @@ public class HttpAcceptorHandler extends ChannelDuplexHandler {
final long timeReceived;
- public ResponseHolder(final long timeReceived, final FullHttpResponse response) {
+ private ResponseHolder(final long timeReceived, final FullHttpResponse response) {
this.timeReceived = timeReceived;
this.response = response;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/BackupManager.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/BackupManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/BackupManager.java
index d8e077c..105bea3 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/BackupManager.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/BackupManager.java
@@ -186,10 +186,10 @@ public class BackupManager implements ActiveMQComponent {
private boolean announcingBackup;
private boolean backupAnnounced = false;
- public BackupConnector(String name,
- TransportConfiguration connector,
- long retryInterval,
- ClusterManager clusterManager) {
+ private BackupConnector(String name,
+ TransportConfiguration connector,
+ long retryInterval,
+ ClusterManager clusterManager) {
this.name = name;
this.connector = connector;
this.retryInterval = retryInterval;
@@ -328,11 +328,11 @@ public class BackupManager implements ActiveMQComponent {
private final TransportConfiguration[] tcConfigs;
- public StaticBackupConnector(TransportConfiguration[] tcConfigs,
- String name,
- TransportConfiguration connector,
- long retryInterval,
- ClusterManager clusterManager) {
+ private StaticBackupConnector(TransportConfiguration[] tcConfigs,
+ String name,
+ TransportConfiguration connector,
+ long retryInterval,
+ ClusterManager clusterManager) {
super(name, connector, retryInterval, clusterManager);
this.tcConfigs = tcConfigs;
}
@@ -365,11 +365,11 @@ public class BackupManager implements ActiveMQComponent {
private final DiscoveryGroupConfiguration discoveryGroupConfiguration;
- public DiscoveryBackupConnector(DiscoveryGroupConfiguration discoveryGroupConfiguration,
- String name,
- TransportConfiguration connector,
- long retryInterval,
- ClusterManager clusterManager) {
+ private DiscoveryBackupConnector(DiscoveryGroupConfiguration discoveryGroupConfiguration,
+ String name,
+ TransportConfiguration connector,
+ long retryInterval,
+ ClusterManager clusterManager) {
super(name, connector, retryInterval, clusterManager);
this.discoveryGroupConfiguration = discoveryGroupConfiguration;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterController.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterController.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterController.java
index f8579be..bdb17d6 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterController.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterController.java
@@ -306,10 +306,10 @@ public class ClusterController implements ActiveMQComponent {
private final ChannelHandler channelHandler;
boolean authorized = false;
- public ClusterControllerChannelHandler(Channel clusterChannel,
- Acceptor acceptorUsed,
- CoreRemotingConnection remotingConnection,
- ChannelHandler channelHandler) {
+ private ClusterControllerChannelHandler(Channel clusterChannel,
+ Acceptor acceptorUsed,
+ CoreRemotingConnection remotingConnection,
+ ChannelHandler channelHandler) {
this.clusterChannel = clusterChannel;
this.acceptorUsed = acceptorUsed;
this.remotingConnection = remotingConnection;
@@ -396,7 +396,7 @@ public class ClusterController implements ActiveMQComponent {
private ServerLocatorInternal serverLocator;
- public ConnectRunnable(ServerLocatorInternal serverLocator) {
+ private ConnectRunnable(ServerLocatorInternal serverLocator) {
this.serverLocator = serverLocator;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
index 44e608c..a978be8 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
@@ -1055,7 +1055,7 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
private final Executor executor;
- public FutureConnectRunnable(Executor exe, BridgeImpl bridge) {
+ private FutureConnectRunnable(Executor exe, BridgeImpl bridge) {
executor = exe;
this.bridge = bridge;
}
@@ -1071,7 +1071,7 @@ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowled
private final BridgeImpl bridge;
- public ConnectRunnable(BridgeImpl bridge2) {
+ private ConnectRunnable(BridgeImpl bridge2) {
bridge = bridge2;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionImpl.java
index 2b09c4c..82b1e4f 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionImpl.java
@@ -835,12 +835,12 @@ public final class ClusterConnectionImpl implements ClusterConnection, AfterConn
private volatile boolean reset = false;
- public MessageFlowRecordImpl(final ServerLocatorInternal targetLocator,
- final long eventUID,
- final String targetNodeID,
- final TransportConfiguration connector,
- final SimpleString queueName,
- final Queue queue) {
+ private MessageFlowRecordImpl(final ServerLocatorInternal targetLocator,
+ final long eventUID,
+ final String targetNodeID,
+ final TransportConfiguration connector,
+ final SimpleString queueName,
+ final Queue queue) {
this.targetLocator = targetLocator;
this.queue = queue;
this.targetNodeID = targetNodeID;
@@ -1418,7 +1418,7 @@ public final class ClusterConnectionImpl implements ClusterConnection, AfterConn
private final TransportConfiguration[] tcConfigs;
- public StaticClusterConnector(TransportConfiguration[] tcConfigs) {
+ private StaticClusterConnector(TransportConfiguration[] tcConfigs) {
this.tcConfigs = tcConfigs;
}
@@ -1446,7 +1446,7 @@ public final class ClusterConnectionImpl implements ClusterConnection, AfterConn
private final DiscoveryGroupConfiguration dg;
- public DiscoveryClusterConnector(DiscoveryGroupConfiguration dg) {
+ private DiscoveryClusterConnector(DiscoveryGroupConfiguration dg) {
this.dg = dg;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3923ae45/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java
index d510b41..76a5d5e 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java
@@ -257,7 +257,7 @@ public final class QuorumManager implements ClusterTopologyListener, ActiveMQCom
private final List<VoteRunnable> runnables;
private int size;
- public VoteRunnableHolder(QuorumVote quorumVote, List<VoteRunnable> runnables, int size) {
+ private VoteRunnableHolder(QuorumVote quorumVote, List<VoteRunnable> runnables, int size) {
this.quorumVote = quorumVote;
this.runnables = runnables;
@@ -282,7 +282,7 @@ public final class QuorumManager implements ClusterTopologyListener, ActiveMQCom
private final QuorumVote quorumVote;
private ClusterControl clusterControl;
- public VoteRunnable(TransportConfiguration serverTC, QuorumVote quorumVote) {
+ private VoteRunnable(TransportConfiguration serverTC, QuorumVote quorumVote) {
this.serverTC = serverTC;
this.quorumVote = quorumVote;
}