gistfile1.txt

./activemq-core-client/src/main/java/org/apache/activemq/api/core/TransportConfiguration.java:            // HORNETQ-1281 - don't log passwords
./activemq-core-client/src/main/java/org/apache/activemq/api/core/UDPBroadcastEndpointFactory.java:         // HORNETQ-874
./activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java:   public static final SimpleString FORCED_DELIVERY_MESSAGE = new SimpleString("_hornetq.forced.delivery.seq");
./activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryImpl.java:      // HORNETQ-1314 - if this in an in-vm connection then disable connection monitoring
./activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManager.java:         String handshake = "HORNETQ";
./activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java:         // https://jira.jboss.org/browse/HORNETQ-522
./activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/BackwardsCompatibilityUtils.java: * This is a utility class to house any HornetQ client specific backwards compatibility methods.
./activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/BackwardsCompatibilityUtils.java:         String className = tc.getFactoryClassName().replace("org.apache.activemq", "org.hornetq").replace("ActiveMQ", "HornetQ");
./activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java:            // HORNETQ-680 - override the server-side config if client-side system properties are set
./activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java:      // HORNETQ-907 - strip off IPv6 scope-id (if necessary)
./activemq-core-client/src/main/java/org/apache/activemq/uri/TCPTransportConfigurationSchema.java:      if (uri.getPath() != null && uri.getPath().contains("hornetq"))
./activemq-core-client/src/main/java/org/apache/activemq/uri/TCPTransportConfigurationSchema.java:         return "org.hornetq.core.remoting.impl.netty.NettyConnectorFactory";
./activemq-core-client/src/main/java/org/apache/activemq/utils/LinkedListImpl.java:      //https://jira.jboss.org/browse/HORNETQ-469
./activemq-core-client/src/main/java/org/apache/activemq/utils/ObjectInputStreamWithClassLoader.java:         // HORNETQ-747 https://issues.jboss.org/browse/HORNETQ-747
./activemq-core-client/src/main/java/org/apache/activemq/utils/PriorityLinkedListImpl.java:         // Part of the fix for HORNETQ-705
./activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQJMSProducer.java:         // XXX HORNETQ-1209 "JMS 2.0" can this be a foreign msg?
./activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQMessage.java:         // https://jira.jboss.org/jira/browse/HORNETQ-356
./activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQMessage.java:         // https://jira.jboss.org/jira/browse/HORNETQ-332
./activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQMessage.java:      // XXX HORNETQ-1209 Do we need translations here?
./activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQMessageProducer.java:               // HORNETQ-1209 XXX ignore?
./activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQMessageProducer.java:               // HORNETQ-1209 XXX ignore?
./activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeImpl.java:    * transaction enlistment of the XAResource (see HORNETQ-27)
./activemq-jms-server/src/main/java/org/apache/activemq/jms/server/impl/JMSServerManagerImpl.java:         // do not clear the cachedCommands - HORNETQ-1047
./activemq-jms-server/src/main/java/org/apache/activemq/jms/server/impl/JMSServerManagerImpl.java:      // HORNETQ-911 - make this runAfterActive to prevent WARN messages on shutdown/undeployment when the backup was never activated
./activemq-jms-server/src/main/java/org/apache/activemq/jms/server/impl/JMSServerManagerImpl.java:      // HORNETQ-911 - make this runAfterActive to prevent WARN messages on shutdown/undeployment when the backup was never activated
./activemq-jms-server/src/main/java/org/apache/activemq/jms/server/impl/JMSServerManagerImpl.java:      // HORNETQ-911 - make this runAfterActive to prevent WARN messages on shutdown/undeployment when the backup was never activated
./activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalImpl.java:            // HORNETQ-482 - Flush deletes only if memory is critical
./activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java:      // Using direct buffer, as described on https://jira.jboss.org/browse/HORNETQ-467
./activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStartPlugin.java:                             String hornetqConfigurationDir) throws Exception
./activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStartPlugin.java:         control.registerNode(nodeId, workingPath, hornetqConfigurationDir);
./activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStartPlugin.java:      ObjectName name = ObjectName.getInstance("hornetq:module=test,type=TestClusterManager");
./activemq-maven-plugin/src/main/java/org/apache/activemq/maven/TestClusterManager.java:                            String hornetqConfigurationDir)
./activemq-maven-plugin/src/main/java/org/apache/activemq/maven/TestClusterManager.java:         testNodes.add(new TestNode(nodeId, workingDir, hornetqConfigurationDir));
./activemq-maven-plugin/src/main/java/org/apache/activemq/maven/TestClusterManagerMBean.java:                     String hornetqConfigurationDirt);
./activemq-maven-plugin/src/main/java/org/apache/activemq/server/ActiveMQBootstrap.java: * This will bootstrap the HornetQ Server and also the naming server if required
./activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQServerSession.java:            // HORNETQ-946
./activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAService.java: * https://jira.jboss.org/browse/HORNETQ-339
./activemq-rest/src/main/java/org/apache/activemq/rest/queue/PostMessage.java:      // HORNETQ-962
./activemq-server/src/main/java/org/apache/activemq/core/config/impl/FileConfiguration.java:      // https://jira.jboss.org/browse/HORNETQ-478 - We only want to validate AIO when
./activemq-server/src/main/java/org/apache/activemq/core/deployers/impl/FileConfigurationParser.java:   // HORNETQ-309 we keep supporting these attribute names for compatibility
./activemq-server/src/main/java/org/apache/activemq/core/deployers/impl/FileConfigurationParser.java:         // https://jira.jboss.org/jira/browse/HORNETQ-295
./activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/impl/PageSubscriptionImpl.java:         // HORNETQ-1017: There are a few cases where a pending transaction might set a big hole on the page system
./activemq-server/src/main/java/org/apache/activemq/core/paging/impl/Page.java:      // Using direct buffer, as described on https://jira.jboss.org/browse/HORNETQ-467
./activemq-server/src/main/java/org/apache/activemq/core/persistence/impl/journal/JournalStorageManager.java:         // Note: (https://issues.jboss.org/browse/HORNETQ-1059)
./activemq-server/src/main/java/org/apache/activemq/core/postoffice/impl/BindingsImpl.java:               //https://issues.jboss.org/browse/HORNETQ-1254 When !routeWhenNoConsumers,
./activemq-server/src/main/java/org/apache/activemq/core/postoffice/impl/PostOfficeImpl.java:   // HORNETQ-1029
./activemq-server/src/main/java/org/apache/activemq/core/postoffice/PostOffice.java:   // we can't start expiry scanner until the system is load otherwise we may get weird races - https://issues.jboss.org/browse/HORNETQ-1142
./activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQPacketHandler.java:         // XXX HORNETQ-720 Taylor commented out this test. Should be verified.
./activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQPacketHandler.java:         // HORNETQ-720 XXX ataylor?
./activemq-server/src/main/java/org/apache/activemq/core/protocol/ProtocolHandler.java:            // HORNETQ-1391
./activemq-server/src/main/java/org/apache/activemq/core/protocol/ProtocolHandler.java:            // See https://issues.jboss.org/browse/HORNETQ-1406
./activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterControl.java:    * XXX HORNETQ-720
./activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BroadcastGroupImpl.java:         // only log the exception at ERROR level once, even if it fails multiple times in a row - HORNETQ-919
./activemq-server/src/main/java/org/apache/activemq/core/server/impl/QueueImpl.java:      // https://issues.jboss.org/browse/HORNETQ-609
./activemq-server/src/main/java/org/apache/activemq/core/server/impl/ScaleDownHandler.java:      //todo - https://issues.jboss.org/browse/HORNETQ-1336
./activemq-server/src/main/java/org/apache/activemq/core/server/impl/ServerConsumerImpl.java:      // TODO - https://jira.jboss.org/browse/HORNETQ-533
./activemq-server/src/main/java/org/apache/activemq/core/server/impl/ServerConsumerImpl.java:         // HORNETQ-946
./activemq-server/src/main/java/org/apache/activemq/core/server/impl/ServerSessionImpl.java:      //https://issues.jboss.org/browse/HORNETQ-1141
./activemq-server/src/main/java/org/apache/activemq/core/server/impl/ServerSessionImpl.java:         // HORNETQ-946
./activemq-server/src/main/java/org/apache/activemq/core/server/impl/ServerSessionImpl.java:      // make an exception for the management address (see HORNETQ-29)
./activemq-server/src/main/java/org/apache/activemq/core/server/impl/ServerSessionImpl.java:      // make an exception for the management address (see HORNETQ-29)
./activemq-server/src/main/java/org/apache/activemq/core/server/management/impl/ManagementServiceImpl.java:               // https://jira.jboss.org/jira/browse/HORNETQ-317
./activemq-server/src/main/java/org/apache/activemq/core/settings/impl/AddressSettings.java:      // https://issues.jboss.org/browse/HORNETQ-1263
./activemq-server/src/test/java/org/apache/activemq/core/config/impl/FileConfigurationTest.java:      final File customConfiguration = File.createTempFile("hornetq-unittest", ".xml");
./activemq-server/src/test/java/org/apache/activemq/core/filter/impl/FilterTest.java://      // the server would fail at doing this when HORNETQ-545 wasn't solved
./tests/extra-tests/src/test/java/org/apache/activemq/tests/extras/jms/bridge/JMSBridgeReconnectionTest.java:    * https://jira.jboss.org/jira/browse/HORNETQ-287
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ActiveMQCrashTest.java: * From https://jira.jboss.org/jira/browse/HORNETQ-144
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerFilterTest.java:      // The server would fail to create this consumer if HORNETQ-545 wasn't solved
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerTest.java:   // https://jira.jboss.org/browse/HORNETQ-410
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerTest.java:   // https://jira.jboss.org/jira/browse/HORNETQ-111
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerTest.java:   // https://jira.jboss.org/jira/browse/HORNETQ-111
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerWindowSizeTest.java:   // https://jira.jboss.org/jira/browse/HORNETQ-385
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerWindowSizeTest.java:   // https://jira.jboss.org/jira/browse/HORNETQ-385
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerWindowSizeTest.java:   // https://jira.jboss.org/jira/browse/HORNETQ-385
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/DeadLetterAddressTest.java:   // HORNETQ- 1084
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/JmsNettyNioStressTest.java: * -- https://issues.jboss.org/browse/HORNETQ-746
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessagePriorityTest.java:   // https://jira.jboss.org/jira/browse/HORNETQ-275
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/PagingTest.java:   // https://issues.jboss.org/browse/HORNETQ-1042 - spread messages because of filters
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ReceiveImmediateTest.java:   // https://jira.jboss.org/browse/HORNETQ-450
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ReceiveImmediateTest.java:   // https://jira.jboss.org/browse/HORNETQ-450
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionTest.java:   //https://issues.jboss.org/browse/HORNETQ-1061
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionTest.java:   //https://issues.jboss.org/browse/HORNETQ-1057
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionTest.java:   // https://issues.jboss.org/browse/HORNETQ-1072
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionTest.java:    * https://jira.jboss.org/jira/browse/HORNETQ-359
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TemporaryQueueClusterTest.java:    * https://jira.jboss.org/jira/browse/HORNETQ-286
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/AsynchronousFailoverTest.java:                  // TODO: https://jira.jboss.org/jira/browse/HORNETQ-369
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/AsynchronousFailoverTest.java:                  // TODO: https://jira.jboss.org/jira/browse/HORNETQ-369
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/AsynchronousFailoverTest.java:                  // TODO: https://jira.jboss.org/jira/browse/HORNETQ-369
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java:   // https://issues.jboss.org/browse/HORNETQ-685
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java:   // https://issues.jboss.org/browse/HORNETQ-685
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java:   // https://issues.jboss.org/browse/HORNETQ-685
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java:   // https://issues.jboss.org/browse/HORNETQ-685
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java:    * see http://jira.jboss.org/browse/HORNETQ-522
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java:   // https://jira.jboss.org/jira/browse/HORNETQ-285
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java:      // HORNETQ-720 Disabling test for replicating backups.
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/LiveToLiveFailoverTest.java:   // https://jira.jboss.org/jira/browse/HORNETQ-285
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/reattach/MultiThreadRandomReattachTestBase.java:   // Added do replicate HORNETQ-264
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/topology/NonHATopologyTest.java: * Created to verify HORNETQ-913 / AS7-4548
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/client/MessageTest.java:    * @see https://jira.jboss.org/jira/browse/HORNETQ-242
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/client/MessageTest.java:   // https://issues.jboss.org/browse/HORNETQ-988
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/client/ReceiveNoWaitTest.java:    * https://jira.jboss.org/jira/browse/HORNETQ-284
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/client/RemoteConnectionStressTest.java: * test Written to replicate https://issues.jboss.org/browse/HORNETQ-1312
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/connection/ConcurrentSessionCloseTest.java:   // https://jira.jboss.org/browse/HORNETQ-525
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/connection/ConnectionFactoryWithJGroupsSerializationTest.java:   //HORNETQ-1389
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/divert/DivertAndACKClientTest.java: * https://jira.jboss.org/jira/browse/HORNETQ-165
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/jms2client/JmsContextTest.java:         // HORNETQ-1209 "JMS 2.0" XXX JMSContext javadoc says we must expect a
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/server/JMSServerStartStopTest.java:   // https://jira.jboss.org/jira/browse/HORNETQ-315
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/jms/server/management/JMSServerControl2Test.java:   //https://jira.jboss.org/browse/HORNETQ-416
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/management/ManagementActivationTest.java:    * If it was run we would receive an exception.  This is for HORNETQ-911.
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/management/ManagementActivationTest.java:    * If it was run we would receive an exception.  This is for HORNETQ-911.
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/management/ManagementActivationTest.java:    * If it was run we would receive an exception.  This is for HORNETQ-911.
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/management/QueueControlTest.java:   //https://issues.jboss.org/browse/HORNETQ-1231
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/persistence/JMSStorageManagerTest.java:   //https://issues.jboss.org/browse/HORNETQ-812
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/ssl/CoreClientOverOneWaySSLTest.java:   // see https://jira.jboss.org/jira/browse/HORNETQ-234
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/stomp/ExtraStompTest.java:      ActiveMQServer hornetQServer = addServer(ActiveMQServers.newActiveMQServer(config, defUser, defPass));
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/stomp/ExtraStompTest.java:      server = new JMSServerManagerImpl(hornetQServer, jmsConfig);
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/stomp/StompTest.java:   // HORNETQ-1007
./tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/xa/XaTimeoutTest.java:   // HORNETQ-1117 - Test that will timeout on a XA transaction and then will perform another XA operation
./tests/performance-tests/src/test/java/org/apache/activemq/tests/performance/sends/AbstractSendReceivePerfTest.java:      long numberOfSamples = Long.getLong("HORNETQ_TEST_SAMPLES", 1000);
./tests/unit-tests/src/test/java/org/apache/activemq/tests/unit/core/postoffice/impl/WildcardAddressManagerUnitTest.java: * This test is replicating the behaviour from https://issues.jboss.org/browse/HORNETQ-988.
./tests/unit-tests/src/test/java/org/apache/activemq/tests/unit/core/postoffice/impl/WildcardAddressManagerUnitTest.java:         // that was happening under https://issues.jboss.org/browse/HORNETQ-988
./tests/unit-tests/src/test/java/org/apache/activemq/tests/unit/core/postoffice/impl/WildcardAddressManagerUnitTest.java:         // that was happening under https://issues.jboss.org/browse/HORNETQ-988