http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceRecovery.java ---------------------------------------------------------------------- diff --git a/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceRecovery.java b/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceRecovery.java index 8767aa8..3616976 100644 --- a/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceRecovery.java +++ b/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceRecovery.java @@ -45,10 +45,6 @@ import org.apache.activemq.api.core.TransportConfiguration; * <property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.ACTIVEMQ2" * value="org.apache.activemq.jms.server.recovery.ActiveMQXAResourceRecovery;org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory,guest,guest,host=localhost,port=61616;org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory,guest,guest,host=localhost2,port=61617"/> * </pre> - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @version <tt>$Revision: 1.1 $</tt> */ public class ActiveMQXAResourceRecovery {
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceWrapper.java ---------------------------------------------------------------------- diff --git a/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceWrapper.java b/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceWrapper.java index b51cf24..dc3e1c8 100644 --- a/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceWrapper.java +++ b/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/ActiveMQXAResourceWrapper.java @@ -39,13 +39,6 @@ import org.apache.activemq.api.core.client.SessionFailureListener; * The reason why we don't use that class directly is that it assumes on failure of connection * the RM_FAIL or RM_ERR is thrown, but in ActiveMQ we throw XA_RETRY since we want the recovery manager to be able * to retry on failure without having to manually retry - * - * @author <a href="[email protected]">Adrian Brock</a> - * @author <a href="[email protected]">Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * - * @version $Revision: 45341 $ */ public class ActiveMQXAResourceWrapper implements XAResource, SessionFailureListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/XARecoveryConfig.java ---------------------------------------------------------------------- diff --git a/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/XARecoveryConfig.java b/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/XARecoveryConfig.java index 5225528..2f3a948 100644 --- a/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/XARecoveryConfig.java +++ b/activemq-service-extensions/src/main/java/org/apache/activemq/service/extensions/xa/recovery/XARecoveryConfig.java @@ -28,12 +28,7 @@ import org.apache.activemq.jms.client.ActiveMQConnectionFactory; * * This represents the configuration of a single connection factory. * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @author Clebert Suconic - * * A wrapper around info needed for the xa recovery resource - * Date: 3/23/11 - * Time: 10:15 AM */ public class XARecoveryConfig { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/DummyTransactionManagerLocator.java ---------------------------------------------------------------------- diff --git a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/DummyTransactionManagerLocator.java b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/DummyTransactionManagerLocator.java index d26efc3..1097031 100644 --- a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/DummyTransactionManagerLocator.java +++ b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/DummyTransactionManagerLocator.java @@ -27,9 +27,6 @@ import javax.transaction.SystemException; import javax.transaction.Transaction; import javax.transaction.TransactionManager; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - */ public class DummyTransactionManagerLocator implements TransactionManagerLocator,TransactionManager { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/TransactionManagerLocatorTest.java ---------------------------------------------------------------------- diff --git a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/TransactionManagerLocatorTest.java b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/TransactionManagerLocatorTest.java index ee4b8de..f928423 100644 --- a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/TransactionManagerLocatorTest.java +++ b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/transactions/TransactionManagerLocatorTest.java @@ -20,9 +20,6 @@ import org.apache.activemq.service.extensions.ServiceUtils; import org.junit.Assert; import org.junit.Test; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - */ public class TransactionManagerLocatorTest extends Assert { @Test http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ActiveMQXAResourceWrapperImplTest.java ---------------------------------------------------------------------- diff --git a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ActiveMQXAResourceWrapperImplTest.java b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ActiveMQXAResourceWrapperImplTest.java index 210f129..052957c 100644 --- a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ActiveMQXAResourceWrapperImplTest.java +++ b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ActiveMQXAResourceWrapperImplTest.java @@ -27,10 +27,6 @@ import org.junit.Test; import static org.jgroups.util.Util.assertEquals; -/** - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - */ - public class ActiveMQXAResourceWrapperImplTest { @Test http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockActiveMQResourceWrapperFactory.java ---------------------------------------------------------------------- diff --git a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockActiveMQResourceWrapperFactory.java b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockActiveMQResourceWrapperFactory.java index d2ee713..5933b5a 100644 --- a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockActiveMQResourceWrapperFactory.java +++ b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockActiveMQResourceWrapperFactory.java @@ -22,10 +22,6 @@ import java.util.Map; import org.apache.activemq.service.extensions.xa.ActiveMQXAResourceWrapper; import org.apache.activemq.service.extensions.xa.ActiveMQXAResourceWrapperFactory; -/** - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - */ - public class MockActiveMQResourceWrapperFactory implements ActiveMQXAResourceWrapperFactory { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockXAResource.java ---------------------------------------------------------------------- diff --git a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockXAResource.java b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockXAResource.java index 8be31e7..8651a98 100644 --- a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockXAResource.java +++ b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/MockXAResource.java @@ -20,10 +20,6 @@ import javax.transaction.xa.XAException; import javax.transaction.xa.XAResource; import javax.transaction.xa.Xid; -/** - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - */ - public class MockXAResource implements XAResource { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ServiceUtilsTest.java ---------------------------------------------------------------------- diff --git a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ServiceUtilsTest.java b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ServiceUtilsTest.java index 292255c..a278a3b 100644 --- a/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ServiceUtilsTest.java +++ b/activemq-service-extensions/src/test/java/org/apache/activemq/service/extensions/tests/xa/ServiceUtilsTest.java @@ -28,10 +28,6 @@ import org.junit.Test; import static org.jgroups.util.Util.assertTrue; -/** - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - */ - public class ServiceUtilsTest { @Test http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/ActiveMQToolsLogger.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/ActiveMQToolsLogger.java b/activemq-tools/src/main/java/org/apache/activemq/tools/ActiveMQToolsLogger.java index 20ea432..4c8e49f 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/ActiveMQToolsLogger.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/ActiveMQToolsLogger.java @@ -21,8 +21,6 @@ import org.jboss.logging.Logger; import org.jboss.logging.annotations.MessageLogger; /** - * @author Justin Bertram - * * Logger Code 24 * * each message id must be 6 digits long starting with 10, the 3rd digit donates the level so http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/DataTool.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/DataTool.java b/activemq-tools/src/main/java/org/apache/activemq/tools/DataTool.java index 8737003..8c63598 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/DataTool.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/DataTool.java @@ -24,10 +24,6 @@ import org.apache.activemq.core.journal.SequentialFileFactory; import org.apache.activemq.core.journal.impl.JournalImpl; import org.apache.activemq.core.journal.impl.NIOSequentialFileFactory; -/** - * @author Clebert Suconic - */ - public class DataTool { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/ExportJournal.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/ExportJournal.java b/activemq-tools/src/main/java/org/apache/activemq/tools/ExportJournal.java index 9e175b7..2742b0a 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/ExportJournal.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/ExportJournal.java @@ -36,8 +36,6 @@ import org.apache.activemq.utils.Base64; * If you use the main method, use it as <JournalDirectory> <JournalPrefix> <FileExtension> <MinFiles> <FileSize> <FileOutput> * <p/> * Example: java -cp activemq-tools*-jar-with-dependencies.jar export-journal /journalDir activemq-data amq 2 10485760 /tmp/export.dat - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public class ExportJournal { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/ImportJournal.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/ImportJournal.java b/activemq-tools/src/main/java/org/apache/activemq/tools/ImportJournal.java index 77a04fd..ac1e24f 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/ImportJournal.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/ImportJournal.java @@ -49,7 +49,6 @@ import org.apache.activemq.utils.Base64; * <pre> * java -cp activemq-core.jar org.apache.activemq.core.journal.impl.ExportJournal /journalDir activemq-data amq 2 10485760 /tmp/export.dat * </pre> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public class ImportJournal { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/PrintData.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/PrintData.java b/activemq-tools/src/main/java/org/apache/activemq/tools/PrintData.java index 3ff5e42..7d6ad53 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/PrintData.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/PrintData.java @@ -30,7 +30,6 @@ import org.apache.activemq.core.server.impl.FileLockNodeManager; * cd activemq-server * mvn -q exec:java -Dexec.args="/foo/activemq/bindings /foo/activemq/journal" -Dexec.mainClass="org.apache.activemq.tools.PrintData" * </pre> - * @author clebertsuconic */ public class PrintData // NO_UCD (unused code) { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/PrintPages.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/PrintPages.java b/activemq-tools/src/main/java/org/apache/activemq/tools/PrintPages.java index 459c160..be32b8d 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/PrintPages.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/PrintPages.java @@ -58,8 +58,6 @@ import org.apache.activemq.utils.ExecutorFactory; /** * A PrintPage - * - * @author clebertsuconic */ public class PrintPages // NO_UCD (unused code) { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/TransferQueue.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/TransferQueue.java b/activemq-tools/src/main/java/org/apache/activemq/tools/TransferQueue.java index dd6602a..819406b 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/TransferQueue.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/TransferQueue.java @@ -32,10 +32,6 @@ import org.apache.activemq.api.core.client.ServerLocator; import org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory; import org.apache.activemq.core.remoting.impl.netty.TransportConstants; -/** - * @author Clebert Suconic - */ - public class TransferQueue // NO_UCD (unused code) { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataConstants.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataConstants.java b/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataConstants.java index a5742f9..1da4891 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataConstants.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataConstants.java @@ -19,8 +19,6 @@ package org.apache.activemq.tools; /** * The constants shared by <code>org.apache.activemq.tools.XmlDataImporter</code> and * <code>org.apache.activemq.tools.XmlDataExporter</code>. - * - * @author Justin Bertram */ public final class XmlDataConstants { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataExporter.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataExporter.java b/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataExporter.java index 16b90e5..9aa5603 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataExporter.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataExporter.java @@ -91,8 +91,6 @@ import org.apache.activemq.utils.ExecutorFactory; * Read the journal, page, and large-message data from a stopped instance of ActiveMQ and save it in an XML format to * a file. It uses the StAX <code>javax.xml.stream.XMLStreamWriter</code> for speed and simplicity. Output can be * read by <code>org.apache.activemq.core.persistence.impl.journal.XmlDataImporter</code>. - * - * @author Justin Bertram */ public final class XmlDataExporter { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataImporter.java ---------------------------------------------------------------------- diff --git a/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataImporter.java b/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataImporter.java index e859c63..baf6a28 100644 --- a/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataImporter.java +++ b/activemq-tools/src/main/java/org/apache/activemq/tools/XmlDataImporter.java @@ -56,8 +56,6 @@ import org.apache.activemq.utils.Base64; * Read XML output from <code>org.apache.activemq.core.persistence.impl.journal.XmlDataExporter</code>, create a core session, and * send the messages to a running instance of ActiveMQ. It uses the StAX <code>javax.xml.stream.XMLStreamReader</code> * for speed and simplicity. - * - * @author Justin Bertram */ public final class XmlDataImporter { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/etc/checkstyle.xml ---------------------------------------------------------------------- diff --git a/etc/checkstyle.xml b/etc/checkstyle.xml index d13fdd2..cd189c4 100644 --- a/etc/checkstyle.xml +++ b/etc/checkstyle.xml @@ -103,5 +103,11 @@ under the License. <property name="requiredParameters" value="name"/> </module> + <module name="WriteTag"> + <property name="tag" value="@author"/> + <property name="tagSeverity" value="error"/> + <property name="severity" value="ignore"/> + </module> + </module> </module> http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedRemoteExample.java ---------------------------------------------------------------------- diff --git a/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedRemoteExample.java b/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedRemoteExample.java index 9842615..ed9fa8d 100644 --- a/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedRemoteExample.java +++ b/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedRemoteExample.java @@ -34,9 +34,6 @@ import org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory; * * This example shows how to run a ActiveMQ core client and server embedded in your * own application - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class EmbeddedRemoteExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedServer.java ---------------------------------------------------------------------- diff --git a/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedServer.java b/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedServer.java index ccf8975..f6500c3 100644 --- a/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedServer.java +++ b/examples/core/embedded-remote/src/main/java/org/apache/activemq/core/example/EmbeddedServer.java @@ -29,7 +29,6 @@ import org.apache.activemq.core.server.ActiveMQServers; /** * An EmbeddedServer - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public class EmbeddedServer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/core/embedded/src/main/java/org/apache/activemq/core/example/EmbeddedExample.java ---------------------------------------------------------------------- diff --git a/examples/core/embedded/src/main/java/org/apache/activemq/core/example/EmbeddedExample.java b/examples/core/embedded/src/main/java/org/apache/activemq/core/example/EmbeddedExample.java index 2b9e821..c8d5405 100644 --- a/examples/core/embedded/src/main/java/org/apache/activemq/core/example/EmbeddedExample.java +++ b/examples/core/embedded/src/main/java/org/apache/activemq/core/example/EmbeddedExample.java @@ -37,9 +37,6 @@ import org.apache.activemq.core.server.ActiveMQServers; * * This example shows how to run a ActiveMQ core client and server embedded in your * own application - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class EmbeddedExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfBase.java ---------------------------------------------------------------------- diff --git a/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfBase.java b/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfBase.java index 6dd0d2a..a6107f1 100644 --- a/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfBase.java +++ b/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfBase.java @@ -45,10 +45,6 @@ import org.apache.activemq.utils.TokenBucketLimiterImpl; /** * * A PerfBase - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public abstract class PerfBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfListener.java ---------------------------------------------------------------------- diff --git a/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfListener.java b/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfListener.java index 70605ec..70daa9c 100644 --- a/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfListener.java +++ b/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfListener.java @@ -19,12 +19,7 @@ package org.apache.activemq.core.example; import java.util.logging.Logger; /** - * * A PerfListener - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public class PerfListener extends PerfBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfParams.java ---------------------------------------------------------------------- diff --git a/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfParams.java b/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfParams.java index e162413..38094b2 100644 --- a/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfParams.java +++ b/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfParams.java @@ -19,10 +19,7 @@ package org.apache.activemq.core.example; import java.io.Serializable; /** - * * Class that holds the parameters used in the performance examples - * - * @author <a href="[email protected]">Andy Taylor</a> */ public class PerfParams implements Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfSender.java ---------------------------------------------------------------------- diff --git a/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfSender.java b/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfSender.java index eeb42f8..12edb55 100644 --- a/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfSender.java +++ b/examples/core/perf/src/main/java/org/apache/activemq/core/example/PerfSender.java @@ -19,12 +19,7 @@ package org.apache.activemq.core.example; import java.util.logging.Logger; /** - * * A PerfSender - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public class PerfSender extends PerfBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/core/vertx-connector/src/main/java/org/apache/activemq/core/example/VertxConnectorExample.java ---------------------------------------------------------------------- diff --git a/examples/core/vertx-connector/src/main/java/org/apache/activemq/core/example/VertxConnectorExample.java b/examples/core/vertx-connector/src/main/java/org/apache/activemq/core/example/VertxConnectorExample.java index b146998..dceca41 100644 --- a/examples/core/vertx-connector/src/main/java/org/apache/activemq/core/example/VertxConnectorExample.java +++ b/examples/core/vertx-connector/src/main/java/org/apache/activemq/core/example/VertxConnectorExample.java @@ -30,8 +30,6 @@ import org.vertx.java.spi.cluster.impl.hazelcast.HazelcastClusterManagerFactory; /** * A simple example of using Vert.x connector service. - * - * @author <a href="[email protected]">Howard Gao</a> */ public class VertxConnectorExample { @@ -60,7 +58,7 @@ public class VertxConnectorExample // Step 2 Deploy a Verticle to receive message String verticle = "org.apache.activemq.core.example.ExampleVerticle"; - platformManager.deployVerticle(verticle, null, new URL[0], 1, null, + platformManager.deployVerticle(verticle, null, new URL[0], 1, null, new Handler<AsyncResult<String>>(){ @Override @@ -72,7 +70,7 @@ public class VertxConnectorExample } latch0.countDown(); } - + }); latch0.await(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/ActiveMQExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/ActiveMQExample.java b/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/ActiveMQExample.java index fcfbfc4..c94be4e 100644 --- a/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/ActiveMQExample.java +++ b/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/ActiveMQExample.java @@ -38,8 +38,6 @@ import org.apache.activemq.jms.client.ActiveMQConnectionFactory; * <p> * This takes care of starting and stopping the server as well as deploying any * queue needed. - * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> */ public abstract class ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/DummyXid.java ---------------------------------------------------------------------- diff --git a/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/DummyXid.java b/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/DummyXid.java index 036fe24..6625227 100644 --- a/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/DummyXid.java +++ b/examples/jms/activemq-jms-examples-common/src/main/java/org/apache/activemq/common/example/DummyXid.java @@ -20,9 +20,6 @@ import javax.transaction.xa.Xid; import org.apache.activemq.utils.Base64; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - */ public class DummyXid implements Xid { private static final long serialVersionUID = 407053232840068514L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/aerogear/src/main/java/org/apache/activemq/jms/example/AerogearExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/aerogear/src/main/java/org/apache/activemq/jms/example/AerogearExample.java b/examples/jms/aerogear/src/main/java/org/apache/activemq/jms/example/AerogearExample.java index 2c47863..d7cd36a 100644 --- a/examples/jms/aerogear/src/main/java/org/apache/activemq/jms/example/AerogearExample.java +++ b/examples/jms/aerogear/src/main/java/org/apache/activemq/jms/example/AerogearExample.java @@ -30,8 +30,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message. - * - * @author <a href="[email protected]">Andy Taylor</a> */ public class AerogearExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/application-layer-failover/src/main/java/org/apache/activemq/jms/example/ApplicationLayerFailoverExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/application-layer-failover/src/main/java/org/apache/activemq/jms/example/ApplicationLayerFailoverExample.java b/examples/jms/application-layer-failover/src/main/java/org/apache/activemq/jms/example/ApplicationLayerFailoverExample.java index 9051ba7..345764f 100644 --- a/examples/jms/application-layer-failover/src/main/java/org/apache/activemq/jms/example/ApplicationLayerFailoverExample.java +++ b/examples/jms/application-layer-failover/src/main/java/org/apache/activemq/jms/example/ApplicationLayerFailoverExample.java @@ -38,8 +38,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example that demonstrates application-layer failover of the JMS connection from one node to another * when the live server crashes - * - * @author <a href="[email protected]>Tim Fox</a> */ public class ApplicationLayerFailoverExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/BridgeExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/BridgeExample.java b/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/BridgeExample.java index 45d3951..ce51d55 100644 --- a/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/BridgeExample.java +++ b/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/BridgeExample.java @@ -32,8 +32,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * This example demonstrates a core bridge set-up between two nodes, consuming messages from a queue * on one node and forwarding them to an address on the second node. - * - * @author <a href="[email protected]>Tim Fox</a> */ public class BridgeExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/HatColourChangeTransformer.java ---------------------------------------------------------------------- diff --git a/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/HatColourChangeTransformer.java b/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/HatColourChangeTransformer.java index 4a8be2a..b2dd485 100644 --- a/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/HatColourChangeTransformer.java +++ b/examples/jms/bridge/src/main/java/org/apache/activemq/jms/example/HatColourChangeTransformer.java @@ -22,10 +22,6 @@ import org.apache.activemq.core.server.cluster.Transformer; /** * A HatColourChangeTransformer - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public class HatColourChangeTransformer implements Transformer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/browser/src/main/java/org/apache/activemq/jms/example/QueueBrowserExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/browser/src/main/java/org/apache/activemq/jms/example/QueueBrowserExample.java b/examples/jms/browser/src/main/java/org/apache/activemq/jms/example/QueueBrowserExample.java index 729ea8d..98405c9 100644 --- a/examples/jms/browser/src/main/java/org/apache/activemq/jms/example/QueueBrowserExample.java +++ b/examples/jms/browser/src/main/java/org/apache/activemq/jms/example/QueueBrowserExample.java @@ -32,10 +32,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example which shows how to use a QueueBrowser to look at messages of a queue without removing them from the queue - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * - * */ public class QueueBrowserExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/client-kickoff/src/main/java/org/apache/activemq/jms/example/ClientKickoffExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/client-kickoff/src/main/java/org/apache/activemq/jms/example/ClientKickoffExample.java b/examples/jms/client-kickoff/src/main/java/org/apache/activemq/jms/example/ClientKickoffExample.java index c9864c3..014a7d4 100644 --- a/examples/jms/client-kickoff/src/main/java/org/apache/activemq/jms/example/ClientKickoffExample.java +++ b/examples/jms/client-kickoff/src/main/java/org/apache/activemq/jms/example/ClientKickoffExample.java @@ -37,8 +37,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * An example that shows how to kick off a client connected to ActiveMQ by using JMX. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class ClientKickoffExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/client-side-failoverlistener/src/main/java/org/apache/activemq/jms/example/ClientSideFailoverListerExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/client-side-failoverlistener/src/main/java/org/apache/activemq/jms/example/ClientSideFailoverListerExample.java b/examples/jms/client-side-failoverlistener/src/main/java/org/apache/activemq/jms/example/ClientSideFailoverListerExample.java index 07f2fe8..2e7eb3b 100644 --- a/examples/jms/client-side-failoverlistener/src/main/java/org/apache/activemq/jms/example/ClientSideFailoverListerExample.java +++ b/examples/jms/client-side-failoverlistener/src/main/java/org/apache/activemq/jms/example/ClientSideFailoverListerExample.java @@ -35,8 +35,6 @@ import org.apache.activemq.jms.client.ActiveMQConnection; * * In this example there are two nodes running in a cluster, both server will be running for start, * but after a while the first server will crash. This will trigger an fail oever event - * - * @author <a href="[email protected]>Flemming Harms</a> */ public class ClientSideFailoverListerExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/client-side-load-balancing/src/main/java/org/apache/activemq/jms/example/ClientSideLoadBalancingExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/client-side-load-balancing/src/main/java/org/apache/activemq/jms/example/ClientSideLoadBalancingExample.java b/examples/jms/client-side-load-balancing/src/main/java/org/apache/activemq/jms/example/ClientSideLoadBalancingExample.java index 1536107..98eea5e 100644 --- a/examples/jms/client-side-load-balancing/src/main/java/org/apache/activemq/jms/example/ClientSideLoadBalancingExample.java +++ b/examples/jms/client-side-load-balancing/src/main/java/org/apache/activemq/jms/example/ClientSideLoadBalancingExample.java @@ -34,8 +34,6 @@ import org.apache.activemq.common.example.ActiveMQExample; * * In this example there are three nodes and we use a round-robin client side load-balancing * policy. - * - * @author <a href="[email protected]>Tim Fox</a> */ public class ClientSideLoadBalancingExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/clustered-durable-subscription/src/main/java/org/apache/activemq/jms/example/ClusteredDurableSubscriptionExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/clustered-durable-subscription/src/main/java/org/apache/activemq/jms/example/ClusteredDurableSubscriptionExample.java b/examples/jms/clustered-durable-subscription/src/main/java/org/apache/activemq/jms/example/ClusteredDurableSubscriptionExample.java index 4e4afc0..5f2b9ed 100644 --- a/examples/jms/clustered-durable-subscription/src/main/java/org/apache/activemq/jms/example/ClusteredDurableSubscriptionExample.java +++ b/examples/jms/clustered-durable-subscription/src/main/java/org/apache/activemq/jms/example/ClusteredDurableSubscriptionExample.java @@ -34,8 +34,6 @@ import org.apache.activemq.common.example.ActiveMQExample; * * The same durable subscription can exist on more than one node of the cluster, and messages * sent to the topic will be load-balanced in a round-robin fashion between the two nodes - * - * @author <a href="[email protected]>Tim Fox</a> */ public class ClusteredDurableSubscriptionExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/clustered-grouping/src/main/java/org/apache/activemq/jms/example/ClusteredGroupingExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/clustered-grouping/src/main/java/org/apache/activemq/jms/example/ClusteredGroupingExample.java b/examples/jms/clustered-grouping/src/main/java/org/apache/activemq/jms/example/ClusteredGroupingExample.java index 869f5ed..5e7bccd 100644 --- a/examples/jms/clustered-grouping/src/main/java/org/apache/activemq/jms/example/ClusteredGroupingExample.java +++ b/examples/jms/clustered-grouping/src/main/java/org/apache/activemq/jms/example/ClusteredGroupingExample.java @@ -32,8 +32,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example that demonstrates server side load-balancing of messages between the queue instances on different * nodes of the cluster. - * - * @author <a href="[email protected]>Tim Fox</a> */ public class ClusteredGroupingExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/clustered-jgroups/src/main/java/org/apache/activemq/jms/example/ClusteredJgroupsExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/clustered-jgroups/src/main/java/org/apache/activemq/jms/example/ClusteredJgroupsExample.java b/examples/jms/clustered-jgroups/src/main/java/org/apache/activemq/jms/example/ClusteredJgroupsExample.java index bdf6699..226c7f2 100644 --- a/examples/jms/clustered-jgroups/src/main/java/org/apache/activemq/jms/example/ClusteredJgroupsExample.java +++ b/examples/jms/clustered-jgroups/src/main/java/org/apache/activemq/jms/example/ClusteredJgroupsExample.java @@ -31,9 +31,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example that demonstrates clustering using jgroups. - * - * @author <a href="[email protected]>Tim Fox</a> - * @author <a href="[email protected]>Howard Gao</a> */ public class ClusteredJgroupsExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/clustered-queue/src/main/java/org/apache/activemq/jms/example/ClusteredQueueExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/clustered-queue/src/main/java/org/apache/activemq/jms/example/ClusteredQueueExample.java b/examples/jms/clustered-queue/src/main/java/org/apache/activemq/jms/example/ClusteredQueueExample.java index bdc8be3..9e4c021 100644 --- a/examples/jms/clustered-queue/src/main/java/org/apache/activemq/jms/example/ClusteredQueueExample.java +++ b/examples/jms/clustered-queue/src/main/java/org/apache/activemq/jms/example/ClusteredQueueExample.java @@ -32,8 +32,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example that demonstrates server side load-balancing of messages between the queue instances on different * nodes of the cluster. - * - * @author <a href="[email protected]>Tim Fox</a> */ public class ClusteredQueueExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/clustered-standalone/src/main/java/org/apache/activemq/jms/example/ClusteredStandaloneExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/clustered-standalone/src/main/java/org/apache/activemq/jms/example/ClusteredStandaloneExample.java b/examples/jms/clustered-standalone/src/main/java/org/apache/activemq/jms/example/ClusteredStandaloneExample.java index 60dc7d3..6ca3f8b 100644 --- a/examples/jms/clustered-standalone/src/main/java/org/apache/activemq/jms/example/ClusteredStandaloneExample.java +++ b/examples/jms/clustered-standalone/src/main/java/org/apache/activemq/jms/example/ClusteredStandaloneExample.java @@ -29,9 +29,6 @@ import javax.naming.InitialContext; import org.apache.activemq.common.example.ActiveMQExample; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class ClusteredStandaloneExample extends ActiveMQExample { public static void main(final String[] args) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/clustered-static-discovery/src/main/java/org/apache/activemq/jms/example/StaticClusteredQueueExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/clustered-static-discovery/src/main/java/org/apache/activemq/jms/example/StaticClusteredQueueExample.java b/examples/jms/clustered-static-discovery/src/main/java/org/apache/activemq/jms/example/StaticClusteredQueueExample.java index e587536..9e2d5f3 100644 --- a/examples/jms/clustered-static-discovery/src/main/java/org/apache/activemq/jms/example/StaticClusteredQueueExample.java +++ b/examples/jms/clustered-static-discovery/src/main/java/org/apache/activemq/jms/example/StaticClusteredQueueExample.java @@ -32,8 +32,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example that demonstrates server side load-balancing of messages between the queue instances on different * nodes of the cluster. The cluster is created from a static list of nodes. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class StaticClusteredQueueExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/clustered-static-oneway/src/main/java/org/apache/activemq/jms/example/ClusterStaticOnewayExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/clustered-static-oneway/src/main/java/org/apache/activemq/jms/example/ClusterStaticOnewayExample.java b/examples/jms/clustered-static-oneway/src/main/java/org/apache/activemq/jms/example/ClusterStaticOnewayExample.java index 0ddefeb..8d2af35 100644 --- a/examples/jms/clustered-static-oneway/src/main/java/org/apache/activemq/jms/example/ClusterStaticOnewayExample.java +++ b/examples/jms/clustered-static-oneway/src/main/java/org/apache/activemq/jms/example/ClusterStaticOnewayExample.java @@ -32,8 +32,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example that demonstrates server side load-balancing of messages between the queue instances on different * nodes of the cluster. The cluster is created from a static list of nodes. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class ClusterStaticOnewayExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/clustered-topic/src/main/java/org/apache/activemq/jms/example/ClusteredTopicExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/clustered-topic/src/main/java/org/apache/activemq/jms/example/ClusteredTopicExample.java b/examples/jms/clustered-topic/src/main/java/org/apache/activemq/jms/example/ClusteredTopicExample.java index 61e3d65..6ad2e86 100644 --- a/examples/jms/clustered-topic/src/main/java/org/apache/activemq/jms/example/ClusteredTopicExample.java +++ b/examples/jms/clustered-topic/src/main/java/org/apache/activemq/jms/example/ClusteredTopicExample.java @@ -32,8 +32,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example that shows a JMS Topic clustered across two nodes of a cluster. * Messages are sent on one node and received by consumers on both nodes. - * - * @author <a href="[email protected]>Tim Fox</a> */ public class ClusteredTopicExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/jms/example/ColocatedFailoverScaleDownExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/jms/example/ColocatedFailoverScaleDownExample.java b/examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/jms/example/ColocatedFailoverScaleDownExample.java index bc23589..af381fb 100644 --- a/examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/jms/example/ColocatedFailoverScaleDownExample.java +++ b/examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/jms/example/ColocatedFailoverScaleDownExample.java @@ -32,8 +32,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example that demonstrates server side load-balancing of messages between the queue instances on different * nodes of the cluster. - * - * @author <a href="[email protected]>Tim Fox</a> */ public class ColocatedFailoverScaleDownExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/consumer-rate-limit/src/main/java/org/apache/activemq/jms/example/ConsumerRateLimitExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/consumer-rate-limit/src/main/java/org/apache/activemq/jms/example/ConsumerRateLimitExample.java b/examples/jms/consumer-rate-limit/src/main/java/org/apache/activemq/jms/example/ConsumerRateLimitExample.java index 4121685..a4abd9f 100644 --- a/examples/jms/consumer-rate-limit/src/main/java/org/apache/activemq/jms/example/ConsumerRateLimitExample.java +++ b/examples/jms/consumer-rate-limit/src/main/java/org/apache/activemq/jms/example/ConsumerRateLimitExample.java @@ -30,8 +30,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * This example demonstrates how a message consumer can be limited to consumer messages at a maximum rate * specified in messages per sec. - * - * @author <a href="[email protected]">Tim Fox</a> */ public class ConsumerRateLimitExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/dead-letter/src/main/java/org/apache/activemq/jms/example/DeadLetterExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/dead-letter/src/main/java/org/apache/activemq/jms/example/DeadLetterExample.java b/examples/jms/dead-letter/src/main/java/org/apache/activemq/jms/example/DeadLetterExample.java index d38cebe..38f176c 100644 --- a/examples/jms/dead-letter/src/main/java/org/apache/activemq/jms/example/DeadLetterExample.java +++ b/examples/jms/dead-letter/src/main/java/org/apache/activemq/jms/example/DeadLetterExample.java @@ -29,9 +29,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * An example showing how messages are moved to dead letter destination when they are unsuccessfully delivered multiple times - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * */ public class DeadLetterExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/delayed-redelivery/src/main/java/org/apache/activemq/jms/example/DelayedRedeliveryExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/delayed-redelivery/src/main/java/org/apache/activemq/jms/example/DelayedRedeliveryExample.java b/examples/jms/delayed-redelivery/src/main/java/org/apache/activemq/jms/example/DelayedRedeliveryExample.java index 886dcff..3651232 100644 --- a/examples/jms/delayed-redelivery/src/main/java/org/apache/activemq/jms/example/DelayedRedeliveryExample.java +++ b/examples/jms/delayed-redelivery/src/main/java/org/apache/activemq/jms/example/DelayedRedeliveryExample.java @@ -32,9 +32,6 @@ import org.apache.activemq.common.example.ActiveMQExample; * is redelivered. * * Please see the readme.html for more information - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class DelayedRedeliveryExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/AddForwardingTimeTransformer.java ---------------------------------------------------------------------- diff --git a/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/AddForwardingTimeTransformer.java b/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/AddForwardingTimeTransformer.java index c78b182..6a163d7 100644 --- a/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/AddForwardingTimeTransformer.java +++ b/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/AddForwardingTimeTransformer.java @@ -22,10 +22,6 @@ import org.apache.activemq.core.server.cluster.Transformer; /** * A AddForwardingTimeTransformer - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public class AddForwardingTimeTransformer implements Transformer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/DivertExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/DivertExample.java b/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/DivertExample.java index 4f197ce..8347bb4 100644 --- a/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/DivertExample.java +++ b/examples/jms/divert/src/main/java/org/apache/activemq/jms/example/DivertExample.java @@ -36,8 +36,6 @@ import org.apache.activemq.common.example.ActiveMQExample; * from one address to another. * * Please see the readme.html for more information. - * - * @author <a href="[email protected]">Tim Fox</a> */ public class DivertExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/durable-subscription/src/main/java/org/apache/activemq/jms/example/DurableSubscriptionExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/durable-subscription/src/main/java/org/apache/activemq/jms/example/DurableSubscriptionExample.java b/examples/jms/durable-subscription/src/main/java/org/apache/activemq/jms/example/DurableSubscriptionExample.java index 5c88b01..9274258 100644 --- a/examples/jms/durable-subscription/src/main/java/org/apache/activemq/jms/example/DurableSubscriptionExample.java +++ b/examples/jms/durable-subscription/src/main/java/org/apache/activemq/jms/example/DurableSubscriptionExample.java @@ -29,8 +29,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS example that shows how to use a durable subscription. - * - * @author <a href="[email protected]">Howard Gao</a> */ public class DurableSubscriptionExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/embedded-simple/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/embedded-simple/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java b/examples/jms/embedded-simple/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java index 8ef78fa..008a604 100644 --- a/examples/jms/embedded-simple/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java +++ b/examples/jms/embedded-simple/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java @@ -35,9 +35,6 @@ import org.apache.activemq.api.jms.JMSFactoryType; /** * This example demonstrates how to run a ActiveMQ embedded with JMS - * - * @author <a href="[email protected]">Clebert Suconic</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class EmbeddedExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/embedded/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/embedded/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java b/examples/jms/embedded/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java index a89c7b4..a2776d9 100644 --- a/examples/jms/embedded/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java +++ b/examples/jms/embedded/src/main/java/org/apache/activemq/jms/example/EmbeddedExample.java @@ -43,10 +43,6 @@ import org.apache.activemq.jms.server.embedded.EmbeddedJMS; /** * This example demonstrates how to run a ActiveMQ embedded with JMS - * - * @author <a href="[email protected]">Clebert Suconic</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Bill Burke</a> */ public final class EmbeddedExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/expiry/src/main/java/org/apache/activemq/jms/example/ExpiryExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/expiry/src/main/java/org/apache/activemq/jms/example/ExpiryExample.java b/examples/jms/expiry/src/main/java/org/apache/activemq/jms/example/ExpiryExample.java index 02e3963..3f0064e 100644 --- a/examples/jms/expiry/src/main/java/org/apache/activemq/jms/example/ExpiryExample.java +++ b/examples/jms/expiry/src/main/java/org/apache/activemq/jms/example/ExpiryExample.java @@ -29,9 +29,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * An example showing how messages are moved to an expiry queue when they expire. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * */ public class ExpiryExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java b/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java index 914c017..6477b6b 100644 --- a/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java +++ b/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java @@ -29,8 +29,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS Queue example that uses HTTP protocol. - * - * @author <a href="[email protected]">Howard Gao</a> */ public class HttpTransportExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/instantiate-connection-factory/src/main/java/org/apache/activemq/jms/example/InstantiateConnectionFactoryExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/instantiate-connection-factory/src/main/java/org/apache/activemq/jms/example/InstantiateConnectionFactoryExample.java b/examples/jms/instantiate-connection-factory/src/main/java/org/apache/activemq/jms/example/InstantiateConnectionFactoryExample.java index 4459f7e..c7febed 100644 --- a/examples/jms/instantiate-connection-factory/src/main/java/org/apache/activemq/jms/example/InstantiateConnectionFactoryExample.java +++ b/examples/jms/instantiate-connection-factory/src/main/java/org/apache/activemq/jms/example/InstantiateConnectionFactoryExample.java @@ -40,9 +40,6 @@ import org.apache.activemq.core.remoting.impl.netty.TransportConstants; * Queue, ConnectionFactory, etc. without having to use JNDI at all. * * For more information please see the readme.html file. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class InstantiateConnectionFactoryExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java b/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java index 70f0231..0a56600 100644 --- a/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java +++ b/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java @@ -29,8 +29,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS example that shows how to implement and use interceptors with ActiveMQ. - * - * @author <a href="[email protected]">Howard Gao</a> */ public class InterceptorExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/SimpleInterceptor.java ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/SimpleInterceptor.java b/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/SimpleInterceptor.java index ef15c17..7043164 100644 --- a/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/SimpleInterceptor.java +++ b/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/SimpleInterceptor.java @@ -26,8 +26,6 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection; /** * A simple Interceptor implementation - * - * @author <a href="[email protected]">Howard Gao</a> */ public class SimpleInterceptor implements Interceptor { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java b/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java index 646fdeb..2d60d00 100644 --- a/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java +++ b/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java @@ -23,8 +23,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS example that shows how AutoCloseable is used by JMS 2 resources. - * - * @author <a href="[email protected]">Andy Taylor</a> */ public class JMSAutoCloseableExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java b/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java index 83b4228..e531941 100644 --- a/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java +++ b/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java @@ -38,8 +38,6 @@ import javax.naming.InitialContext; * An example which sends a message to a source topic and consume from a target queue. * The source and target destinations are located on 2 different ActiveMQ server. * The source and target queues are bridged by a JMS Bridge configured and running on the "target" server. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class JMSBridgeExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/jms-completion-listener/src/main/java/org/apache/activemq/jms/example/JMSCompletionListenerExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/jms-completion-listener/src/main/java/org/apache/activemq/jms/example/JMSCompletionListenerExample.java b/examples/jms/jms-completion-listener/src/main/java/org/apache/activemq/jms/example/JMSCompletionListenerExample.java index af5b13d..7b2b108 100644 --- a/examples/jms/jms-completion-listener/src/main/java/org/apache/activemq/jms/example/JMSCompletionListenerExample.java +++ b/examples/jms/jms-completion-listener/src/main/java/org/apache/activemq/jms/example/JMSCompletionListenerExample.java @@ -31,8 +31,6 @@ import java.util.concurrent.TimeUnit; /** * A JMS Completion Listener Example. - * - * @author <a href="[email protected]">Andy Taylor</a> */ public class JMSCompletionListenerExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/jms-context/src/main/java/org/apache/activemq/jms/example/JMSContextExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/jms-context/src/main/java/org/apache/activemq/jms/example/JMSContextExample.java b/examples/jms/jms-context/src/main/java/org/apache/activemq/jms/example/JMSContextExample.java index 616574b..e888426 100644 --- a/examples/jms/jms-context/src/main/java/org/apache/activemq/jms/example/JMSContextExample.java +++ b/examples/jms/jms-context/src/main/java/org/apache/activemq/jms/example/JMSContextExample.java @@ -26,8 +26,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message. - * - * @author <a href="[email protected]">Andy Taylor</a> */ public class JMSContextExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/jms-shared-consumer/src/main/java/org/apache/activemq/jms/example/JMSSharedConsumerExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/jms-shared-consumer/src/main/java/org/apache/activemq/jms/example/JMSSharedConsumerExample.java b/examples/jms/jms-shared-consumer/src/main/java/org/apache/activemq/jms/example/JMSSharedConsumerExample.java index 23d72ca..f394d9a 100644 --- a/examples/jms/jms-shared-consumer/src/main/java/org/apache/activemq/jms/example/JMSSharedConsumerExample.java +++ b/examples/jms/jms-shared-consumer/src/main/java/org/apache/activemq/jms/example/JMSSharedConsumerExample.java @@ -33,8 +33,6 @@ import java.util.concurrent.TimeUnit; /** * A JMS Example that uses shared consumers. - * - * @author <a href="[email protected]">Andy Taylor</a> */ public class JMSSharedConsumerExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/jmx/src/main/java/org/apache/activemq/jms/example/JMXExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/jmx/src/main/java/org/apache/activemq/jms/example/JMXExample.java b/examples/jms/jmx/src/main/java/org/apache/activemq/jms/example/JMXExample.java index 6027479..b88402c 100644 --- a/examples/jms/jmx/src/main/java/org/apache/activemq/jms/example/JMXExample.java +++ b/examples/jms/jmx/src/main/java/org/apache/activemq/jms/example/JMXExample.java @@ -40,8 +40,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * An example that shows how to manage ActiveMQ using JMX. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class JMXExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/large-message/src/main/java/org/apache/activemq/jms/example/LargeMessageExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/large-message/src/main/java/org/apache/activemq/jms/example/LargeMessageExample.java b/examples/jms/large-message/src/main/java/org/apache/activemq/jms/example/LargeMessageExample.java index 2b9bf0e..c6796d3 100644 --- a/examples/jms/large-message/src/main/java/org/apache/activemq/jms/example/LargeMessageExample.java +++ b/examples/jms/large-message/src/main/java/org/apache/activemq/jms/example/LargeMessageExample.java @@ -38,9 +38,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * This example demonstrates the ability of ActiveMQ to send and consume a very large message, much * bigger than can fit in RAM. - * - * @author <a href="[email protected]">Tim Fox</a> - * @author <a href="[email protected]">Clebert Suconic</a> */ public class LargeMessageExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/last-value-queue/src/main/java/org/apache/activemq/jms/example/LastValueQueueExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/last-value-queue/src/main/java/org/apache/activemq/jms/example/LastValueQueueExample.java b/examples/jms/last-value-queue/src/main/java/org/apache/activemq/jms/example/LastValueQueueExample.java index be7992a..7805749 100644 --- a/examples/jms/last-value-queue/src/main/java/org/apache/activemq/jms/example/LastValueQueueExample.java +++ b/examples/jms/last-value-queue/src/main/java/org/apache/activemq/jms/example/LastValueQueueExample.java @@ -33,9 +33,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * This example shows how to configure and use a <em>Last-Value</em> queues. * Only the last message with a well-defined property is hold by the queue. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * */ public class LastValueQueueExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/management-notifications/src/main/java/org/apache/activemq/jms/example/ManagementNotificationExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/management-notifications/src/main/java/org/apache/activemq/jms/example/ManagementNotificationExample.java b/examples/jms/management-notifications/src/main/java/org/apache/activemq/jms/example/ManagementNotificationExample.java index de631dc..23c2a4a 100644 --- a/examples/jms/management-notifications/src/main/java/org/apache/activemq/jms/example/ManagementNotificationExample.java +++ b/examples/jms/management-notifications/src/main/java/org/apache/activemq/jms/example/ManagementNotificationExample.java @@ -34,8 +34,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * An example that shows how to receive management notifications using JMS messages. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class ManagementNotificationExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/management/src/main/java/org/apache/activemq/jms/example/ManagementExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/management/src/main/java/org/apache/activemq/jms/example/ManagementExample.java b/examples/jms/management/src/main/java/org/apache/activemq/jms/example/ManagementExample.java index fd83ed0..8b8dc46 100644 --- a/examples/jms/management/src/main/java/org/apache/activemq/jms/example/ManagementExample.java +++ b/examples/jms/management/src/main/java/org/apache/activemq/jms/example/ManagementExample.java @@ -34,8 +34,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * An example that shows how to manage ActiveMQ using JMS messages. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class ManagementExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/message-counters/src/main/java/org/apache/activemq/jms/example/MessageCounterExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/message-counters/src/main/java/org/apache/activemq/jms/example/MessageCounterExample.java b/examples/jms/message-counters/src/main/java/org/apache/activemq/jms/example/MessageCounterExample.java index 92843ca..2b4dcf9 100644 --- a/examples/jms/message-counters/src/main/java/org/apache/activemq/jms/example/MessageCounterExample.java +++ b/examples/jms/message-counters/src/main/java/org/apache/activemq/jms/example/MessageCounterExample.java @@ -41,9 +41,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * An example showing how to use message counters to have information on a queue. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * */ public class MessageCounterExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/message-group/src/main/java/org/apache/activemq/jms/example/MessageGroupExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/message-group/src/main/java/org/apache/activemq/jms/example/MessageGroupExample.java b/examples/jms/message-group/src/main/java/org/apache/activemq/jms/example/MessageGroupExample.java index 02b46d6..bf9c16d 100644 --- a/examples/jms/message-group/src/main/java/org/apache/activemq/jms/example/MessageGroupExample.java +++ b/examples/jms/message-group/src/main/java/org/apache/activemq/jms/example/MessageGroupExample.java @@ -35,8 +35,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS Queue example that sends and receives message groups. - * - * @author <a href="[email protected]">Howard Gao</a> */ public class MessageGroupExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/message-group2/src/main/java/org/apache/activemq/jms/example/MessageGroup2Example.java ---------------------------------------------------------------------- diff --git a/examples/jms/message-group2/src/main/java/org/apache/activemq/jms/example/MessageGroup2Example.java b/examples/jms/message-group2/src/main/java/org/apache/activemq/jms/example/MessageGroup2Example.java index 043c2bc..30c75a5 100644 --- a/examples/jms/message-group2/src/main/java/org/apache/activemq/jms/example/MessageGroup2Example.java +++ b/examples/jms/message-group2/src/main/java/org/apache/activemq/jms/example/MessageGroup2Example.java @@ -35,8 +35,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS Queue example that sends and receives message groups. - * - * @author <a href="[email protected]">Howard Gao</a> */ public class MessageGroup2Example extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/message-priority/src/main/java/org/apache/activemq/jms/example/MessagePriorityExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/message-priority/src/main/java/org/apache/activemq/jms/example/MessagePriorityExample.java b/examples/jms/message-priority/src/main/java/org/apache/activemq/jms/example/MessagePriorityExample.java index ee0e791..5ce815f 100644 --- a/examples/jms/message-priority/src/main/java/org/apache/activemq/jms/example/MessagePriorityExample.java +++ b/examples/jms/message-priority/src/main/java/org/apache/activemq/jms/example/MessagePriorityExample.java @@ -35,8 +35,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS example that shows the delivery order of messages with priorities. - * - * @author <a href="[email protected]">Howard Gao</a> */ public class MessagePriorityExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/multiple-failover-failback/src/main/java/org/apache/activemq/jms/example/MultipleFailoverFailbackExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/multiple-failover-failback/src/main/java/org/apache/activemq/jms/example/MultipleFailoverFailbackExample.java b/examples/jms/multiple-failover-failback/src/main/java/org/apache/activemq/jms/example/MultipleFailoverFailbackExample.java index a295731..36e7475 100644 --- a/examples/jms/multiple-failover-failback/src/main/java/org/apache/activemq/jms/example/MultipleFailoverFailbackExample.java +++ b/examples/jms/multiple-failover-failback/src/main/java/org/apache/activemq/jms/example/MultipleFailoverFailbackExample.java @@ -28,11 +28,6 @@ import javax.naming.InitialContext; import org.apache.activemq.common.example.ActiveMQExample; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * Date: Nov 4, 2010 - * Time: 10:51:45 AM - */ public class MultipleFailoverFailbackExample extends ActiveMQExample { public static void main(final String[] args) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/multiple-failover/src/main/java/org/apache/activemq/jms/example/MultipleFailoverExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/multiple-failover/src/main/java/org/apache/activemq/jms/example/MultipleFailoverExample.java b/examples/jms/multiple-failover/src/main/java/org/apache/activemq/jms/example/MultipleFailoverExample.java index 768868f..cfbeda4 100644 --- a/examples/jms/multiple-failover/src/main/java/org/apache/activemq/jms/example/MultipleFailoverExample.java +++ b/examples/jms/multiple-failover/src/main/java/org/apache/activemq/jms/example/MultipleFailoverExample.java @@ -28,11 +28,6 @@ import javax.naming.InitialContext; import org.apache.activemq.common.example.ActiveMQExample; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * Date: Nov 4, 2010 - * Time: 10:51:45 AM - */ public class MultipleFailoverExample extends ActiveMQExample { public static void main(final String[] args) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/no-consumer-buffering/src/main/java/org/apache/activemq/jms/example/NoConsumerBufferingExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/no-consumer-buffering/src/main/java/org/apache/activemq/jms/example/NoConsumerBufferingExample.java b/examples/jms/no-consumer-buffering/src/main/java/org/apache/activemq/jms/example/NoConsumerBufferingExample.java index 4fa4f83..9cbcf3c 100644 --- a/examples/jms/no-consumer-buffering/src/main/java/org/apache/activemq/jms/example/NoConsumerBufferingExample.java +++ b/examples/jms/no-consumer-buffering/src/main/java/org/apache/activemq/jms/example/NoConsumerBufferingExample.java @@ -30,8 +30,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * This example demonstrates how ActiveMQ consumers can be configured to not buffer any messages from * the server. - * - * @author <a href="[email protected]">Tim Fox</a> */ public class NoConsumerBufferingExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/non-transaction-failover/src/main/java/org/apache/activemq/jms/example/NonTransactionFailoverExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/non-transaction-failover/src/main/java/org/apache/activemq/jms/example/NonTransactionFailoverExample.java b/examples/jms/non-transaction-failover/src/main/java/org/apache/activemq/jms/example/NonTransactionFailoverExample.java index 2b346a5..39cdb15 100644 --- a/examples/jms/non-transaction-failover/src/main/java/org/apache/activemq/jms/example/NonTransactionFailoverExample.java +++ b/examples/jms/non-transaction-failover/src/main/java/org/apache/activemq/jms/example/NonTransactionFailoverExample.java @@ -31,8 +31,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple example that demonstrates failover of the JMS connection from one node to another * when the live server crashes using a JMS <em>non-transacted</em> session. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class NonTransactionFailoverExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/openwire/src/main/java/org/apache/activemq/jms/example/OpenWireExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/openwire/src/main/java/org/apache/activemq/jms/example/OpenWireExample.java b/examples/jms/openwire/src/main/java/org/apache/activemq/jms/example/OpenWireExample.java index 972c885..f089704 100644 --- a/examples/jms/openwire/src/main/java/org/apache/activemq/jms/example/OpenWireExample.java +++ b/examples/jms/openwire/src/main/java/org/apache/activemq/jms/example/OpenWireExample.java @@ -31,8 +31,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS Queue example that creates a producer and consumer on a queue * and sends then receives a message. - * - * @author <a href="[email protected]">Andy Taylor</a> */ public class OpenWireExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/paging/src/main/java/org/apache/activemq/jms/example/PagingExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/paging/src/main/java/org/apache/activemq/jms/example/PagingExample.java b/examples/jms/paging/src/main/java/org/apache/activemq/jms/example/PagingExample.java index 4754fa7..56bf905 100644 --- a/examples/jms/paging/src/main/java/org/apache/activemq/jms/example/PagingExample.java +++ b/examples/jms/paging/src/main/java/org/apache/activemq/jms/example/PagingExample.java @@ -30,8 +30,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message. - * - * @author <a href="[email protected]">Clebert Suconic</a> */ public class PagingExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfBase.java ---------------------------------------------------------------------- diff --git a/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfBase.java b/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfBase.java index 5ceacf0..539af20 100644 --- a/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfBase.java +++ b/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfBase.java @@ -31,12 +31,7 @@ import org.apache.activemq.utils.TokenBucketLimiter; import org.apache.activemq.utils.TokenBucketLimiterImpl; /** - * * A PerfBase - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public abstract class PerfBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfListener.java ---------------------------------------------------------------------- diff --git a/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfListener.java b/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfListener.java index a6315ed..a16e10a 100644 --- a/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfListener.java +++ b/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfListener.java @@ -20,12 +20,7 @@ import java.util.Properties; import java.util.logging.Logger; /** - * * A PerfListener - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public class PerfListener extends PerfBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfParams.java ---------------------------------------------------------------------- diff --git a/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfParams.java b/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfParams.java index 681331b..309bdaa 100644 --- a/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfParams.java +++ b/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfParams.java @@ -19,10 +19,7 @@ package org.apache.activemq.jms.example; import java.io.Serializable; /** - * * Class that holds the parameters used in the performance examples - * - * @author <a href="[email protected]">Andy Taylor</a> */ public class PerfParams implements Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfSender.java ---------------------------------------------------------------------- diff --git a/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfSender.java b/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfSender.java index 55f4583..0408a6b 100644 --- a/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfSender.java +++ b/examples/jms/perf/src/main/java/org/apache/activemq/jms/example/PerfSender.java @@ -20,12 +20,7 @@ import java.util.Properties; import java.util.logging.Logger; /** - * * A PerfSender - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public class PerfSender extends PerfBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/jms/example/PreacknowledgeExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/jms/example/PreacknowledgeExample.java b/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/jms/example/PreacknowledgeExample.java index 8c507c4..945a4d1 100644 --- a/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/jms/example/PreacknowledgeExample.java +++ b/examples/jms/pre-acknowledge/src/main/java/org/apache/activemq/jms/example/PreacknowledgeExample.java @@ -35,14 +35,10 @@ import org.apache.activemq.api.jms.management.JMSManagementHelper; import org.apache.activemq.common.example.ActiveMQExample; /** - * * This example demonstrates the use of ActiveMQ "pre-acknowledge" functionality where * messages are acknowledged before they are delivered to the consumer. * * Please see the readme.html for more details. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class PreacknowledgeExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/jms/example/ProducerRateLimitExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/jms/example/ProducerRateLimitExample.java b/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/jms/example/ProducerRateLimitExample.java index 78bdf33..c60e4b1 100644 --- a/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/jms/example/ProducerRateLimitExample.java +++ b/examples/jms/producer-rate-limit/src/main/java/org/apache/activemq/jms/example/ProducerRateLimitExample.java @@ -30,8 +30,6 @@ import org.apache.activemq.common.example.ActiveMQExample; /** * This example demonstrates how a message producer can be limited to produce messages at a maximum rate * specified in messages per sec. - * - * @author <a href="[email protected]">Tim Fox</a> */ public class ProducerRateLimitExample extends ActiveMQExample { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/examples/jms/queue-message-redistribution/src/main/java/org/apache/activemq/jms/example/QueueMessageRedistributionExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/queue-message-redistribution/src/main/java/org/apache/activemq/jms/example/QueueMessageRedistributionExample.java b/examples/jms/queue-message-redistribution/src/main/java/org/apache/activemq/jms/example/QueueMessageRedistributionExample.java index a64e0f6..213499d 100644 --- a/examples/jms/queue-message-redistribution/src/main/java/org/apache/activemq/jms/example/QueueMessageRedistributionExample.java +++ b/examples/jms/queue-message-redistribution/src/main/java/org/apache/activemq/jms/example/QueueMessageRedistributionExample.java @@ -34,8 +34,6 @@ import org.apache.activemq.common.example.ActiveMQExample; * Messages are initially round robin'd between both nodes of the cluster. * The consumer on one of the nodes is then closed, and we demonstrate that the "stranded" messages * are redistributed to the other node which has a consumer so they can be consumed. - * - * @author <a href="[email protected]>Tim Fox</a> */ public class QueueMessageRedistributionExample extends ActiveMQExample {
