http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/FailoverEventListener.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/FailoverEventListener.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/FailoverEventListener.java index bcfccd7..2f90f7a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/FailoverEventListener.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/FailoverEventListener.java @@ -18,8 +18,6 @@ package org.apache.activemq.api.core.client; /** * A FailoverEvent notifies the client the state if the connection changes occurred on the session. - * - * @author <a href="mailto:[email protected]";>Flemming Harms</a> */ public interface FailoverEventListener {
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/MessageHandler.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/MessageHandler.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/MessageHandler.java index 8ae3dde..52f9d14 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/MessageHandler.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/MessageHandler.java @@ -21,7 +21,6 @@ package org.apache.activemq.api.core.client; * <p> * To receive messages asynchronously, a MessageHandler is set on a ClientConsumer. Every time the * consumer will receive a message, it will call the handler's {@code onMessage()} method. - * @author <a href="mailto:[email protected]";>Tim Fox</a> * @see ClientConsumer#setMessageHandler(MessageHandler) */ public interface MessageHandler http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SendAcknowledgementHandler.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SendAcknowledgementHandler.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SendAcknowledgementHandler.java index 2695f47..fb87bdd 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SendAcknowledgementHandler.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SendAcknowledgementHandler.java @@ -32,7 +32,6 @@ import org.apache.activemq.api.core.Message; * <p> * Notice that this notification will only take place if {@code ConfirmationWindowSize} is set to a * positive value at {@link ServerLocator#setConfirmationWindowSize(int)}. - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface SendAcknowledgementHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/ServerLocator.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/ServerLocator.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/ServerLocator.java index aaf62ba..4e4b7fa 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/ServerLocator.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/ServerLocator.java @@ -32,8 +32,6 @@ import org.apache.activemq.spi.core.remoting.ClientProtocolManagerFactory; * If you use UDP or JGroups (exclusively JGroups or UDP), the initial discovery is done by the * grouping finder, after the initial connection is made the server will always send updates to the * client. But the listeners will listen for updates on grouping. - * - * @author Tim Fox */ public interface ServerLocator extends AutoCloseable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SessionFailureListener.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SessionFailureListener.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SessionFailureListener.java index e37c48d..4864ba3 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SessionFailureListener.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/SessionFailureListener.java @@ -21,8 +21,6 @@ import org.apache.activemq.core.remoting.FailureListener; /** * A SessionFailureListener notifies the client when a failure occurred on the session. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface SessionFailureListener extends FailureListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/ConnectionLoadBalancingPolicy.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/ConnectionLoadBalancingPolicy.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/ConnectionLoadBalancingPolicy.java index dc4c173..f7cca43 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/ConnectionLoadBalancingPolicy.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/ConnectionLoadBalancingPolicy.java @@ -18,8 +18,6 @@ package org.apache.activemq.api.core.client.loadbalance; /** * A ConnectionLoadBalancingPolicy defines a policy to load balance between connections. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface ConnectionLoadBalancingPolicy { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/FirstElementConnectionLoadBalancingPolicy.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/FirstElementConnectionLoadBalancingPolicy.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/FirstElementConnectionLoadBalancingPolicy.java index 41c29f0..544f9d8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/FirstElementConnectionLoadBalancingPolicy.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/FirstElementConnectionLoadBalancingPolicy.java @@ -19,10 +19,6 @@ package org.apache.activemq.api.core.client.loadbalance; /** * A {@link FirstElementConnectionLoadBalancingPolicy#select(int)} always returns 0. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 28 Nov 2008 10:56:59 */ public final class FirstElementConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomConnectionLoadBalancingPolicy.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomConnectionLoadBalancingPolicy.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomConnectionLoadBalancingPolicy.java index 5cd1011..9d836e8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomConnectionLoadBalancingPolicy.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomConnectionLoadBalancingPolicy.java @@ -21,7 +21,6 @@ import org.apache.activemq.utils.Random; /** * {@link RandomConnectionLoadBalancingPolicy#select(int)} returns a (pseudo) random integer between * {@code 0} (inclusive) and {@code max} (exclusive). - * @author <a href="mailto:[email protected]";>Tim Fox</a> Created 28 Nov 2008 10:24:11 */ public final class RandomConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomStickyConnectionLoadBalancingPolicy.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomStickyConnectionLoadBalancingPolicy.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomStickyConnectionLoadBalancingPolicy.java index 2aacb67..0205af7 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomStickyConnectionLoadBalancingPolicy.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RandomStickyConnectionLoadBalancingPolicy.java @@ -20,9 +20,6 @@ import org.apache.activemq.utils.Random; /** * {@link RandomConnectionLoadBalancingPolicy#select(int)} chooses a the initial node randomly then subsequent requests return the same node - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public final class RandomStickyConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java index b5f1e5f..cec1949 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/client/loadbalance/RoundRobinConnectionLoadBalancingPolicy.java @@ -26,12 +26,6 @@ import org.apache.activemq.utils.Random; * <br> * The first call to {@link #select(int)} will return a random integer between {@code 0} (inclusive) and {@code max} (exclusive). * Subsequent calls will then return an integer in a round-robin fashion. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 28 Nov 2008 10:21:08 - * - * */ public final class RoundRobinConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy, Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AcceptorControl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AcceptorControl.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AcceptorControl.java index 8a030ac..d565810 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AcceptorControl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AcceptorControl.java @@ -21,8 +21,6 @@ import java.util.Map; /** * An AcceptorControl is used to manage Acceptors. * - * @author <a href="[email protected]">Jeff Mesnil</a> - * * @see Acceptor */ public interface AcceptorControl extends ActiveMQComponentControl http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ActiveMQComponentControl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ActiveMQComponentControl.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ActiveMQComponentControl.java index ba29ee4..f5f9e64 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ActiveMQComponentControl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ActiveMQComponentControl.java @@ -18,8 +18,6 @@ package org.apache.activemq.api.core.management; /** * A ActiveMQComponentControl is used to manage the life cycle of a ActiveMQ component. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public interface ActiveMQComponentControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressControl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressControl.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressControl.java index 78edcd2..3602f5d 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressControl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressControl.java @@ -21,8 +21,6 @@ import javax.management.MBeanOperationInfo; /** * An AddressControl is used to manage an address. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public interface AddressControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java index bc7f82a..3081a1f 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/AddressSettingsInfo.java @@ -20,10 +20,6 @@ import org.apache.activemq.utils.json.JSONObject; /** * A AddressSettingsInfo - * - * @author jmesnil - * - * */ // XXX no javadocs public final class AddressSettingsInfo http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BridgeControl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BridgeControl.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BridgeControl.java index 1cc564d..a73610a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BridgeControl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BridgeControl.java @@ -19,9 +19,6 @@ package org.apache.activemq.api.core.management; /** * A BridgeControl is used to manage a Bridge. - * - * @author <a href="[email protected]">Jeff Mesnil</a> - * */ public interface BridgeControl extends ActiveMQComponentControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BroadcastGroupControl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BroadcastGroupControl.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BroadcastGroupControl.java index 9fe80cb..414ecd9 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BroadcastGroupControl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/BroadcastGroupControl.java @@ -18,9 +18,6 @@ package org.apache.activemq.api.core.management; /** * A BroadcastGroupControl is used to manage a broadcast group. - * - * @author <a href="[email protected]">Jeff Mesnil</a> - * */ public interface BroadcastGroupControl extends ActiveMQComponentControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ClusterConnectionControl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ClusterConnectionControl.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ClusterConnectionControl.java index 3b68583..1cfedb6 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ClusterConnectionControl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ClusterConnectionControl.java @@ -20,9 +20,6 @@ import java.util.Map; /** * A ClusterConnectionControl is used to manage a cluster connection. - * - * @author <a href="[email protected]">Jeff Mesnil</a> - * */ public interface ClusterConnectionControl extends ActiveMQComponentControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/CoreNotificationType.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/CoreNotificationType.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/CoreNotificationType.java index 5b2393b..a483e0a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/CoreNotificationType.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/CoreNotificationType.java @@ -18,8 +18,6 @@ package org.apache.activemq.api.core.management; /** * This enum defines all core notification types - * - * @author <a href="mailto:[email protected]";>Howard Gao</a> */ public enum CoreNotificationType implements NotificationType { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DayCounterInfo.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DayCounterInfo.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DayCounterInfo.java index b6eb901..b4a41b0 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DayCounterInfo.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DayCounterInfo.java @@ -25,8 +25,6 @@ import org.apache.activemq.utils.json.JSONObject; /** * Helper class to create Java Objects from the * JSON serialization returned by {@link QueueControl#listMessageCounterHistory()}. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public final class DayCounterInfo { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DivertControl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DivertControl.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DivertControl.java index 1af7d6c..58f8c69 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DivertControl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/DivertControl.java @@ -18,8 +18,6 @@ package org.apache.activemq.api.core.management; /** * A DivertControl is used to manage a divert. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public interface DivertControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ManagementHelper.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ManagementHelper.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ManagementHelper.java index 90b4a5f..9dbb962 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ManagementHelper.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ManagementHelper.java @@ -29,9 +29,6 @@ import org.apache.activemq.utils.json.JSONObject; /** * Helper class to use ActiveMQ Core messages to manage server resources. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public final class ManagementHelper { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/NotificationType.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/NotificationType.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/NotificationType.java index 8bdf73e..22ddfcf 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/NotificationType.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/NotificationType.java @@ -26,7 +26,6 @@ package org.apache.activemq.api.core.management; * <li>JMS messages * </ul> * @see the ActiveMQ user manual section on "Management Notifications" - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public interface NotificationType { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ObjectNameBuilder.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ObjectNameBuilder.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ObjectNameBuilder.java index 4e58b9d..8ac35a8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ObjectNameBuilder.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ObjectNameBuilder.java @@ -23,7 +23,6 @@ import org.apache.activemq.api.core.SimpleString; /** * Helper class to build ObjectNames for ActiveMQ resources. - * @author <a href="[email protected]">Jeff Mesnil</a> */ public final class ObjectNameBuilder { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Operation.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Operation.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Operation.java index 64f6002..7bab654 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Operation.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Operation.java @@ -29,8 +29,6 @@ import javax.management.MBeanOperationInfo; * <p> * This annotation is used only for methods which can be invoked * through a GUI. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Parameter.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Parameter.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Parameter.java index 855cb4a..c30b253 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Parameter.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/Parameter.java @@ -26,8 +26,6 @@ import java.lang.annotation.Target; * <p> * This annotation is used only for methods which can be invoked * through a GUI. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.PARAMETER) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/QueueControl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/QueueControl.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/QueueControl.java index 9d20713..f864860 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/QueueControl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/QueueControl.java @@ -22,8 +22,6 @@ import java.util.Map; /** * A QueueControl is used to manage a queue. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public interface QueueControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ResourceNames.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ResourceNames.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ResourceNames.java index 92d6cda..8d68907 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ResourceNames.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/ResourceNames.java @@ -21,8 +21,6 @@ package org.apache.activemq.api.core.management; * <br> * Resource's name is build by appending its <em>name</em> to its corresponding type. * For example, the resource name of the "foo" queue is {@code CORE_QUEUE + "foo"}. - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public final class ResourceNames { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/RoleInfo.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/RoleInfo.java b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/RoleInfo.java index bf8f4d4..20888fd 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/RoleInfo.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/api/core/management/RoleInfo.java @@ -22,8 +22,6 @@ import org.apache.activemq.utils.json.JSONObject; /** * Helper class to create Java Objects from the * JSON serialization returned by {@link AddressControl#getRolesAsJSON()}. - * - * @author <a href="[email protected]">Jeff Mesnil</a> */ public final class RoleInfo { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/buffers/impl/ResetLimitWrappedActiveMQBuffer.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/buffers/impl/ResetLimitWrappedActiveMQBuffer.java b/activemq-core-client/src/main/java/org/apache/activemq/core/buffers/impl/ResetLimitWrappedActiveMQBuffer.java index 1cd342d..7c0c16a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/buffers/impl/ResetLimitWrappedActiveMQBuffer.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/buffers/impl/ResetLimitWrappedActiveMQBuffer.java @@ -25,7 +25,6 @@ import org.apache.activemq.core.message.impl.MessageInternal; /** * A ResetLimitWrappedActiveMQBuffer * TODO: Move this to commons - * @author Tim Fox * */ public final class ResetLimitWrappedActiveMQBuffer extends ChannelBufferWrapper http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientLogger.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientLogger.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientLogger.java index ae78db7..6e88446 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientLogger.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientLogger.java @@ -45,8 +45,6 @@ import org.w3c.dom.Node; * <p> * Once released, methods should not be deleted as they may be referenced by knowledge base * articles. Unused methods should be marked as deprecated. - * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> */ @MessageLogger(projectCode = "AMQ") public interface ActiveMQClientLogger extends BasicLogger http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientMessageBundle.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientMessageBundle.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientMessageBundle.java index 145eedb..cfa9cf0 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientMessageBundle.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientMessageBundle.java @@ -39,9 +39,6 @@ import org.jboss.logging.Messages; import org.w3c.dom.Node; /** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * 3/12/12 - * * Logger Code 11 * * each message id must be 6 digits long starting with 10, the 3rd digit should be 9 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/AfterConnectInternalListener.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/AfterConnectInternalListener.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/AfterConnectInternalListener.java index 03e27c1..e49840e 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/AfterConnectInternalListener.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/AfterConnectInternalListener.java @@ -20,10 +20,6 @@ package org.apache.activemq.core.client.impl; * To be called right after the ConnectionFactory created a connection. * This listener is not part of the API and shouldn't be used by users. * (if you do so we can't guarantee any API compatibility on this class) - * - * @author clebertsuconic - * - * */ public interface AfterConnectInternalListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java index 919882d..ebf98d6 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java @@ -44,14 +44,6 @@ import org.apache.activemq.utils.PriorityLinkedListImpl; import org.apache.activemq.utils.ReusableLatch; import org.apache.activemq.utils.TokenBucketLimiter; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Ovidiu Feodorov</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @version <tt>$Revision: 3603 $</tt> $Id: ClientConsumerImpl.java 3603 2008-01-21 18:49:20Z timfox $ - */ public final class ClientConsumerImpl implements ClientConsumerInternal { // Constants http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java index 3a7663a..e3d9fd3 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerInternal.java @@ -25,8 +25,6 @@ import org.apache.activemq.utils.FutureLatch; /** * A ClientConsumerInternal - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface ClientConsumerInternal extends ClientConsumer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageImpl.java index 913c1e6..732c406 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageImpl.java @@ -30,7 +30,6 @@ import org.apache.activemq.utils.DataConstants; * <p> * At the time of sending a regular Message is sent as we won't know the message is considered large * until the buffer is filled up or the user set a streaming. - * @author clebertsuconic */ public final class ClientLargeMessageImpl extends ClientMessageImpl implements ClientLargeMessageInternal { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java index e0c5a74..29cb645 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientLargeMessageInternal.java @@ -19,10 +19,6 @@ package org.apache.activemq.core.client.impl; /** * A ClientLargeMessageInternal - * - * @author clebertsuconic - * - * */ public interface ClientLargeMessageInternal extends ClientMessageInternal { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageImpl.java index 8e28079..7f961df 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageImpl.java @@ -35,10 +35,6 @@ import org.apache.activemq.reader.MessageUtil; /** * * A ClientMessageImpl - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * */ public class ClientMessageImpl extends MessageImpl implements ClientMessageInternal { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java index 3550e0e..3e88720 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientMessageInternal.java @@ -22,8 +22,6 @@ import org.apache.activemq.utils.TypedProperties; /** * A ClientMessageInternal - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface ClientMessageInternal extends ClientMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java index 42315aa..c177ed7 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManager.java @@ -21,10 +21,6 @@ import org.apache.activemq.spi.core.remoting.SessionContext; /** * A ClientProducerCreditManager - * - * @author Tim Fox - * - * */ public interface ClientProducerCreditManager { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java index 2fc4d56..130c8a4 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditManagerImpl.java @@ -25,8 +25,6 @@ import org.apache.activemq.spi.core.remoting.SessionContext; /** * A ProducerCreditManager - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public class ClientProducerCreditManagerImpl implements ClientProducerCreditManager { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java index 03c91e9..91a9c02 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCredits.java @@ -21,10 +21,6 @@ import org.apache.activemq.spi.core.remoting.SessionContext; /** * A ClientProducerCredits - * - * @author Tim Fox - * - * */ public interface ClientProducerCredits { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java index 66832da..0aac7a7 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerCreditsImpl.java @@ -27,8 +27,6 @@ import java.util.concurrent.TimeUnit; /** * A ClientProducerCreditsImpl - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public class ClientProducerCreditsImpl implements ClientProducerCredits { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerImpl.java index 83bb03c..7623cdb 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerImpl.java @@ -39,10 +39,6 @@ import org.apache.activemq.utils.UUIDGenerator; /** * The client-side Producer. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> */ public class ClientProducerImpl implements ClientProducerInternal { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerInternal.java index d3f3129..ff37542 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientProducerInternal.java @@ -21,9 +21,6 @@ import org.apache.activemq.api.core.client.ClientProducer; /** * * A ClientProducerInternal - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public interface ClientProducerInternal extends ClientProducer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryImpl.java index 07aafcc..da4d476 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryImpl.java @@ -65,12 +65,6 @@ import org.apache.activemq.utils.ExecutorFactory; import org.apache.activemq.utils.OrderedExecutorFactory; import org.apache.activemq.utils.UUIDGenerator; -/** - * @author Tim Fox - * @author Clebert Suconic - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - */ - public class ClientSessionFactoryImpl implements ClientSessionFactoryInternal, ConnectionLifeCycleListener { // Constants http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java index ef1616a..0678639 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionFactoryInternal.java @@ -26,10 +26,6 @@ import org.apache.activemq.utils.ConfirmationWindowWarning; /** * A ClientSessionFactoryInternal - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - * */ public interface ClientSessionFactoryInternal extends ClientSessionFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionImpl.java index cbe5ce4..fd4f268 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionImpl.java @@ -50,14 +50,6 @@ import org.apache.activemq.utils.ConfirmationWindowWarning; import org.apache.activemq.utils.TokenBucketLimiterImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Ovidiu Feodorov</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - */ public final class ClientSessionImpl implements ClientSessionInternal, FailureListener { private final Map<String, String> metadata = new HashMap<String, String>(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java index 5f80989..8ead36f 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientSessionInternal.java @@ -27,8 +27,6 @@ import org.apache.activemq.spi.core.remoting.ConsumerContext; /** * A ClientSessionInternal - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface ClientSessionInternal extends ClientSession { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/CompressedLargeMessageControllerImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/CompressedLargeMessageControllerImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/CompressedLargeMessageControllerImpl.java index f55bfee..c792f16 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/CompressedLargeMessageControllerImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/CompressedLargeMessageControllerImpl.java @@ -33,9 +33,6 @@ import org.apache.activemq.utils.InflaterReader; import org.apache.activemq.utils.InflaterWriter; import org.apache.activemq.utils.UTF8Util; -/** - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - */ final class CompressedLargeMessageControllerImpl implements LargeMessageController { private static final String OPERATION_NOT_SUPPORTED = "Operation not supported"; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/DelegatingSession.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/DelegatingSession.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/DelegatingSession.java index 388f069..6c5966b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/DelegatingSession.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/DelegatingSession.java @@ -41,9 +41,6 @@ import org.apache.activemq.utils.ConcurrentHashSet; * <p> * We wrap the real session, so we can add a finalizer on this and close the session * on GC if it has not already been closed - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> */ public class DelegatingSession implements ClientSessionInternal { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java index 10c24fe..863e5ab 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageController.java @@ -23,8 +23,6 @@ import org.apache.activemq.api.core.ActiveMQException; /** * A LargeMessageBufferInternal - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public interface LargeMessageController extends ActiveMQBuffer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageControllerImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageControllerImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageControllerImpl.java index a279024..610668c 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageControllerImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/LargeMessageControllerImpl.java @@ -47,8 +47,6 @@ import org.apache.activemq.utils.UTF8Util; * by a single buffer. This buffer can be consumed as messages are arriving, and it will hold the * packets until they are read using the ChannelBuffer interface, or the setOutputStream or * saveStream are called. - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public class LargeMessageControllerImpl implements LargeMessageController { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorImpl.java index db0b34c..2e01e1f 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorImpl.java @@ -69,8 +69,6 @@ import org.apache.activemq.utils.UUIDGenerator; /** * This is the implementation of {@link org.apache.activemq.api.core.client.ServerLocator} and all * the proper javadoc is located on that interface. - * - * @author Tim Fox */ public final class ServerLocatorImpl implements ServerLocatorInternal, DiscoveryListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java index 896b7a6..db374ec 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ServerLocatorInternal.java @@ -27,10 +27,6 @@ import org.apache.activemq.spi.core.remoting.ClientProtocolManager; /** * A ServerLocatorInternal - * - * @author Tim Fox - * - * */ public interface ServerLocatorInternal extends ServerLocator { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/Topology.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/Topology.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/Topology.java index e85f123..2742001 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/Topology.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/Topology.java @@ -32,11 +32,6 @@ import org.apache.activemq.api.core.client.ClusterTopologyListener; import org.apache.activemq.core.client.ActiveMQClientLogger; import org.apache.activemq.spi.core.remoting.Connector; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @author Clebert Suconic - * Created Aug 16, 2010 - */ public final class Topology implements Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/TopologyMemberImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/TopologyMemberImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/TopologyMemberImpl.java index a7d45cc..597d71e 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/TopologyMemberImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/TopologyMemberImpl.java @@ -21,10 +21,6 @@ import org.apache.activemq.api.core.TransportConfiguration; import org.apache.activemq.api.core.client.TopologyMember; import org.apache.activemq.spi.core.protocol.RemotingConnection; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * Created Aug 16, 2010 - */ public final class TopologyMemberImpl implements TopologyMember { private static final long serialVersionUID = 1123652191795626133L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java b/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java index b407a05..35402cc 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryEntry.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.TransportConfiguration; /** * A DiscoveryEntry - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public class DiscoveryEntry { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryGroup.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryGroup.java b/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryGroup.java index 1bd502c..2b6dd75 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryGroup.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryGroup.java @@ -45,10 +45,6 @@ import org.apache.activemq.utils.TypedProperties; * We will probably keep both interfaces for a while as UDP is a simple solution requiring no extra dependencies which * is suitable for users looking for embedded solutions. * <p/> - * Created 17 Nov 2008 13:21:45 - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author Clebert Suconic */ public final class DiscoveryGroup implements ActiveMQComponent { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryListener.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryListener.java b/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryListener.java index f37172b..0842ac9 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryListener.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/cluster/DiscoveryListener.java @@ -20,13 +20,6 @@ import java.util.List; /** * To be called any time Discovery changes its list of nodes. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author Clebert Suconic - * - * Created 17 Nov 2008 14:30:39 - * - * */ public interface DiscoveryListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java b/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java index 9e15446..f347d06 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/exception/ActiveMQXAException.java @@ -20,10 +20,6 @@ import javax.transaction.xa.XAException; /** * A ActiveMQXAException - * - * @author Tim Fox - * - * */ public class ActiveMQXAException extends XAException { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/message/BodyEncoder.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/message/BodyEncoder.java b/activemq-core-client/src/main/java/org/apache/activemq/core/message/BodyEncoder.java index 1846bb0..8c28d69 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/message/BodyEncoder.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/message/BodyEncoder.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.ActiveMQException; * Class used to encode message body into buffers. * <br> * Used to send large streams over the wire - * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public interface BodyEncoder { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageImpl.java index 94d4252..b16946c 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageImpl.java @@ -39,12 +39,6 @@ import org.apache.activemq.utils.UUID; * A concrete implementation of a message * <p> * All messages handled by ActiveMQ core are of this type - * - * @author <a href="mailto:[email protected]";>Ovidiu Feodorov</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @version <tt>$Revision: 2740 $</tt> */ public abstract class MessageImpl implements MessageInternal { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java index e51a452..aedf5af 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/message/impl/MessageInternal.java @@ -27,10 +27,6 @@ import org.apache.activemq.utils.TypedProperties; /** * A MessageInternal - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public interface MessageInternal extends Message { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/ClientPacketDecoder.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/ClientPacketDecoder.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/ClientPacketDecoder.java index f7e80d1..6c057bd 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/ClientPacketDecoder.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/ClientPacketDecoder.java @@ -26,10 +26,7 @@ import org.apache.activemq.core.protocol.core.Packet; import org.apache.activemq.core.protocol.core.impl.PacketDecoder; import org.apache.activemq.core.protocol.core.impl.wireformat.SessionReceiveClientLargeMessage; import org.apache.activemq.core.protocol.core.impl.wireformat.SessionReceiveMessage; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * 10/12/12 - */ + public class ClientPacketDecoder extends PacketDecoder { private static final long serialVersionUID = 6952614096979334582L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Channel.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Channel.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Channel.java index 3cc9e62..7546952 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Channel.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Channel.java @@ -29,8 +29,6 @@ import org.apache.activemq.api.core.ActiveMQException; * Each Channel should will forward any packets received to its {@link org.apache.activemq.core.protocol.core.ChannelHandler}. * <p> * A Channel *does not* support concurrent access by more than one thread! - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface Channel { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/ChannelHandler.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/ChannelHandler.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/ChannelHandler.java index bf11a74..c363280 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/ChannelHandler.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/ChannelHandler.java @@ -20,8 +20,6 @@ package org.apache.activemq.core.protocol.core; /** * A ChannelHandler is used by {@link Channel}. When a channel receives a packet it will call its handler to deal with the * packet. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface ChannelHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CommandConfirmationHandler.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CommandConfirmationHandler.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CommandConfirmationHandler.java index 7b7876b..ab41bce 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CommandConfirmationHandler.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CommandConfirmationHandler.java @@ -20,9 +20,6 @@ package org.apache.activemq.core.protocol.core; /** * A CommandConfirmationHandler is used by the channel to confirm confirmations of packets. * <p> - * Created 9 Feb 2009 12:39:11 - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface CommandConfirmationHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CoreRemotingConnection.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CoreRemotingConnection.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CoreRemotingConnection.java index 9ef6cf2..fdbe8eb 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CoreRemotingConnection.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/CoreRemotingConnection.java @@ -22,7 +22,6 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection; /** * Extension of RemotingConnection for the ActiveMQ core protocol - * @author Tim Fox */ public interface CoreRemotingConnection extends RemotingConnection { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Packet.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Packet.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Packet.java index 6b23bff..40f5062 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Packet.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/Packet.java @@ -21,8 +21,6 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection; /** * A Packet represents a packet of data transmitted over a connection. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public interface Packet { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManager.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManager.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManager.java index 890e8d0..0f10f38 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManager.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManager.java @@ -70,8 +70,6 @@ import org.apache.activemq.utils.VersionLoader; * Semantic properties could also be added to this implementation. * <p/> * Implementations of this class need to be stateless. - * - * @author Clebert Suconic */ public class ActiveMQClientProtocolManager implements ClientProtocolManager http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManagerFactory.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManagerFactory.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManagerFactory.java index 0d27b6f..d312b52 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManagerFactory.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQClientProtocolManagerFactory.java @@ -19,10 +19,6 @@ package org.apache.activemq.core.protocol.core.impl; import org.apache.activemq.spi.core.remoting.ClientProtocolManager; import org.apache.activemq.spi.core.remoting.ClientProtocolManagerFactory; -/** - * @author Clebert Suconic - */ - public class ActiveMQClientProtocolManagerFactory implements ClientProtocolManagerFactory { private static final long serialVersionUID = 1; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQConsumerContext.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQConsumerContext.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQConsumerContext.java index 1225a8d..f58dbe8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQConsumerContext.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQConsumerContext.java @@ -18,10 +18,6 @@ package org.apache.activemq.core.protocol.core.impl; import org.apache.activemq.spi.core.remoting.ConsumerContext; -/** - * @author Clebert Suconic - */ - public class ActiveMQConsumerContext extends ConsumerContext { private long id; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java index c1ec157..8df0011 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java @@ -107,10 +107,6 @@ import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_RECEIV import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_LARGE_MSG; import static org.apache.activemq.core.protocol.core.impl.PacketImpl.SESS_RECEIVE_MSG; -/** - * @author Clebert Suconic - */ - public class ActiveMQSessionContext extends SessionContext { private final Channel sessionChannel; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/BackwardsCompatibilityUtils.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/BackwardsCompatibilityUtils.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/BackwardsCompatibilityUtils.java index 1ca4293..eb9d886 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/BackwardsCompatibilityUtils.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/BackwardsCompatibilityUtils.java @@ -24,9 +24,7 @@ import org.apache.activemq.api.core.client.TopologyMember; /** * This is a utility class to house any HornetQ client specific backwards compatibility methods. * - * @author mtaylor */ - public class BackwardsCompatibilityUtils { private static int INITIAL_ACTIVEMQ_INCREMENTING_VERSION = 126; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java index 3b284a2..2150bb1 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java @@ -42,8 +42,6 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection; /** * A ChannelImpl - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public final class ChannelImpl implements Channel { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java index cbb94c3..2aa2958 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketDecoder.java @@ -147,8 +147,6 @@ import org.apache.activemq.core.protocol.core.impl.wireformat.SubscribeClusterTo /** * A PacketDecoder - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public abstract class PacketDecoder implements Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java index 61e0eca..ffb111c 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/PacketImpl.java @@ -21,10 +21,6 @@ import org.apache.activemq.core.protocol.core.Packet; import org.apache.activemq.spi.core.protocol.RemotingConnection; import org.apache.activemq.utils.DataConstants; -/** - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class PacketImpl implements Packet { // Constants ------------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java index 8820850..9bc4633 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/RemotingConnectionImpl.java @@ -39,10 +39,6 @@ import org.apache.activemq.spi.core.protocol.AbstractRemotingConnection; import org.apache.activemq.spi.core.remoting.Connection; import org.apache.activemq.utils.SimpleIDGenerator; -/** - * @author <a href="[email protected]">Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - */ public class RemotingConnectionImpl extends AbstractRemotingConnection implements CoreRemotingConnection { // Constants http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ActiveMQExceptionMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ActiveMQExceptionMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ActiveMQExceptionMessage.java index b56e89c..13d01df 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ActiveMQExceptionMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ActiveMQExceptionMessage.java @@ -21,10 +21,6 @@ import org.apache.activemq.api.core.ActiveMQException; import org.apache.activemq.api.core.ActiveMQExceptionType; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class ActiveMQExceptionMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java index 3998902..8bc31ed 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage.java @@ -21,9 +21,6 @@ import org.apache.activemq.api.core.Pair; import org.apache.activemq.api.core.TransportConfiguration; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class ClusterTopologyChangeMessage extends PacketImpl { protected boolean exit; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java index 8b031ef..fa96e3f 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ClusterTopologyChangeMessage_V3.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.Pair; import org.apache.activemq.api.core.TransportConfiguration; -/** - * @author Justin Bertram - */ public class ClusterTopologyChangeMessage_V3 extends ClusterTopologyChangeMessage_V2 { private String scaleDownGroupName; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java index 3d3fc2c..692b998 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateQueueMessage.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - - */ public class CreateQueueMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java index 8087edd..8820d83 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionMessage.java @@ -19,11 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a>. - * - */ public class CreateSessionMessage extends PacketImpl { private String name; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java index b934e3f..0ffa83b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSessionResponseMessage.java @@ -19,11 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a>. - * - */ public class CreateSessionResponseMessage extends PacketImpl { private int serverVersion; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java index 5a78bb8..ecc2780 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/CreateSharedQueueMessage.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - - */ public class CreateSharedQueueMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java index 36b1265..bc35071 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/MessagePacket.java @@ -22,10 +22,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A MessagePacket - * - * @author Tim Fox - * - * */ public abstract class MessagePacket extends PacketImpl {
