remove useless JavaDoc
Project: http://git-wip-us.apache.org/repos/asf/activemq-6/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-6/commit/fa549a00 Tree: http://git-wip-us.apache.org/repos/asf/activemq-6/tree/fa549a00 Diff: http://git-wip-us.apache.org/repos/asf/activemq-6/diff/fa549a00 Branch: refs/heads/master Commit: fa549a00e737cde0df5fc18b9cb2283561ede017 Parents: 88ed03e Author: jbertram <[email protected]> Authored: Tue Mar 10 14:41:40 2015 -0500 Committer: jbertram <[email protected]> Committed: Tue Mar 10 15:23:07 2015 -0500 ---------------------------------------------------------------------- .../apache/activemq/core/buffers/impl/ChannelBufferWrapper.java | 3 --- .../java/org/apache/activemq/core/server/ActiveMQComponent.java | 3 --- .../java/org/apache/activemq/utils/ActiveMQThreadFactory.java | 3 --- .../src/main/java/org/apache/activemq/utils/DataConstants.java | 3 --- .../main/java/org/apache/activemq/utils/PasswordMaskingUtil.java | 3 --- .../apache/activemq/api/core/management/AddressSettingsInfo.java | 3 --- .../apache/activemq/core/client/impl/ClientConsumerInternal.java | 3 --- .../activemq/core/client/impl/ClientLargeMessageInternal.java | 3 --- .../apache/activemq/core/client/impl/ClientMessageInternal.java | 3 --- .../activemq/core/client/impl/ClientProducerCreditManager.java | 3 --- .../core/client/impl/ClientProducerCreditManagerImpl.java | 3 --- .../apache/activemq/core/client/impl/ClientProducerCredits.java | 3 --- .../activemq/core/client/impl/ClientProducerCreditsImpl.java | 3 --- .../activemq/core/client/impl/ClientSessionFactoryInternal.java | 3 --- .../apache/activemq/core/client/impl/ClientSessionInternal.java | 3 --- .../apache/activemq/core/client/impl/LargeMessageController.java | 3 --- .../apache/activemq/core/client/impl/ServerLocatorInternal.java | 3 --- .../java/org/apache/activemq/core/cluster/DiscoveryEntry.java | 3 --- .../org/apache/activemq/core/exception/ActiveMQXAException.java | 3 --- .../org/apache/activemq/core/message/impl/MessageInternal.java | 3 --- .../org/apache/activemq/core/protocol/core/impl/ChannelImpl.java | 3 --- .../apache/activemq/core/protocol/core/impl/PacketDecoder.java | 3 --- .../core/protocol/core/impl/wireformat/MessagePacket.java | 3 --- .../protocol/core/impl/wireformat/PacketsConfirmedMessage.java | 3 --- .../protocol/core/impl/wireformat/ReattachSessionMessage.java | 3 --- .../core/impl/wireformat/ReattachSessionResponseMessage.java | 3 --- .../core/protocol/core/impl/wireformat/RollbackMessage.java | 3 --- .../protocol/core/impl/wireformat/SessionBindingQueryMessage.java | 3 --- .../core/protocol/core/impl/wireformat/SessionCommitMessage.java | 3 --- .../protocol/core/impl/wireformat/SessionContinuationMessage.java | 3 --- .../protocol/core/impl/wireformat/SessionQueueQueryMessage.java | 3 --- .../core/impl/wireformat/SessionQueueQueryResponseMessage.java | 3 --- .../core/impl/wireformat/SessionReceiveContinuationMessage.java | 3 --- .../protocol/core/impl/wireformat/SessionReceiveLargeMessage.java | 3 --- .../core/impl/wireformat/SessionUniqueAddMetaDataMessage.java | 3 --- .../apache/activemq/core/remoting/impl/netty/NettyConnector.java | 3 --- .../activemq/core/remoting/impl/netty/NettyConnectorFactory.java | 3 --- .../activemq/core/remoting/impl/netty/TransportConstants.java | 3 --- .../java/org/apache/activemq/core/server/QueueQueryResult.java | 3 --- .../activemq/core/server/management/NotificationListener.java | 3 --- .../activemq/core/server/management/NotificationService.java | 3 --- .../activemq/core/settings/impl/AddressFullMessagePolicy.java | 3 --- .../src/main/java/org/apache/activemq/core/version/Version.java | 3 --- .../java/org/apache/activemq/core/version/impl/VersionImpl.java | 3 --- .../org/apache/activemq/spi/core/protocol/ConnectionEntry.java | 3 --- .../java/org/apache/activemq/spi/core/remoting/BufferDecoder.java | 3 --- .../java/org/apache/activemq/spi/core/remoting/ReadyListener.java | 3 --- .../main/java/org/apache/activemq/utils/ConfigurationHelper.java | 3 --- .../src/main/java/org/apache/activemq/utils/ExecutorFactory.java | 3 --- .../src/main/java/org/apache/activemq/utils/FutureLatch.java | 3 --- .../src/main/java/org/apache/activemq/utils/LinkedList.java | 3 --- .../src/main/java/org/apache/activemq/utils/MemorySize.java | 3 --- .../src/main/java/org/apache/activemq/utils/Random.java | 3 --- .../main/java/org/apache/activemq/utils/SimpleIDGenerator.java | 3 --- .../main/java/org/apache/activemq/utils/SizeFormatterUtil.java | 3 --- .../src/main/java/org/apache/activemq/utils/SoftValueHashMap.java | 3 --- .../java/org/apache/activemq/utils/TokenBucketLimiterImpl.java | 3 --- .../test/java/org/apache/activemq/util/CompressionUtilTest.java | 3 --- .../org/apache/activemq/util/TimeAndCounterIDGeneratorTest.java | 3 --- .../org/apache/activemq/util/TypedPropertiesConversionTest.java | 3 --- .../src/main/java/org/apache/activemq/api/jms/JMSFactoryType.java | 3 --- .../org/apache/activemq/api/jms/management/JMSConnectionInfo.java | 3 --- .../org/apache/activemq/api/jms/management/JMSSessionInfo.java | 3 --- .../org/apache/activemq/jms/client/ActiveMQTemporaryTopic.java | 3 --- .../java/org/apache/activemq/jms/client/ActiveMQXASession.java | 3 --- .../java/org/apache/activemq/jms/client/JMSExceptionHelper.java | 3 --- .../org/apache/activemq/jms/client/JMSMessageListenerWrapper.java | 3 --- .../org/apache/activemq/jms/bridge/ConnectionFactoryFactory.java | 3 --- .../java/org/apache/activemq/jms/bridge/JMSBridgeControl.java | 3 --- .../org/apache/activemq/jms/bridge/impl/JMSBridgeControlImpl.java | 3 --- .../java/org/apache/activemq/jms/bridge/impl/JMSBridgeImpl.java | 3 --- .../activemq/jms/bridge/impl/JNDIConnectionFactoryFactory.java | 3 --- .../org/apache/activemq/jms/persistence/JMSStorageManager.java | 3 --- .../apache/activemq/jms/persistence/config/PersistedBindings.java | 3 --- .../jms/persistence/config/PersistedConnectionFactory.java | 3 --- .../activemq/jms/persistence/config/PersistedDestination.java | 3 --- .../org/apache/activemq/jms/persistence/config/PersistedType.java | 3 --- .../persistence/impl/journal/JMSJournalStorageManagerImpl.java | 3 --- .../jms/persistence/impl/nullpm/NullJMSStorageManagerImpl.java | 3 --- .../org/apache/activemq/jms/server/JMSServerConfigParser.java | 3 --- .../org/apache/activemq/jms/server/config/JMSConfiguration.java | 3 --- .../apache/activemq/jms/server/config/JMSQueueConfiguration.java | 3 --- .../org/apache/activemq/jms/server/config/TopicConfiguration.java | 3 --- .../activemq/jms/server/config/impl/JMSConfigurationImpl.java | 3 --- .../jms/server/config/impl/JMSQueueConfigurationImpl.java | 3 --- .../activemq/jms/server/config/impl/TopicConfigurationImpl.java | 3 --- .../server/config/impl/TransportConfigurationEncodingSupport.java | 3 --- .../org/apache/activemq/jms/transaction/JMSTransactionDetail.java | 3 --- .../org/apache/activemq/core/asyncio/IOExceptionListener.java | 3 --- .../org/apache/activemq/core/asyncio/impl/ActiveMQFileLock.java | 3 --- .../main/java/org/apache/activemq/core/journal/IOCompletion.java | 3 --- .../org/apache/activemq/core/journal/IOCriticalErrorListener.java | 3 --- .../org/apache/activemq/core/journal/PreparedTransactionInfo.java | 3 --- .../main/java/org/apache/activemq/core/journal/RecordInfo.java | 3 --- .../java/org/apache/activemq/core/journal/SequentialFile.java | 3 --- .../java/org/apache/activemq/core/journal/TestableJournal.java | 3 --- .../org/apache/activemq/core/journal/impl/AIOSequentialFile.java | 3 --- .../activemq/core/journal/impl/AIOSequentialFileFactory.java | 3 --- .../apache/activemq/core/journal/impl/AbstractSequentialFile.java | 3 --- .../java/org/apache/activemq/core/journal/impl/DummyCallback.java | 3 --- .../org/apache/activemq/core/journal/impl/JournalCompactor.java | 3 --- .../java/org/apache/activemq/core/journal/impl/JournalFile.java | 3 --- .../org/apache/activemq/core/journal/impl/JournalFileImpl.java | 3 --- .../apache/activemq/core/journal/impl/JournalReaderCallback.java | 3 --- .../activemq/core/journal/impl/JournalReaderCallbackAbstract.java | 3 --- .../org/apache/activemq/core/journal/impl/JournalTransaction.java | 3 --- .../org/apache/activemq/core/journal/impl/NIOSequentialFile.java | 3 --- .../activemq/core/journal/impl/NIOSequentialFileFactory.java | 3 --- .../apache/activemq/core/journal/impl/SimpleWaitIOCallback.java | 3 --- .../java/org/apache/activemq/core/journal/impl/TimedBuffer.java | 3 --- .../apache/activemq/core/journal/impl/TimedBufferObserver.java | 3 --- .../apache/activemq/core/journal/impl/TransactionCallback.java | 3 --- .../activemq/core/journal/impl/dataformat/ByteArrayEncoding.java | 3 --- .../activemq/core/journal/impl/dataformat/JournalAddRecord.java | 3 --- .../activemq/core/journal/impl/dataformat/JournalAddRecordTX.java | 3 --- .../core/journal/impl/dataformat/JournalDeleteRecord.java | 3 --- .../core/journal/impl/dataformat/JournalDeleteRecordTX.java | 3 --- .../core/journal/impl/dataformat/JournalInternalRecord.java | 3 --- .../core/journal/impl/dataformat/JournalRollbackRecordTX.java | 3 --- .../core/protocol/openwire/OpenWireProtocolManagerFactory.java | 3 --- .../proton/plug/test/minimalserver/SimpleServerThreadFactory.java | 3 --- .../org/apache/activemq/core/protocol/stomp/StompConnection.java | 3 --- .../org/apache/activemq/core/protocol/stomp/StompDecoder.java | 3 --- .../activemq/core/protocol/stomp/StompProtocolManagerFactory.java | 3 --- .../org/apache/activemq/core/protocol/stomp/StompSession.java | 3 --- .../apache/activemq/core/protocol/stomp/StompSubscription.java | 3 --- .../java/org/apache/activemq/core/protocol/stomp/StompUtils.java | 3 --- .../java/org/apache/activemq/core/config/BridgeConfiguration.java | 3 --- .../activemq/core/config/ClusterConnectionConfiguration.java | 3 --- .../activemq/core/config/ConnectorServiceConfiguration.java | 3 --- .../org/apache/activemq/core/config/CoreQueueConfiguration.java | 3 --- .../java/org/apache/activemq/core/config/DivertConfiguration.java | 3 --- .../src/main/java/org/apache/activemq/core/filter/Filter.java | 3 --- .../org/apache/activemq/core/management/impl/AbstractControl.java | 3 --- .../apache/activemq/core/management/impl/AcceptorControlImpl.java | 3 --- .../apache/activemq/core/management/impl/BridgeControlImpl.java | 3 --- .../activemq/core/management/impl/BroadcastGroupControlImpl.java | 3 --- .../core/management/impl/ClusterConnectionControlImpl.java | 3 --- .../apache/activemq/core/management/impl/DivertControlImpl.java | 3 --- .../org/apache/activemq/core/paging/cursor/LivePageCache.java | 3 --- .../java/org/apache/activemq/core/paging/cursor/PageCache.java | 3 --- .../java/org/apache/activemq/core/paging/cursor/PagePosition.java | 3 --- .../org/apache/activemq/core/paging/cursor/PageSubscription.java | 3 --- .../activemq/core/paging/cursor/PageSubscriptionCounter.java | 3 --- .../org/apache/activemq/core/paging/cursor/PagedReference.java | 3 --- .../apache/activemq/core/paging/cursor/PagedReferenceImpl.java | 3 --- .../apache/activemq/core/paging/cursor/impl/PagePositionImpl.java | 3 --- .../activemq/core/paging/cursor/impl/PageSubscriptionImpl.java | 3 --- .../org/apache/activemq/core/persistence/QueueBindingInfo.java | 3 --- .../activemq/core/persistence/config/PersistedAddressSetting.java | 3 --- .../apache/activemq/core/persistence/config/PersistedRoles.java | 3 --- .../core/persistence/impl/journal/LargeServerMessageImpl.java | 3 --- .../persistence/impl/nullpm/NullStorageLargeServerMessage.java | 3 --- .../activemq/core/persistence/impl/nullpm/NullStorageManager.java | 3 --- .../main/java/org/apache/activemq/core/postoffice/Binding.java | 3 --- .../java/org/apache/activemq/core/postoffice/BindingType.java | 3 --- .../main/java/org/apache/activemq/core/postoffice/Bindings.java | 3 --- .../org/apache/activemq/core/postoffice/DuplicateIDCache.java | 3 --- .../java/org/apache/activemq/core/postoffice/QueueBinding.java | 3 --- .../main/java/org/apache/activemq/core/postoffice/QueueInfo.java | 3 --- .../org/apache/activemq/core/postoffice/impl/BindingsImpl.java | 3 --- .../apache/activemq/core/postoffice/impl/LocalQueueBinding.java | 3 --- .../org/apache/activemq/core/postoffice/impl/PostOfficeImpl.java | 3 --- .../activemq/core/protocol/core/ServerSessionPacketHandler.java | 3 --- .../activemq/core/protocol/core/impl/CoreProtocolManager.java | 3 --- .../core/protocol/core/impl/CoreProtocolManagerFactory.java | 3 --- .../activemq/core/protocol/core/impl/CoreSessionCallback.java | 3 --- .../core/protocol/core/impl/wireformat/ReplicationAddMessage.java | 3 --- .../protocol/core/impl/wireformat/ReplicationAddTXMessage.java | 3 --- .../protocol/core/impl/wireformat/ReplicationCommitMessage.java | 3 --- .../protocol/core/impl/wireformat/ReplicationDeleteMessage.java | 3 --- .../protocol/core/impl/wireformat/ReplicationDeleteTXMessage.java | 3 --- .../core/impl/wireformat/ReplicationLargeMessageBeginMessage.java | 3 --- .../core/impl/wireformat/ReplicationLargeMessageEndMessage.java | 3 --- .../core/impl/wireformat/ReplicationLargeMessageWriteMessage.java | 3 --- .../core/impl/wireformat/ReplicationPageEventMessage.java | 3 --- .../core/impl/wireformat/ReplicationPageWriteMessage.java | 3 --- .../org/apache/activemq/core/remoting/impl/invm/InVMAcceptor.java | 3 --- .../activemq/core/remoting/impl/invm/InVMAcceptorFactory.java | 3 --- .../apache/activemq/core/remoting/impl/invm/InVMConnection.java | 3 --- .../apache/activemq/core/remoting/impl/invm/InVMConnector.java | 3 --- .../activemq/core/remoting/impl/invm/InVMConnectorFactory.java | 3 --- .../org/apache/activemq/core/remoting/impl/invm/InVMRegistry.java | 3 --- .../activemq/core/remoting/impl/invm/TransportConstants.java | 3 --- .../activemq/core/remoting/impl/netty/NettyAcceptorFactory.java | 3 --- .../java/org/apache/activemq/core/server/ActivateCallback.java | 3 --- .../src/main/java/org/apache/activemq/core/server/Bindable.java | 3 --- .../java/org/apache/activemq/core/server/BindingQueryResult.java | 3 --- .../src/main/java/org/apache/activemq/core/server/Consumer.java | 3 --- .../src/main/java/org/apache/activemq/core/server/Divert.java | 3 --- .../main/java/org/apache/activemq/core/server/JournalType.java | 3 --- .../java/org/apache/activemq/core/server/LargeServerMessage.java | 3 --- .../src/main/java/org/apache/activemq/core/server/Queue.java | 3 --- .../main/java/org/apache/activemq/core/server/RoutingContext.java | 3 --- .../main/java/org/apache/activemq/core/server/ServerSession.java | 3 --- .../org/apache/activemq/core/server/cluster/BroadcastGroup.java | 3 --- .../apache/activemq/core/server/cluster/ClusterConnection.java | 3 --- .../apache/activemq/core/server/cluster/MessageFlowRecord.java | 3 --- .../apache/activemq/core/server/cluster/RemoteQueueBinding.java | 3 --- .../java/org/apache/activemq/core/server/cluster/Transformer.java | 3 --- .../activemq/core/server/cluster/impl/ClusterConnectionImpl.java | 3 --- .../apache/activemq/core/server/cluster/impl/Redistributor.java | 3 --- .../activemq/core/server/cluster/impl/RemoteQueueBindingImpl.java | 3 --- .../org/apache/activemq/core/server/impl/RoutingContextImpl.java | 3 --- .../java/org/apache/activemq/core/server/impl/ServerInfo.java | 3 --- .../org/apache/activemq/core/server/impl/ServerMessageImpl.java | 3 --- .../apache/activemq/core/settings/impl/SlowConsumerPolicy.java | 3 --- .../org/apache/activemq/core/transaction/ResourceManager.java | 3 --- .../org/apache/activemq/core/transaction/TransactionDetail.java | 3 --- .../activemq/core/transaction/TransactionPropertyIndexes.java | 3 --- .../activemq/core/transaction/impl/BindingsTransactionImpl.java | 3 --- .../activemq/core/transaction/impl/CoreTransactionDetail.java | 3 --- .../activemq/core/transaction/impl/ResourceManagerImpl.java | 3 --- .../apache/activemq/core/transaction/impl/TransactionImpl.java | 3 --- .../org/apache/activemq/spi/core/protocol/ProtocolManager.java | 3 --- .../apache/activemq/spi/core/protocol/ProtocolManagerFactory.java | 3 --- .../org/apache/activemq/spi/core/protocol/SessionCallback.java | 3 --- .../main/java/org/apache/activemq/utils/XMLConfigurationUtil.java | 3 --- .../apache/activemq/core/config/impl/ConfigurationImplTest.java | 3 --- .../activemq/core/config/impl/DefaultsFileConfigurationTest.java | 3 --- .../activemq/core/config/impl/FileConfigurationParserTest.java | 3 --- .../java/org/apache/activemq/tests/util/SimpleStringTest.java | 3 --- .../src/main/java/org/apache/activemq/tools/PrintPages.java | 3 --- .../main/java/org/apache/activemq/core/example/PerfListener.java | 3 --- .../main/java/org/apache/activemq/core/example/PerfSender.java | 3 --- .../apache/activemq/jms/example/HatColourChangeTransformer.java | 3 --- .../apache/activemq/jms/example/AddForwardingTimeTransformer.java | 3 --- .../src/main/java/org/apache/activemq/jms/example/PerfBase.java | 3 --- .../main/java/org/apache/activemq/jms/example/PerfListener.java | 3 --- .../src/main/java/org/apache/activemq/jms/example/PerfSender.java | 3 --- .../main/java/org/apache/activemq/jms/soak/example/SoakBase.java | 3 --- .../apache/activemq/tests/extras/jms/bridge/BridgeTestBase.java | 3 --- .../apache/activemq/tests/extras/jms/bridge/JMSBridgeTest.java | 3 --- .../test/java/org/apache/activemq/tests/extras/jms/xa/XATest.java | 3 --- .../apache/activemq/tests/integration/DuplicateDetectionTest.java | 3 --- .../org/apache/activemq/tests/integration/InterceptorTest.java | 3 --- .../activemq/tests/integration/SimpleNotificationService.java | 3 --- .../activemq/tests/integration/client/BlockingSendTest.java | 3 --- .../activemq/tests/integration/client/ConsumerFilterTest.java | 3 --- .../activemq/tests/integration/client/DurableQueueTest.java | 3 --- .../tests/integration/client/ExpireTestOnRestartTest.java | 3 --- .../activemq/tests/integration/client/FailureDeadlockTest.java | 3 --- .../client/FlowControlOnIgnoreLargeMessageBodyTest.java | 3 --- .../apache/activemq/tests/integration/client/HeuristicXATest.java | 3 --- .../tests/integration/client/InVMPersistentMessageBufferTest.java | 3 --- .../tests/integration/client/IncompatibleVersionTest.java | 3 --- .../tests/integration/client/InterruptedLargeMessageTest.java | 3 --- .../activemq/tests/integration/client/JournalCrashTest.java | 3 --- .../activemq/tests/integration/client/LargeMessageTest.java | 3 --- .../activemq/tests/integration/client/MessageConcurrencyTest.java | 3 --- .../tests/integration/client/MessageConsumerRollbackTest.java | 3 --- .../activemq/tests/integration/client/MessageDurabilityTest.java | 3 --- .../activemq/tests/integration/client/MessageExpirationTest.java | 3 --- .../activemq/tests/integration/client/MessagePriorityTest.java | 3 --- .../apache/activemq/tests/integration/client/MessageRateTest.java | 3 --- .../tests/integration/client/NettyConsumerWindowSizeTest.java | 3 --- .../integration/client/NettyNonPersistentMessageBufferTest.java | 3 --- .../integration/client/NettyPersistentMessageBufferTest.java | 3 --- .../tests/integration/client/NettyProducerFlowControlTest.java | 3 --- .../org/apache/activemq/tests/integration/client/OrderTest.java | 3 --- .../org/apache/activemq/tests/integration/client/PagingTest.java | 3 --- .../tests/integration/client/ProducerFlowControlTest.java | 3 --- .../activemq/tests/integration/client/RedeliveryConsumerTest.java | 3 --- .../apache/activemq/tests/integration/client/RequestorTest.java | 3 --- .../tests/integration/client/SelfExpandingBufferTest.java | 3 --- .../activemq/tests/integration/client/SessionCloseOnGCTest.java | 3 --- .../activemq/tests/integration/client/SessionCloseTest.java | 3 --- .../client/SessionClosedOnRemotingConnectionFailureTest.java | 3 --- .../activemq/tests/integration/client/SessionFactoryTest.java | 3 --- .../integration/client/SessionSendAcknowledgementHandlerTest.java | 3 --- .../activemq/tests/integration/client/TemporaryQueueTest.java | 3 --- .../tests/integration/client/TransactionDurabilityTest.java | 3 --- .../activemq/tests/integration/clientcrash/ClientTestBase.java | 3 --- .../tests/integration/cluster/bridge/BridgeReconnectTest.java | 3 --- .../tests/integration/cluster/bridge/BridgeStartTest.java | 3 --- .../activemq/tests/integration/cluster/bridge/BridgeTest.java | 3 --- .../activemq/tests/integration/cluster/bridge/BridgeTestBase.java | 3 --- .../cluster/bridge/BridgeWithDiscoveryGroupStartTest.java | 3 --- .../tests/integration/cluster/bridge/SimpleTransformer.java | 3 --- .../tests/integration/cluster/distribution/ClusterTestBase.java | 3 --- .../integration/cluster/distribution/ClusterWithBackupTest.java | 3 --- .../cluster/distribution/ClusteredRequestResponseTest.java | 3 --- .../cluster/distribution/LargeMessageRedistributionTest.java | 3 --- .../cluster/distribution/MessageRedistributionTest.java | 3 --- .../distribution/MessageRedistributionWithDiscoveryTest.java | 3 --- .../distribution/NettyFileStorageSymmetricClusterTest.java | 3 --- .../NettyFileStorageSymmetricClusterWithBackupTest.java | 3 --- .../NettyFileStorageSymmetricClusterWithDiscoveryTest.java | 3 --- .../cluster/distribution/NettyOneWayChainClusterTest.java | 3 --- .../cluster/distribution/NettyOneWayTwoNodeClusterTest.java | 3 --- .../cluster/distribution/NettySymmetricClusterTest.java | 3 --- .../cluster/distribution/NettySymmetricClusterWithBackupTest.java | 3 --- .../distribution/NettySymmetricClusterWithDiscoveryTest.java | 3 --- .../integration/cluster/distribution/OneWayChainClusterTest.java | 3 --- .../cluster/distribution/OnewayTwoNodeClusterTest.java | 3 --- .../cluster/distribution/SimpleSymmetricClusterTest.java | 3 --- .../cluster/distribution/SymmetricClusterWithBackupTest.java | 3 --- .../cluster/distribution/SymmetricClusterWithDiscoveryTest.java | 3 --- .../cluster/distribution/TemporaryQueueClusterTest.java | 3 --- .../cluster/distribution/TwoWayTwoNodeClusterTest.java | 3 --- .../distribution/TwoWayTwoNodeClusterWithDiscoveryTest.java | 3 --- .../cluster/failover/ClusterWithBackupFailoverTestBase.java | 3 --- .../tests/integration/cluster/failover/DelayInterceptor.java | 3 --- .../tests/integration/cluster/failover/DelayInterceptor2.java | 3 --- .../tests/integration/cluster/failover/DelayInterceptor3.java | 3 --- .../cluster/failover/DiscoveryClusterWithBackupFailoverTest.java | 3 --- .../integration/cluster/failover/FailoverOnFlowControlTest.java | 3 --- .../activemq/tests/integration/cluster/failover/FailoverTest.java | 3 --- .../tests/integration/cluster/failover/FailoverTestBase.java | 3 --- .../integration/cluster/failover/LargeMessageFailoverTest.java | 3 --- .../cluster/failover/MultipleBackupsFailoverTestBase.java | 3 --- .../cluster/failover/NettyAsynchronousFailoverTest.java | 3 --- .../cluster/failover/NettyAsynchronousReattachTest.java | 3 --- .../failover/NettyDiscoveryClusterWithBackupFailoverTest.java | 3 --- .../tests/integration/cluster/failover/NettyFailoverTest.java | 3 --- .../NettyFileStorageDiscoveryClusterWithBackupFailoverTest.java | 3 --- .../NettyFileStorageStaticClusterWithBackupFailoverTest.java | 3 --- .../integration/cluster/failover/NettyReplicatedFailoverTest.java | 3 --- .../failover/NettyStaticClusterWithBackupFailoverTest.java | 3 --- .../cluster/failover/ReplicatedAsynchronousFailoverTest.java | 3 --- .../integration/cluster/failover/ReplicatedDistributionTest.java | 3 --- .../cluster/failover/ReplicatedLargeMessageFailoverTest.java | 3 --- .../cluster/failover/ReplicatedNettyAsynchronousFailoverTest.java | 3 --- .../cluster/failover/ReplicatedPagingFailoverTest.java | 3 --- .../tests/integration/cluster/failover/SecurityFailoverTest.java | 3 --- .../integration/cluster/failover/SharedStoreDistributionTest.java | 3 --- .../cluster/failover/StaticClusterWithBackupFailoverTest.java | 3 --- .../cluster/failover/remote/FailoverWithSharedStoreTest.java | 3 --- .../cluster/reattach/MultiThreadRandomReattachTestBase.java | 3 --- .../cluster/reattach/MultiThreadReattachSupportTestBase.java | 3 --- .../cluster/reattach/NettyMultiThreadRandomReattachTest.java | 3 --- .../tests/integration/cluster/reattach/OrderReattachTest.java | 3 --- .../tests/integration/cluster/reattach/RandomReattachTest.java | 3 --- .../activemq/tests/integration/cluster/reattach/ReattachTest.java | 3 --- .../tests/integration/cluster/topology/IsolatedTopologyTest.java | 3 --- .../integration/cluster/topology/NettyHAClientTopologyTest.java | 3 --- .../cluster/topology/NettyHAClientTopologyWithDiscoveryTest.java | 3 --- .../integration/cluster/topology/TopologyClusterTestBase.java | 3 --- .../tests/integration/cluster/util/SameProcessActiveMQServer.java | 3 --- .../activemq/tests/integration/cluster/util/TestableServer.java | 3 --- .../org/apache/activemq/tests/integration/divert/DivertTest.java | 3 --- .../activemq/tests/integration/divert/PersistentDivertTest.java | 3 --- .../activemq/tests/integration/jms/client/AutoGroupingTest.java | 3 --- .../activemq/tests/integration/jms/client/ConnectionTest.java | 3 --- .../activemq/tests/integration/jms/client/CreateQueueTest.java | 3 --- .../activemq/tests/integration/jms/client/ExpiryMessageTest.java | 3 --- .../apache/activemq/tests/integration/jms/client/GroupIDTest.java | 3 --- .../apache/activemq/tests/integration/jms/client/MessageTest.java | 3 --- .../activemq/tests/integration/jms/client/PreACKJMSTest.java | 3 --- .../apache/activemq/tests/integration/jms/client/SessionTest.java | 3 --- .../activemq/tests/integration/jms/client/StoreConfigTest.java | 3 --- .../activemq/tests/integration/jms/client/TextMessageTest.java | 3 --- .../tests/integration/jms/cluster/BindingsClusterTest.java | 3 --- .../activemq/tests/integration/jms/cluster/JMSReconnectTest.java | 3 --- .../tests/integration/jms/cluster/LargeMessageOverBridgeTest.java | 3 --- .../tests/integration/jms/cluster/MultipleThreadsOpeningTest.java | 3 --- .../tests/integration/jms/cluster/ReplicatedJMSFailoverTest.java | 3 --- .../tests/integration/jms/cluster/TemporaryQueueClusterTest.java | 3 --- .../activemq/tests/integration/jms/cluster/TopicClusterTest.java | 3 --- .../tests/integration/jms/server/JMSServerDeployerTest.java | 3 --- .../tests/integration/jms/server/JMSServerStartStopTest.java | 3 --- .../tests/integration/jms/server/config/JMSConfigurationTest.java | 3 --- .../integration/jms/server/config/JMSServerConfigParserTest.java | 3 --- .../integration/jms/server/management/JMSMessagingProxy.java | 3 --- .../integration/jms/server/management/JMSServerControl2Test.java | 3 --- .../jms/server/management/JMSServerControlRestartTest.java | 3 --- .../integration/jms/server/management/JMSServerControlTest.java | 3 --- .../jms/server/management/JMSServerControlUsingJMSTest.java | 3 --- .../activemq/tests/integration/jms/server/management/JMSUtil.java | 3 --- .../integration/jms/server/management/NullInitialContext.java | 3 --- .../tests/integration/jms/server/management/TopicControlTest.java | 3 --- .../activemq/tests/integration/journal/AIOImportExportTest.java | 3 --- .../activemq/tests/integration/journal/AIOJournalCompactTest.java | 3 --- .../tests/integration/journal/AIOSequentialFileFactoryTest.java | 3 --- .../activemq/tests/integration/journal/JournalPerfTuneTest.java | 3 --- .../tests/integration/journal/NIOBufferedJournalCompactTest.java | 3 --- .../activemq/tests/integration/journal/NIOImportExportTest.java | 3 --- .../activemq/tests/integration/journal/NIOJournalCompactTest.java | 3 --- .../activemq/tests/integration/journal/NIOJournalImplTest.java | 3 --- .../tests/integration/journal/NIONoBufferJournalImplTest.java | 3 --- .../journal/NIONonBufferedSequentialFileFactoryTest.java | 3 --- .../tests/integration/journal/NIOSequentialFileFactoryTest.java | 3 --- .../apache/activemq/tests/integration/journal/OldFormatTest.java | 3 --- .../tests/integration/largemessage/LargeMessageTestBase.java | 3 --- .../tests/integration/largemessage/ServerLargeMessageTest.java | 3 --- .../tests/integration/management/AcceptorControlTest.java | 3 --- .../integration/management/AcceptorControlUsingCoreTest.java | 3 --- .../tests/integration/management/ActiveMQServerControlTest.java | 3 --- .../management/ActiveMQServerControlUsingCoreTest.java | 3 --- .../activemq/tests/integration/management/AddressControlTest.java | 3 --- .../tests/integration/management/AddressControlUsingCoreTest.java | 3 --- .../activemq/tests/integration/management/BridgeControlTest.java | 3 --- .../tests/integration/management/BridgeControlUsingCoreTest.java | 3 --- .../management/BroadcastGroupControlUsingCoreTest.java | 3 --- .../integration/management/ClusterConnectionControl2Test.java | 3 --- .../integration/management/ClusterConnectionControlTest.java | 3 --- .../management/ClusterConnectionControlUsingCoreTest.java | 3 --- .../activemq/tests/integration/management/CoreMessagingProxy.java | 3 --- .../activemq/tests/integration/management/DivertControlTest.java | 3 --- .../tests/integration/management/DivertControlUsingCoreTest.java | 3 --- .../activemq/tests/integration/management/JMXDomainTest.java | 3 --- .../tests/integration/management/ManagementControlHelper.java | 3 --- .../tests/integration/management/ManagementHelperTest.java | 3 --- .../activemq/tests/integration/management/ManagementTestBase.java | 3 --- .../tests/integration/management/ManagementWithStompTest.java | 3 --- .../activemq/tests/integration/management/NotificationTest.java | 3 --- .../activemq/tests/integration/management/QueueControlTest.java | 3 --- .../tests/integration/management/QueueControlUsingCoreTest.java | 3 --- .../tests/integration/management/SecurityManagementTestBase.java | 3 --- .../management/SecurityManagementWithConfiguredAdminUserTest.java | 3 --- .../SecurityManagementWithDefaultConfigurationTest.java | 3 --- .../SecurityManagementWithModifiedConfigurationTest.java | 3 --- .../tests/integration/management/SecurityNotificationTest.java | 3 --- .../activemq/tests/integration/paging/NettyPagingSendTest.java | 3 --- .../activemq/tests/integration/paging/PagingCounterTest.java | 3 --- .../apache/activemq/tests/integration/paging/PagingSendTest.java | 3 --- .../persistence/AddressSettingsConfigurationStorageTest.java | 3 --- .../integration/persistence/DeleteMessagesOnStartupTest.java | 3 --- .../tests/integration/persistence/DeleteQueueRestartTest.java | 3 --- .../tests/integration/persistence/DuplicateCacheTest.java | 3 --- .../activemq/tests/integration/persistence/ExportFormatTest.java | 3 --- .../persistence/JMSConnectionFactoryConfigurationStorageTest.java | 3 --- .../tests/integration/persistence/JMSDynamicConfigTest.java | 3 --- .../tests/integration/persistence/JMSStorageManagerTest.java | 3 --- .../activemq/tests/integration/persistence/RestartSMTest.java | 3 --- .../integration/persistence/RolesConfigurationStorageTest.java | 3 --- .../tests/integration/persistence/StorageManagerTestBase.java | 3 --- .../persistence/TransportConfigurationEncodingSupportTest.java | 3 --- .../activemq/tests/integration/ra/ActiveMQActivationTest.java | 3 --- .../activemq/tests/integration/remoting/BatchDelayTest.java | 3 --- .../activemq/tests/integration/remoting/DirectDeliverTest.java | 3 --- .../tests/integration/remoting/NettyNetworkAddressTest.java | 3 --- .../tests/integration/remoting/NettySynchronousCloseTest.java | 3 --- .../tests/integration/remoting/NetworkAddressTestBase.java | 3 --- .../apache/activemq/tests/integration/remoting/ReconnectTest.java | 3 --- .../activemq/tests/integration/remoting/SynchronousCloseTest.java | 3 --- .../tests/integration/replication/ReplicationOrderTest.java | 3 --- .../activemq/tests/integration/replication/ReplicationTest.java | 3 --- .../tests/integration/security/NettySecurityClientTest.java | 3 --- .../activemq/tests/integration/server/GracefulShutdownTest.java | 3 --- .../activemq/tests/integration/server/PredefinedQueueTest.java | 3 --- .../tests/integration/stomp/StompConnectionCleanupTest.java | 3 --- .../integration/transports/netty/ActiveMQFrameDecoder2Test.java | 3 --- .../java/org/apache/activemq/tests/util/JMSClusteredTestBase.java | 3 --- .../src/test/java/org/apache/activemq/tests/util/JMSTestBase.java | 3 --- .../org/apache/activemq/jms/tests/AutoAckMesageListenerTest.java | 3 --- .../java/org/apache/activemq/jms/tests/DeliveryOrderTest.java | 3 --- .../test/java/org/apache/activemq/jms/tests/PersistenceTest.java | 3 --- .../org/apache/activemq/jms/tests/message/MessageBodyTest.java | 3 --- .../src/test/java/org/apache/activemq/jms/ActiveMQAdmin.java | 3 --- .../src/test/java/org/apache/activemq/jms/SpawnedJMSServer.java | 3 --- .../activemq/tests/performance/journal/JournalImplTestUnit.java | 3 --- .../tests/performance/journal/RealJournalImplAIOTest.java | 3 --- .../tests/performance/journal/RealJournalImplNIOTest.java | 3 --- .../tests/performance/paging/MeasurePagingMultiThreadTest.java | 3 --- .../activemq/tests/soak/client/ClientNonDivertedSoakTest.java | 3 --- .../org/apache/activemq/tests/soak/client/ClientSoakTest.java | 3 --- .../test/java/org/apache/activemq/tests/soak/client/Receiver.java | 3 --- .../test/java/org/apache/activemq/tests/soak/client/Sender.java | 3 --- .../activemq/tests/soak/client/SimpleSendReceiveSoakTest.java | 3 --- .../activemq/tests/soak/failover/RandomFailoverSoakTest.java | 3 --- .../activemq/tests/stress/chunk/LargeMessageStressTest.java | 3 --- .../org/apache/activemq/tests/stress/client/SendStressTest.java | 3 --- .../stress/failover/MultiThreadRandomReattachStressTest.java | 3 --- .../activemq/tests/stress/failover/RandomReattachStressTest.java | 3 --- .../stress/journal/AIOAllPossibilitiesCompactStressTest.java | 3 --- .../tests/stress/journal/AIOMultiThreadCompactorStressTest.java | 3 --- .../tests/stress/journal/AllPossibilitiesCompactStressTest.java | 3 --- .../journal/AllPossibilitiesCompactWithAddDeleteStressTest.java | 3 --- .../activemq/tests/stress/journal/CompactingStressTest.java | 3 --- .../tests/stress/journal/JournalCleanupCompactStressTest.java | 3 --- .../activemq/tests/stress/journal/LargeJournalStressTest.java | 3 --- .../tests/stress/journal/NIOMultiThreadCompactorStressTest.java | 3 --- .../tests/stress/paging/MultipleConsumersPageStressTest.java | 3 --- .../apache/activemq/tests/stress/paging/PageCursorStressTest.java | 3 --- .../tests/timing/core/journal/impl/AIOJournalImplTest.java | 3 --- .../tests/timing/core/journal/impl/FakeJournalImplTest.java | 3 --- .../tests/timing/core/journal/impl/JournalImplTestUnit.java | 3 --- .../tests/timing/core/journal/impl/NIOJournalImplTest.java | 3 --- .../activemq/tests/timing/util/TokenBucketLimiterImplTest.java | 3 --- .../test/java/org/apache/activemq/tests/timing/util/UTF8Test.java | 3 --- .../tests/unit/core/client/impl/LargeMessageBufferTest.java | 3 --- .../tests/unit/core/config/impl/ConfigurationValidationTest.java | 3 --- .../tests/unit/core/config/impl/TransportConfigurationTest.java | 3 --- .../tests/unit/core/journal/impl/FakeJournalImplTest.java | 3 --- .../unit/core/journal/impl/FakeSequentialFileFactoryTest.java | 3 --- .../activemq/tests/unit/core/journal/impl/JournalAsyncTest.java | 3 --- .../tests/unit/core/journal/impl/JournalImplTestBase.java | 3 --- .../tests/unit/core/journal/impl/JournalImplTestUnit.java | 3 --- .../activemq/tests/unit/core/journal/impl/ReclaimerTest.java | 3 --- .../unit/core/journal/impl/SequentialFileFactoryTestBase.java | 3 --- .../activemq/tests/unit/core/journal/impl/TimedBufferTest.java | 3 --- .../unit/core/journal/impl/fakes/FakeSequentialFileFactory.java | 3 --- .../activemq/tests/unit/core/paging/impl/PagePositionTest.java | 3 --- .../unit/core/persistence/impl/BatchIDGeneratorUnitTest.java | 3 --- .../unit/core/persistence/impl/OperationContextUnitTest.java | 3 --- .../tests/unit/core/postoffice/impl/BindingsImplTest.java | 3 --- .../unit/core/postoffice/impl/DuplicateDetectionUnitTest.java | 3 --- .../activemq/tests/unit/core/postoffice/impl/FakeQueue.java | 3 --- .../unit/core/remoting/impl/netty/NettyAcceptorFactoryTest.java | 3 --- .../tests/unit/core/remoting/impl/netty/NettyAcceptorTest.java | 3 --- .../tests/unit/core/remoting/impl/netty/NettyConnectionTest.java | 3 --- .../unit/core/server/cluster/impl/RemoteQueueBindImplTest.java | 3 --- .../apache/activemq/tests/unit/core/server/impl/FileLockTest.java | 3 --- .../activemq/tests/unit/core/server/impl/QueueImplTest.java | 3 --- .../activemq/tests/unit/core/server/impl/fakes/FakeConsumer.java | 3 --- .../activemq/tests/unit/core/server/impl/fakes/FakeFilter.java | 3 --- .../tests/unit/core/server/impl/fakes/FakeQueueFactory.java | 3 --- .../activemq/tests/unit/jms/client/SelectorTranslatorTest.java | 3 --- .../org/apache/activemq/tests/unit/ra/ResourceAdapterTest.java | 3 --- .../activemq/tests/unit/util/ActiveMQBufferInputStreamTest.java | 3 --- .../java/org/apache/activemq/tests/unit/util/LinkedListTest.java | 3 --- .../java/org/apache/activemq/tests/unit/util/MemorySizeTest.java | 3 --- .../org/apache/activemq/tests/unit/util/SoftValueMapTest.java | 3 --- .../test/java/org/apache/activemq/tests/unit/util/UTF8Test.java | 3 --- 515 files changed, 1545 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-commons/src/main/java/org/apache/activemq/core/buffers/impl/ChannelBufferWrapper.java ---------------------------------------------------------------------- diff --git a/activemq-commons/src/main/java/org/apache/activemq/core/buffers/impl/ChannelBufferWrapper.java b/activemq-commons/src/main/java/org/apache/activemq/core/buffers/impl/ChannelBufferWrapper.java index 3dddb1a..50c19d1 100644 --- a/activemq-commons/src/main/java/org/apache/activemq/core/buffers/impl/ChannelBufferWrapper.java +++ b/activemq-commons/src/main/java/org/apache/activemq/core/buffers/impl/ChannelBufferWrapper.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.utils.DataConstants; import org.apache.activemq.utils.UTF8Util; -/** - * A ChannelBufferWrapper - */ public class ChannelBufferWrapper implements ActiveMQBuffer { protected ByteBuf buffer; // NO_UCD (use final) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-commons/src/main/java/org/apache/activemq/core/server/ActiveMQComponent.java ---------------------------------------------------------------------- diff --git a/activemq-commons/src/main/java/org/apache/activemq/core/server/ActiveMQComponent.java b/activemq-commons/src/main/java/org/apache/activemq/core/server/ActiveMQComponent.java index fb69bf2..0df80f5 100644 --- a/activemq-commons/src/main/java/org/apache/activemq/core/server/ActiveMQComponent.java +++ b/activemq-commons/src/main/java/org/apache/activemq/core/server/ActiveMQComponent.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.server; -/** - * A ActiveMQComponent - */ public interface ActiveMQComponent { void start() throws Exception; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-commons/src/main/java/org/apache/activemq/utils/ActiveMQThreadFactory.java ---------------------------------------------------------------------- diff --git a/activemq-commons/src/main/java/org/apache/activemq/utils/ActiveMQThreadFactory.java b/activemq-commons/src/main/java/org/apache/activemq/utils/ActiveMQThreadFactory.java index f1b9754..23a84db 100644 --- a/activemq-commons/src/main/java/org/apache/activemq/utils/ActiveMQThreadFactory.java +++ b/activemq-commons/src/main/java/org/apache/activemq/utils/ActiveMQThreadFactory.java @@ -22,9 +22,6 @@ import java.security.PrivilegedAction; import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicInteger; -/** - * A ActiveMQThreadFactory - */ public final class ActiveMQThreadFactory implements ThreadFactory { private final ThreadGroup group; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-commons/src/main/java/org/apache/activemq/utils/DataConstants.java ---------------------------------------------------------------------- diff --git a/activemq-commons/src/main/java/org/apache/activemq/utils/DataConstants.java b/activemq-commons/src/main/java/org/apache/activemq/utils/DataConstants.java index d1a3558..8e659bb 100644 --- a/activemq-commons/src/main/java/org/apache/activemq/utils/DataConstants.java +++ b/activemq-commons/src/main/java/org/apache/activemq/utils/DataConstants.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.utils; -/** - * A DataConstants - */ public final class DataConstants { public static final int SIZE_INT = 4; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-commons/src/main/java/org/apache/activemq/utils/PasswordMaskingUtil.java ---------------------------------------------------------------------- diff --git a/activemq-commons/src/main/java/org/apache/activemq/utils/PasswordMaskingUtil.java b/activemq-commons/src/main/java/org/apache/activemq/utils/PasswordMaskingUtil.java index d631060..271c8d4 100644 --- a/activemq-commons/src/main/java/org/apache/activemq/utils/PasswordMaskingUtil.java +++ b/activemq-commons/src/main/java/org/apache/activemq/utils/PasswordMaskingUtil.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.ActiveMQException; import org.apache.activemq.api.core.ActiveMQExceptionType; import org.apache.activemq.logs.ActiveMQUtilBundle; -/** - * A PasswordMarkingUtil - */ public class PasswordMaskingUtil { /* http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java index 3081a1f..babcffa 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java @@ -18,9 +18,6 @@ package org.apache.activemq.api.core.management; import org.apache.activemq.utils.json.JSONObject; -/** - * A AddressSettingsInfo - */ // XXX no javadocs public final class AddressSettingsInfo { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java index e3d9fd3..27a0a75 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java @@ -23,9 +23,6 @@ import org.apache.activemq.api.core.client.ClientMessage; import org.apache.activemq.api.core.client.ClientSession; import org.apache.activemq.utils.FutureLatch; -/** - * A ClientConsumerInternal - */ public interface ClientConsumerInternal extends ClientConsumer { SimpleString getQueueName(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java index 29cb645..b4ce9dd 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java @@ -17,9 +17,6 @@ package org.apache.activemq.core.client.impl; -/** - * A ClientLargeMessageInternal - */ public interface ClientLargeMessageInternal extends ClientMessageInternal { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java index 3e88720..45e6f73 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.api.core.client.ClientMessage; import org.apache.activemq.utils.TypedProperties; -/** - * A ClientMessageInternal - */ public interface ClientMessageInternal extends ClientMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java index c177ed7..27636d8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.client.impl; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.spi.core.remoting.SessionContext; -/** - * A ClientProducerCreditManager - */ public interface ClientProducerCreditManager { ClientProducerCredits getCredits(SimpleString address, boolean anon, SessionContext context); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java index 130c8a4..80e9ebf 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java @@ -23,9 +23,6 @@ import java.util.Map; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.spi.core.remoting.SessionContext; -/** - * A ProducerCreditManager - */ public class ClientProducerCreditManagerImpl implements ClientProducerCreditManager { public static final int MAX_UNREFERENCED_CREDITS_CACHE_SIZE = 1000; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java index 91a9c02..3a463cf 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.client.impl; import org.apache.activemq.api.core.ActiveMQException; import org.apache.activemq.spi.core.remoting.SessionContext; -/** - * A ClientProducerCredits - */ public interface ClientProducerCredits { void acquireCredits(int credits) throws InterruptedException, ActiveMQException; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java index 0aac7a7..ec201e7 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java @@ -25,9 +25,6 @@ import org.apache.activemq.spi.core.remoting.SessionContext; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit; -/** - * A ClientProducerCreditsImpl - */ public class ClientProducerCreditsImpl implements ClientProducerCredits { private final Semaphore semaphore; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java index 0678639..57c5a61 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java @@ -24,9 +24,6 @@ import org.apache.activemq.api.core.client.ClientSessionFactory; import org.apache.activemq.api.core.client.SessionFailureListener; import org.apache.activemq.utils.ConfirmationWindowWarning; -/** - * A ClientSessionFactoryInternal - */ public interface ClientSessionFactoryInternal extends ClientSessionFactory { void causeExit(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java index 8ead36f..24d6396 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.client.SendAcknowledgementHandler; import org.apache.activemq.spi.core.protocol.RemotingConnection; import org.apache.activemq.spi.core.remoting.ConsumerContext; -/** - * A ClientSessionInternal - */ public interface ClientSessionInternal extends ClientSession { String getName(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java index 863e5ab..0f8a8e0 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java @@ -21,9 +21,6 @@ import java.io.OutputStream; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.ActiveMQException; -/** - * A LargeMessageBufferInternal - */ public interface LargeMessageController extends ActiveMQBuffer { /** http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java index db374ec..d9e660d 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.client.ServerLocator; import org.apache.activemq.api.core.Pair; import org.apache.activemq.spi.core.remoting.ClientProtocolManager; -/** - * A ServerLocatorInternal - */ public interface ServerLocatorInternal extends ServerLocator { void start(Executor executor) throws Exception; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java b/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java index 35402cc..6028c38 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.cluster; import org.apache.activemq.api.core.TransportConfiguration; -/** - * A DiscoveryEntry - */ public class DiscoveryEntry { private final String nodeID; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java b/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java index f347d06..80db870 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.exception; import javax.transaction.xa.XAException; -/** - * A ActiveMQXAException - */ public class ActiveMQXAException extends XAException { private static final long serialVersionUID = 6535914602965015803L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java index aedf5af..848ebf7 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.message.BodyEncoder; import org.apache.activemq.utils.TypedProperties; -/** - * A MessageInternal - */ public interface MessageInternal extends Message { void decodeFromBuffer(ActiveMQBuffer buffer); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java index 2150bb1..a71aed5 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java @@ -40,9 +40,6 @@ import org.apache.activemq.core.protocol.core.impl.wireformat.ActiveMQExceptionM import org.apache.activemq.core.protocol.core.impl.wireformat.PacketsConfirmedMessage; import org.apache.activemq.spi.core.protocol.RemotingConnection; -/** - * A ChannelImpl - */ public final class ChannelImpl implements Channel { public enum CHANNEL_ID http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java index 2aa2958..694f332 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java @@ -145,9 +145,6 @@ import org.apache.activemq.core.protocol.core.impl.wireformat.SessionXAStartMess import org.apache.activemq.core.protocol.core.impl.wireformat.SubscribeClusterTopologyUpdatesMessage; import org.apache.activemq.core.protocol.core.impl.wireformat.SubscribeClusterTopologyUpdatesMessageV2; -/** - * A PacketDecoder - */ public abstract class PacketDecoder implements Serializable { public abstract Packet decode(final ActiveMQBuffer in); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java index bc35071..2d772d8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.Message; import org.apache.activemq.core.message.impl.MessageInternal; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * A MessagePacket - */ public abstract class MessagePacket extends PacketImpl { protected MessageInternal message; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java index 11cf330..f12d9b0 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * A PacketsConfirmedMessage - */ public class PacketsConfirmedMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java index 666ccf3..dba5246 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * A ReattachSessionMessage - */ public class ReattachSessionMessage extends PacketImpl { private String name; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java index 68d5093..75652f4 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * A ReattachSessionResponseMessage - */ public class ReattachSessionResponseMessage extends PacketImpl { private int lastConfirmedCommandID; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java index 76aeb7b..5e6d777 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * A RollbackMessage - */ public class RollbackMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java index 007dd00..a0c0793 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * A SessionQueueQueryMessage - */ public class SessionBindingQueryMessage extends PacketImpl { private SimpleString address; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java index 95725d5..783ce4a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * A SessionCommitMessage - */ public class SessionCommitMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java index 698452d..41a9f3d 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java @@ -22,9 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.DataConstants; -/** - * A SessionContinuationMessage - */ public abstract class SessionContinuationMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java index 8059015..17555a0 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * A SessionQueueQueryMessage - */ public class SessionQueueQueryMessage extends PacketImpl { private SimpleString queueName; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java index 6358769..fca0268 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java @@ -23,9 +23,6 @@ import org.apache.activemq.core.client.impl.QueueQueryImpl; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.core.server.QueueQueryResult; -/** - * A SessionQueueQueryResponseMessage - */ public class SessionQueueQueryResponseMessage extends PacketImpl { protected SimpleString name; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java index fd9c9bc..f1a3f61 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.utils.DataConstants; -/** - * A SessionSendContinuationMessage - */ public class SessionReceiveContinuationMessage extends SessionContinuationMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java index b4aa9e4..344c614 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.message.impl.MessageInternal; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * A SessionReceiveLargeMessage - */ public class SessionReceiveLargeMessage extends PacketImpl { private final MessageInternal message; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java index f793eed..e844f7b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java @@ -17,9 +17,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; -/** - * A SessionUniqueAddMetaDataMessageV2 - */ public class SessionUniqueAddMetaDataMessage extends SessionAddMetaDataMessageV2 { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java index fe5d1aa..1ddb593 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java @@ -103,9 +103,6 @@ import org.apache.activemq.utils.FutureLatch; import static org.apache.activemq.utils.Base64.encodeBytes; -/** - * A NettyConnector - */ public class NettyConnector extends AbstractConnector { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java index dea675d..b159b02 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java @@ -26,9 +26,6 @@ import org.apache.activemq.spi.core.remoting.ConnectionLifeCycleListener; import org.apache.activemq.spi.core.remoting.Connector; import org.apache.activemq.spi.core.remoting.ConnectorFactory; -/** - * A NettyConnectorFactory - */ public class NettyConnectorFactory implements ConnectorFactory { public Connector createConnector(final Map<String, Object> configuration, http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java index 235b4b5..1836ef3 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java @@ -23,9 +23,6 @@ import java.util.Set; import io.netty.util.Version; import org.apache.activemq.api.config.ActiveMQDefaultConfiguration; -/** - * A TransportConstants - */ public class TransportConstants { public static final String SSL_ENABLED_PROP_NAME = "sslEnabled"; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java b/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java index 7357543..4ed9190 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.server; import org.apache.activemq.api.core.SimpleString; -/** - * A QueueQueryResult - */ public class QueueQueryResult { private SimpleString name; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java index b7f0422..0a16be7 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java @@ -17,9 +17,6 @@ package org.apache.activemq.core.server.management; -/** - * A NotificationListener - */ public interface NotificationListener { void onNotification(Notification notification); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java index e06d759..a58a8c6 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.server.management; -/** - * A NotificationService - */ public interface NotificationService { /** http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java b/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java index 17f96db..485357a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.settings.impl; -/** - * A AddressFullMessagePolicy - */ public enum AddressFullMessagePolicy { DROP, PAGE, BLOCK, FAIL; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java b/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java index 06f521b..797d200 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.version; -/** - * A VersionImpl - */ public interface Version { String getFullVersion(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java index 6fc25c6..ca5bcf6 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java @@ -21,9 +21,6 @@ import java.util.Arrays; import org.apache.activemq.core.version.Version; -/** - * A VersionImpl - */ public class VersionImpl implements Version, Serializable { private static final long serialVersionUID = -5271227256591080403L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java index 53455a9..987b55a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java @@ -19,9 +19,6 @@ package org.apache.activemq.spi.core.protocol; import java.util.concurrent.Executor; -/** - * A ConnectionEntry - */ public class ConnectionEntry { public final RemotingConnection connection; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/BufferDecoder.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/BufferDecoder.java b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/BufferDecoder.java index bb9dc75..ebaf9fc 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/BufferDecoder.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/BufferDecoder.java @@ -18,9 +18,6 @@ package org.apache.activemq.spi.core.remoting; import org.apache.activemq.api.core.ActiveMQBuffer; -/** - * A BufferDecoder - */ public interface BufferDecoder { /** http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/ReadyListener.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/ReadyListener.java b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/ReadyListener.java index 9ed24f3..f5133cf 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/ReadyListener.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/remoting/ReadyListener.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.spi.core.remoting; -/** - * A ReadyListener - */ public interface ReadyListener { void readyForWriting(boolean ready); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/ConfigurationHelper.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/ConfigurationHelper.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/ConfigurationHelper.java index 150d45a..54eea5b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/ConfigurationHelper.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/ConfigurationHelper.java @@ -25,9 +25,6 @@ import java.util.Map; import java.util.Set; -/** - * A ConfigurationHelper - */ public class ConfigurationHelper { public static String getStringProperty(final String propName, final String def, final Map<String, Object> props) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/ExecutorFactory.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/ExecutorFactory.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/ExecutorFactory.java index e3e690e..538fe9d 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/ExecutorFactory.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/ExecutorFactory.java @@ -18,9 +18,6 @@ package org.apache.activemq.utils; import java.util.concurrent.Executor; -/** - * A ExecutorFactory - */ public interface ExecutorFactory { Executor getExecutor(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/FutureLatch.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/FutureLatch.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/FutureLatch.java index 74e69a0..c52e1f2 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/FutureLatch.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/FutureLatch.java @@ -19,9 +19,6 @@ package org.apache.activemq.utils; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; -/** - * A Future - */ public class FutureLatch implements Runnable { private final CountDownLatch latch; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/LinkedList.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/LinkedList.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/LinkedList.java index bfb5f37..b24234a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/LinkedList.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/LinkedList.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.utils; -/** - * A LinkedList - */ public interface LinkedList<E> { void addHead(E e);
