http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/ServerPacketDecoder.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/ServerPacketDecoder.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/ServerPacketDecoder.java index 6d058a6..1011561 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/ServerPacketDecoder.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/ServerPacketDecoder.java @@ -71,10 +71,6 @@ import org.apache.activemq.core.protocol.core.impl.wireformat.SessionSendLargeMe import org.apache.activemq.core.protocol.core.impl.wireformat.SessionSendMessage; import org.apache.activemq.core.server.impl.ServerMessageImpl; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * 10/12/12 - */ public class ServerPacketDecoder extends ClientPacketDecoder { private static final long serialVersionUID = 3348673114388400766L;
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java index 529137a..f3f4165 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/ServerSessionPacketHandler.java @@ -115,11 +115,6 @@ import org.apache.activemq.spi.core.remoting.Connection; /** * A ServerSessionPacketHandler - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]>Andy Taylor</a> - * @author <a href="mailto:[email protected]>Clebert Suconic</a> */ public class ServerSessionPacketHandler implements ChannelHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQPacketHandler.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQPacketHandler.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQPacketHandler.java index 92b4f8a..fa3330e 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQPacketHandler.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQPacketHandler.java @@ -42,10 +42,6 @@ import org.apache.activemq.core.version.Version; /** * A packet handler for all packets that need to be handled at the server level - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="[email protected]">Andy Taylor</a> */ public class ActiveMQPacketHandler implements ChannelHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManager.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManager.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManager.java index eb6ea5a..391fec9 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManager.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManager.java @@ -59,8 +59,6 @@ import org.apache.activemq.spi.core.remoting.Connection; /** * A CoreProtocolManager - * - * @author Tim Fox */ class CoreProtocolManager implements ProtocolManager { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManagerFactory.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManagerFactory.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManagerFactory.java index 5fe9a0e..e0e7b15 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManagerFactory.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreProtocolManagerFactory.java @@ -26,10 +26,6 @@ import org.apache.activemq.spi.core.protocol.ProtocolManagerFactory; /** * A CoreProtocolManagerFactory - * - * @author Tim Fox - * - * */ public class CoreProtocolManagerFactory implements ProtocolManagerFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreSessionCallback.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreSessionCallback.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreSessionCallback.java index b824501..7870660 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreSessionCallback.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/CoreSessionCallback.java @@ -34,8 +34,6 @@ import org.apache.activemq.spi.core.remoting.ReadyListener; /** * A CoreSessionCallback - * - * @author Tim Fox */ public final class CoreSessionCallback implements SessionCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NodeAnnounceMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NodeAnnounceMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NodeAnnounceMessage.java index d5ebc6b..eb7b627 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NodeAnnounceMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NodeAnnounceMessage.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; 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 NodeAnnounceMessage extends PacketImpl { protected String nodeID; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddMessage.java index 5de0d19..db20073 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddMessage.java @@ -25,7 +25,6 @@ import org.apache.activemq.core.replication.ReplicationManager.ADD_OPERATION_TYP /** * A ReplicationAddMessage - * @author <mailto:[email protected]";>Clebert Suconic</a> */ public final class ReplicationAddMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddTXMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddTXMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddTXMessage.java index a7efa96..d21c8e2 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddTXMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationAddTXMessage.java @@ -25,10 +25,6 @@ import org.apache.activemq.core.replication.ReplicationManager.ADD_OPERATION_TYP /** * A ReplicationAddMessage - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class ReplicationAddTXMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationCommitMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationCommitMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationCommitMessage.java index fec1866..5886776 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationCommitMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationCommitMessage.java @@ -21,7 +21,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A ReplicationAddMessage - * @author <mailto:[email protected]";>Clebert Suconic</a> */ public final class ReplicationCommitMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteMessage.java index 5cc244a..dcd6f28 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteMessage.java @@ -21,7 +21,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A ReplicationDeleteMessage - * @author <mailto:[email protected]";>Clebert Suconic</a> */ public final class ReplicationDeleteMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteTXMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteTXMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteTXMessage.java index b34905c..53d8a64 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteTXMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationDeleteTXMessage.java @@ -24,10 +24,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A ReplicationAddMessage - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class ReplicationDeleteTXMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeginMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeginMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeginMessage.java index b076330..494ea43 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeginMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageBeginMessage.java @@ -21,10 +21,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A ReplicationLargeMessageBeingMessage - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class ReplicationLargeMessageBeginMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageEndMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageEndMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageEndMessage.java index 7d88852..2d4bb70 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageEndMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageEndMessage.java @@ -21,10 +21,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A ReplicationLargemessageEndMessage - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class ReplicationLargeMessageEndMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageWriteMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageWriteMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageWriteMessage.java index d75ab5b..ee09042 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageWriteMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationLargeMessageWriteMessage.java @@ -23,8 +23,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A ReplicationLargeMessageWriteMessage - * - * @author <mailto:[email protected]";>Clebert Suconic</a> */ public final class ReplicationLargeMessageWriteMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageEventMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageEventMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageEventMessage.java index a7af525..c543877 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageEventMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageEventMessage.java @@ -22,7 +22,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A ReplicationPageWrite - * @author <mailto:[email protected]";>Clebert Suconic</a> */ public class ReplicationPageEventMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageWriteMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageWriteMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageWriteMessage.java index 1414d77..b598825 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageWriteMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPageWriteMessage.java @@ -23,10 +23,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A ReplicationPageWrite - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class ReplicationPageWriteMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPrepareMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPrepareMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPrepareMessage.java index d389615..e40f22a 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPrepareMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationPrepareMessage.java @@ -22,9 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.journal.EncodingSupport; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <mailto:[email protected]";>Clebert Suconic</a> - */ public final class ReplicationPrepareMessage extends PacketImpl { private long txId; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationResponseMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationResponseMessage.java index 7fb59df..2f66c51 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationResponseMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReplicationResponseMessage.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public final class ReplicationResponseMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/protocol/stomp/WebSocketServerHandler.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/protocol/stomp/WebSocketServerHandler.java b/activemq-server/src/main/java/org/apache/activemq/core/protocol/stomp/WebSocketServerHandler.java index 37dff08..0149e54 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/protocol/stomp/WebSocketServerHandler.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/protocol/stomp/WebSocketServerHandler.java @@ -45,13 +45,6 @@ import static io.netty.handler.codec.http.HttpMethod.GET; import static io.netty.handler.codec.http.HttpResponseStatus.FORBIDDEN; import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1; - -/** - * @author <a href="http://www.jboss.org/netty/";>The Netty Project</a> - * @author <a href="http://gleamynode.net/";>Trustin Lee</a> - * @author <a href="http://jmesnil.net/";>Jeff Mesnil</a - * @author <a href="mailto:[email protected]";>Norman Maurer</a> - */ public class WebSocketServerHandler extends SimpleChannelInboundHandler<Object> { private static final String WEBSOCKET_PATH = "/stomp"; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/registry/JndiBindingRegistry.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/registry/JndiBindingRegistry.java b/activemq-server/src/main/java/org/apache/activemq/core/registry/JndiBindingRegistry.java index 7e2382d..5b33e31 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/registry/JndiBindingRegistry.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/registry/JndiBindingRegistry.java @@ -22,10 +22,6 @@ import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; -/** - * @author <a href="mailto:[email protected]";>Bill Burke</a> - * @version $Revision: 1 $ - */ public class JndiBindingRegistry implements BindingRegistry { private Context context; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/registry/MapBindingRegistry.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/registry/MapBindingRegistry.java b/activemq-server/src/main/java/org/apache/activemq/core/registry/MapBindingRegistry.java index 8acb371..10beb52 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/registry/MapBindingRegistry.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/registry/MapBindingRegistry.java @@ -21,10 +21,6 @@ import java.util.concurrent.ConcurrentMap; import org.apache.activemq.spi.core.naming.BindingRegistry; -/** - * @author <a href="mailto:[email protected]";>Bill Burke</a> - * @version $Revision: 1 $ - */ public class MapBindingRegistry implements BindingRegistry { protected ConcurrentMap<String, Object> registry = new ConcurrentHashMap<String, Object>(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptor.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptor.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptor.java index 3603e98..53cdd65 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptor.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptor.java @@ -42,8 +42,6 @@ import org.apache.activemq.utils.TypedProperties; /** * A InVMAcceptor - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public final class InVMAcceptor implements Acceptor { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptorFactory.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptorFactory.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptorFactory.java index 1495571..2bb5a5d 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptorFactory.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMAcceptorFactory.java @@ -29,9 +29,6 @@ import org.apache.activemq.spi.core.remoting.ConnectionLifeCycleListener; /** * A InVMAcceptorFactory - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class InVMAcceptorFactory implements AcceptorFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnection.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnection.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnection.java index 37e2acb..389bbf0 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnection.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnection.java @@ -39,8 +39,6 @@ import org.apache.activemq.utils.UUIDGenerator; /** * A InVMConnection - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public class InVMConnection implements Connection { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnector.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnector.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnector.java index a65e56a..f4c0e49 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnector.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnector.java @@ -38,10 +38,6 @@ import org.apache.activemq.utils.OrderedExecutorFactory; /** * A InVMConnector - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - * */ public class InVMConnector extends AbstractConnector { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnectorFactory.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnectorFactory.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnectorFactory.java index e800bd1..b6712b3 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnectorFactory.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMConnectorFactory.java @@ -28,9 +28,6 @@ import org.apache.activemq.spi.core.remoting.ConnectorFactory; /** * A InVMConnectorFactory - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> */ public class InVMConnectorFactory implements ConnectorFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMRegistry.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMRegistry.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMRegistry.java index e6a8c03..02a724a 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMRegistry.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/InVMRegistry.java @@ -23,9 +23,6 @@ import java.util.concurrent.ConcurrentMap; /** * A InVMRegistry - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public final class InVMRegistry { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/TransportConstants.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/TransportConstants.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/TransportConstants.java index 45b75d4..dbd6c0f 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/TransportConstants.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/invm/TransportConstants.java @@ -19,11 +19,6 @@ package org.apache.activemq.core.remoting.impl.invm; /** * A TransportConstants - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - * @author ClebertSuconic - * */ public final class TransportConstants { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpAcceptorHandler.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpAcceptorHandler.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpAcceptorHandler.java index 5535ceb..ab87248 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpAcceptorHandler.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpAcceptorHandler.java @@ -40,7 +40,6 @@ import io.netty.util.ReferenceCountUtil; /** * Ensures that every request has a response and also that any uninitiated responses always wait for * a response. - * @author <a href="mailto:[email protected]";>Andy Taylor</a> */ public class HttpAcceptorHandler extends ChannelDuplexHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpKeepAliveRunnable.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpKeepAliveRunnable.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpKeepAliveRunnable.java index f3bee5c..b0c41bd 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpKeepAliveRunnable.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/HttpKeepAliveRunnable.java @@ -22,8 +22,6 @@ import java.util.concurrent.Future; /** * A simple Runnable to allow {@link HttpAcceptorHandler}s to be called intermittently. - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public class HttpKeepAliveRunnable implements Runnable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java index 5e237d7..3c59a03 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptor.java @@ -80,13 +80,6 @@ import org.apache.activemq.utils.TypedProperties; /** * A Netty TCP Acceptor that supports SSL - * - * @author <a href="[email protected]">Andy Taylor</a> - * @author <a href="[email protected]">Tim Fox</a> - * @author <a href="[email protected]">Trustin Lee</a> - * @author <a href="[email protected]">Jeff Mesnil</a> - * @author <a href="[email protected]">Norman Maurer</a> - * @version $Rev$, $Date$ */ public class NettyAcceptor implements Acceptor { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptorFactory.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptorFactory.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptorFactory.java index 674200c..9f01629 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptorFactory.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyAcceptorFactory.java @@ -29,8 +29,6 @@ import org.apache.activemq.spi.core.remoting.ConnectionLifeCycleListener; /** * A NettyAcceptorFactory - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public class NettyAcceptorFactory implements AcceptorFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyServerConnection.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyServerConnection.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyServerConnection.java index 339b407..55bd8d0 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyServerConnection.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyServerConnection.java @@ -23,9 +23,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.buffers.impl.ChannelBufferWrapper; import org.apache.activemq.spi.core.remoting.ConnectionLifeCycleListener; -/** - * @author <a href="mailto:[email protected]";>Norman Maurer</a> - */ public class NettyServerConnection extends NettyConnection { public NettyServerConnection(Map<String, Object> configuration, Channel channel, ConnectionLifeCycleListener listener, boolean batchingEnabled, boolean directDeliver) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/RemotingService.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/RemotingService.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/RemotingService.java index 81d29bd..ff019f0 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/RemotingService.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/RemotingService.java @@ -25,11 +25,6 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection; import org.apache.activemq.spi.core.remoting.Acceptor; import org.apache.activemq.utils.ReusableLatch; -/** - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public interface RemotingService { /** http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/impl/RemotingServiceImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/impl/RemotingServiceImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/impl/RemotingServiceImpl.java index bdbebdf..10b0106 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/impl/RemotingServiceImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/remoting/server/impl/RemotingServiceImpl.java @@ -70,12 +70,6 @@ import org.apache.activemq.utils.ConfigurationHelper; import org.apache.activemq.utils.ActiveMQThreadFactory; import org.apache.activemq.utils.ReusableLatch; -/** - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> - */ public class RemotingServiceImpl implements RemotingService, ConnectionLifeCycleListener { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicatedJournal.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicatedJournal.java b/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicatedJournal.java index 7c3be33..d582549 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicatedJournal.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicatedJournal.java @@ -38,7 +38,7 @@ import org.apache.activemq.core.replication.ReplicationManager.ADD_OPERATION_TYP * <p> * This class wraps a {@link ReplicationManager} and the local {@link Journal}. Every call will be * relayed to both instances. - * @author <mailto:[email protected]";>Clebert Suconic</a> + * * @see org.apache.activemq.core.persistence.impl.journal.JournalStorageManager */ public class ReplicatedJournal implements Journal http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationEndpoint.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationEndpoint.java b/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationEndpoint.java index 1473ae8..9b0872b 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationEndpoint.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationEndpoint.java @@ -83,8 +83,6 @@ import org.apache.activemq.core.server.impl.SharedNothingBackupActivation; /** * Handles all the synchronization necessary for replication on the backup side (that is the * backup's side of the "remote backup" use case). - * - * @author <mailto:[email protected]";>Clebert Suconic</a> */ public final class ReplicationEndpoint implements ChannelHandler, ActiveMQComponent { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationManager.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationManager.java b/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationManager.java index 203c9fd..698962a 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationManager.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/replication/ReplicationManager.java @@ -71,7 +71,6 @@ import org.apache.activemq.utils.ExecutorFactory; * <p/> * Its equivalent in the backup server is {@link ReplicationEndpoint}. * - * @author <mailto:[email protected]";>Clebert Suconic</a> * @see ReplicationEndpoint */ public final class ReplicationManager implements ActiveMQComponent http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/security/CheckType.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/security/CheckType.java b/activemq-server/src/main/java/org/apache/activemq/core/security/CheckType.java index fe08dca..e235ec5 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/security/CheckType.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/security/CheckType.java @@ -16,13 +16,6 @@ */ package org.apache.activemq.core.security; -/** - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]>Andy Taylor</a> - * @version $Revision: 2925 $ - * <p/> - * $Id: $ - */ public enum CheckType { SEND http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/security/SecurityStore.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/security/SecurityStore.java b/activemq-server/src/main/java/org/apache/activemq/core/security/SecurityStore.java index e59ef42..67c55fd 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/security/SecurityStore.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/security/SecurityStore.java @@ -19,11 +19,6 @@ package org.apache.activemq.core.security; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.server.ServerSession; -/** - * @author <a href="mailto:[email protected]";>Ovidiu Feodorov</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public interface SecurityStore { void authenticate(String user, String password) throws Exception; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/security/User.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/security/User.java b/activemq-server/src/main/java/org/apache/activemq/core/security/User.java index 528530d..e79334f 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/security/User.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/security/User.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.security; -/** -* @author <a href="mailto:[email protected]";>Andy Taylor</a> -*/ public class User { final String user; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/security/impl/SecurityStoreImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/security/impl/SecurityStoreImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/security/impl/SecurityStoreImpl.java index b6eb863..53ff7b4 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/security/impl/SecurityStoreImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/security/impl/SecurityStoreImpl.java @@ -39,13 +39,6 @@ import org.apache.activemq.utils.TypedProperties; /** * The ActiveMQ SecurityStore implementation - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="[email protected]">Andy Taylor</a> - * - * - * @version $Revision$ - * */ public class SecurityStoreImpl implements SecurityStore, HierarchicalRepositoryChangeListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ActivateCallback.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ActivateCallback.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ActivateCallback.java index 819ef8e..4fe2061 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ActivateCallback.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ActivateCallback.java @@ -18,10 +18,6 @@ package org.apache.activemq.core.server; /** * A ActivateCallback - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * */ public interface ActivateCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQMessageBundle.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQMessageBundle.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQMessageBundle.java index 488e642..ef2e810 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQMessageBundle.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQMessageBundle.java @@ -52,8 +52,6 @@ import java.io.File; * <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> */ @MessageBundle(projectCode = "AMQ") public interface ActiveMQMessageBundle http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServer.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServer.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServer.java index 2197690..8888588 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServer.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServer.java @@ -53,8 +53,6 @@ import org.apache.activemq.utils.ExecutorFactory; * of the server. * <p> * This is not part of our public API. - * @author <a href="[email protected]">Tim Fox</a> - * @author <a href="[email protected]">Andy Taylor</a> */ public interface ActiveMQServer extends ActiveMQComponent { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServerLogger.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServerLogger.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServerLogger.java index 69f612b..fb64626 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServerLogger.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServerLogger.java @@ -17,9 +17,6 @@ package org.apache.activemq.core.server; /** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * 3/8/12 - * * Logger Code 22 * * 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-server/src/main/java/org/apache/activemq/core/server/ActiveMQServers.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServers.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServers.java index 730a2c8..36d0cdb 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServers.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServers.java @@ -30,7 +30,6 @@ import org.apache.activemq.spi.core.security.ActiveMQSecurityManagerImpl; * <p> * This class should be used when you want to instantiate a ActiveMQServer instance for embedding in * your own application, as opposed to directly instantiating an implementing instance. - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public final class ActiveMQServers { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/AutoCreatedQueueManager.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/AutoCreatedQueueManager.java b/activemq-server/src/main/java/org/apache/activemq/core/server/AutoCreatedQueueManager.java index 03d4d88..32c6e4a 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/AutoCreatedQueueManager.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/AutoCreatedQueueManager.java @@ -19,10 +19,6 @@ package org.apache.activemq.core.server; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.utils.ReferenceCounter; -/** - * @author Clebert Suconic - */ - public interface AutoCreatedQueueManager extends ReferenceCounter { SimpleString getQueueName(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/Bindable.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/Bindable.java b/activemq-server/src/main/java/org/apache/activemq/core/server/Bindable.java index c4491f3..afd88f6 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/Bindable.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/Bindable.java @@ -18,12 +18,6 @@ package org.apache.activemq.core.server; /** * A Bindable - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 21 Dec 2008 09:10:18 - * - * */ public interface Bindable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/BindingQueryResult.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/BindingQueryResult.java b/activemq-server/src/main/java/org/apache/activemq/core/server/BindingQueryResult.java index 33339cf..70eb290 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/BindingQueryResult.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/BindingQueryResult.java @@ -21,11 +21,7 @@ import java.util.List; import org.apache.activemq.api.core.SimpleString; /** - * * A BindingQueryResult - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class BindingQueryResult { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java index 64d7c91..546481a 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java @@ -16,10 +16,6 @@ */ package org.apache.activemq.core.server; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * Created Jun 29, 2010 - */ public interface ConnectorService extends ActiveMQComponent { String getName(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorServiceFactory.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorServiceFactory.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorServiceFactory.java index e52b12c..9cb6684 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorServiceFactory.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorServiceFactory.java @@ -23,10 +23,6 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.ScheduledExecutorService; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * Created Jun 29, 2010 - */ public interface ConnectorServiceFactory { ConnectorService createConnectorService(String connectorName, Map<String, Object> configuration, http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/Consumer.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/Consumer.java b/activemq-server/src/main/java/org/apache/activemq/core/server/Consumer.java index 0ba0a70..98b91dc 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/Consumer.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/Consumer.java @@ -21,11 +21,7 @@ import java.util.List; import org.apache.activemq.core.filter.Filter; /** - * * A ClientConsumer - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public interface Consumer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/Divert.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/Divert.java b/activemq-server/src/main/java/org/apache/activemq/core/server/Divert.java index ba736b9..44a54dd 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/Divert.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/Divert.java @@ -21,12 +21,6 @@ import org.apache.activemq.core.filter.Filter; /** * A Divert - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 24 Dec 2008 09:58:04 - * - * */ public interface Divert extends Bindable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/HandleStatus.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/HandleStatus.java b/activemq-server/src/main/java/org/apache/activemq/core/server/HandleStatus.java index ced846a..625098f 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/HandleStatus.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/HandleStatus.java @@ -25,9 +25,6 @@ package org.apache.activemq.core.server; * NO_MATCH means the MessageReference was rejected by a Filter * * BUSY means the MessageReference was rejected since the ClientConsumer was busy - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public enum HandleStatus { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/JournalType.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/JournalType.java b/activemq-server/src/main/java/org/apache/activemq/core/server/JournalType.java index 16fcac0..d318825 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/JournalType.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/JournalType.java @@ -17,11 +17,7 @@ package org.apache.activemq.core.server; /** - * * A JournalType - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public enum JournalType { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/LargeServerMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/LargeServerMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/server/LargeServerMessage.java index 24aac5f..78277ae 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/LargeServerMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/LargeServerMessage.java @@ -23,8 +23,6 @@ import org.apache.activemq.core.replication.ReplicatedLargeMessage; /** * A LargeMessage - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public interface LargeServerMessage extends ServerMessage, ReplicatedLargeMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/LiveNodeLocator.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/LiveNodeLocator.java b/activemq-server/src/main/java/org/apache/activemq/core/server/LiveNodeLocator.java index 4452bd2..f90f67a 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/LiveNodeLocator.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/LiveNodeLocator.java @@ -28,9 +28,6 @@ import org.apache.activemq.core.server.cluster.qourum.SharedNothingBackupQuorum; * is a job for the implementation. * * This is used for replication (which needs a QuorumManager) and scaling-down (which does not need a QuorumManager). - * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @author Justin Bertram */ public abstract class LiveNodeLocator implements ClusterTopologyListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/MemoryManager.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/MemoryManager.java b/activemq-server/src/main/java/org/apache/activemq/core/server/MemoryManager.java index 335057e..bb3bb79 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/MemoryManager.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/MemoryManager.java @@ -23,7 +23,6 @@ import org.apache.activemq.utils.SizeFormatterUtil; * <p> * This class will run a thread monitoring memory usage and log warnings in case we are low on * memory. - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public class MemoryManager implements ActiveMQComponent { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/MessageReference.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/MessageReference.java b/activemq-server/src/main/java/org/apache/activemq/core/server/MessageReference.java index d037d72..b2b6c3c 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/MessageReference.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/MessageReference.java @@ -21,10 +21,6 @@ package org.apache.activemq.core.server; * A reference to a message. * * Channels store message references rather than the messages themselves. - * - * @author <a href="mailto:[email protected]";>Ovidiu Feodorov</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public interface MessageReference { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/NodeManager.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/NodeManager.java b/activemq-server/src/main/java/org/apache/activemq/core/server/NodeManager.java index b725da7..3735ae7 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/NodeManager.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/NodeManager.java @@ -27,11 +27,6 @@ import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.utils.UUID; import org.apache.activemq.utils.UUIDGenerator; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * Date: Oct 13, 2010 - * Time: 2:38:40 PM - */ public abstract class NodeManager implements ActiveMQComponent { protected static final byte FIRST_TIME_START = '0'; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/Queue.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/Queue.java b/activemq-server/src/main/java/org/apache/activemq/core/server/Queue.java index e3d2d2c..9f613ee 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/Queue.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/Queue.java @@ -30,10 +30,6 @@ import org.apache.activemq.utils.ReferenceCounter; /** * A Queue - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="[email protected]">Andy Taylor</a> - * @author <a href="[email protected]">Clebert Suconic</a> */ public interface Queue extends Bindable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/QueueFactory.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/QueueFactory.java b/activemq-server/src/main/java/org/apache/activemq/core/server/QueueFactory.java index 8e9e7ed..a4225e4 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/QueueFactory.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/QueueFactory.java @@ -27,9 +27,6 @@ import org.apache.activemq.core.postoffice.PostOffice; * * Implementations of this class know how to create queues with the correct attribute values * based on default and overrides - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public interface QueueFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/RouteContextList.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/RouteContextList.java b/activemq-server/src/main/java/org/apache/activemq/core/server/RouteContextList.java index 8c49ba2..91d7e76 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/RouteContextList.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/RouteContextList.java @@ -20,10 +20,6 @@ import java.util.List; /** * This is a simple datatype containing the list of a routing context - * - * @author clebertsuconic - * - * */ public interface RouteContextList { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/RoutingContext.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/RoutingContext.java b/activemq-server/src/main/java/org/apache/activemq/core/server/RoutingContext.java index 3cd18b9..ea3f987 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/RoutingContext.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/RoutingContext.java @@ -24,11 +24,6 @@ import org.apache.activemq.core.transaction.Transaction; /** * A RoutingContext - * - * @author Tim Fox - * @author Clebert Suconic - * - * */ public interface RoutingContext { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ScheduledDeliveryHandler.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ScheduledDeliveryHandler.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ScheduledDeliveryHandler.java index e977078..0d4dee7 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ScheduledDeliveryHandler.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ScheduledDeliveryHandler.java @@ -20,9 +20,6 @@ import org.apache.activemq.core.filter.Filter; import java.util.List; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - */ public interface ScheduledDeliveryHandler { boolean checkAndSchedule(MessageReference ref, final boolean tail); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ServerConsumer.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ServerConsumer.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ServerConsumer.java index d5bdc16..52fa1de 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ServerConsumer.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ServerConsumer.java @@ -23,9 +23,6 @@ import org.apache.activemq.core.transaction.Transaction; /** * * A ServerConsumer - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public interface ServerConsumer extends Consumer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ServerMessage.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ServerMessage.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ServerMessage.java index 5fc0f7d..f3ceaee 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ServerMessage.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ServerMessage.java @@ -24,10 +24,6 @@ import org.apache.activemq.core.paging.PagingStore; /** * * A ServerMessage - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * */ public interface ServerMessage extends MessageInternal, EncodingSupport { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/ServerSession.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ServerSession.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ServerSession.java index cf0b900..e05cf7a 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ServerSession.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ServerSession.java @@ -29,9 +29,6 @@ import org.apache.activemq.utils.json.JSONArray; /** * A ServerSession - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]>Andy Taylor</a> */ public interface ServerSession { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/TransientQueueManager.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/TransientQueueManager.java b/activemq-server/src/main/java/org/apache/activemq/core/server/TransientQueueManager.java index 288d30f..b53b4de 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/TransientQueueManager.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/TransientQueueManager.java @@ -19,10 +19,6 @@ package org.apache.activemq.core.server; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.utils.ReferenceCounter; -/** - * @author Clebert Suconic - */ - public interface TransientQueueManager extends ReferenceCounter { SimpleString getQueueName(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ActiveMQServerSideProtocolManagerFactory.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ActiveMQServerSideProtocolManagerFactory.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ActiveMQServerSideProtocolManagerFactory.java index b0839c0..395f365 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ActiveMQServerSideProtocolManagerFactory.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ActiveMQServerSideProtocolManagerFactory.java @@ -24,7 +24,6 @@ import org.apache.activemq.spi.core.remoting.ClientProtocolManagerFactory; /** * A protocol manager that will replace the packet manager for inter-server communications - * @author Clebert Suconic */ public class ActiveMQServerSideProtocolManagerFactory implements ClientProtocolManagerFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Bridge.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Bridge.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Bridge.java index 209d367..b38919e 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Bridge.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Bridge.java @@ -25,13 +25,6 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection; /** * A Core Bridge - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * - * Created 15 Nov 2008 09:42:31 - * - * */ public interface Bridge extends Consumer, ActiveMQComponent { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/BroadcastGroup.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/BroadcastGroup.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/BroadcastGroup.java index 22baee7..f2f3659 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/BroadcastGroup.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/BroadcastGroup.java @@ -22,13 +22,6 @@ import org.apache.activemq.core.server.management.NotificationService; /** * A BroadcastGroup - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * - * Created 18 Nov 2008 09:29:45 - * - * */ public interface BroadcastGroup extends ActiveMQComponent { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterConnection.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterConnection.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterConnection.java index bd7613c..d12715f 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterConnection.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterConnection.java @@ -28,12 +28,6 @@ import org.apache.activemq.core.server.ActiveMQServer; /** * A ClusterConnection - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 23 Jan 2009 14:51:55 - * - * */ public interface ClusterConnection extends ActiveMQComponent, ClusterTopologyListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterManager.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterManager.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterManager.java index 5c5362e..24ed7c0 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterManager.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/ClusterManager.java @@ -73,9 +73,6 @@ import org.apache.activemq.utils.FutureLatch; * Note that {@link org.apache.activemq.core.server.cluster.impl.ClusterConnectionBridge}s extend Bridges but are controlled over through * {@link ClusterConnectionImpl}. As a node is discovered a new {@link org.apache.activemq.core.server.cluster.impl.ClusterConnectionBridge} is * deployed. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author Clebert Suconic */ public final class ClusterManager implements ActiveMQComponent { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/MessageFlowRecord.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/MessageFlowRecord.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/MessageFlowRecord.java index 48a968e..671decf 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/MessageFlowRecord.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/MessageFlowRecord.java @@ -20,12 +20,6 @@ import org.apache.activemq.api.core.client.MessageHandler; /** * A MessageFlowRecord - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 5 Feb 2009 11:39:36 - * - * */ public interface MessageFlowRecord extends MessageHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/RemoteQueueBinding.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/RemoteQueueBinding.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/RemoteQueueBinding.java index fdfa7f0..84516ba 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/RemoteQueueBinding.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/RemoteQueueBinding.java @@ -21,12 +21,6 @@ import org.apache.activemq.core.postoffice.QueueBinding; /** * A RemoteQueueBinding - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 23 Jan 2009 11:58:05 - * - * */ public interface RemoteQueueBinding extends QueueBinding { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Transformer.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Transformer.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Transformer.java index 4879418..7d5a1c0 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Transformer.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/Transformer.java @@ -20,12 +20,6 @@ import org.apache.activemq.core.server.ServerMessage; /** * A Transformer - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 18 Nov 2008 11:01:50 - * - * */ public interface Transformer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BridgeImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BridgeImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BridgeImpl.java index 175254f..0f7ef6b 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BridgeImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BridgeImpl.java @@ -64,12 +64,6 @@ import org.apache.activemq.utils.UUID; /** * A Core BridgeImpl - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author Clebert Suconic - * <p/> - * Created 12 Nov 2008 11:37:35 */ public class BridgeImpl implements Bridge, SessionFailureListener, SendAcknowledgementHandler http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BroadcastGroupImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BroadcastGroupImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BroadcastGroupImpl.java index bdb5667..69c8b6b 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BroadcastGroupImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/BroadcastGroupImpl.java @@ -43,12 +43,6 @@ import org.apache.activemq.utils.UUIDGenerator; * * <p>This is totally generic to the mechanism used on the transmission. It originally only had UDP but this got refactored * into sub classes of {@link BroadcastEndpoint}</p> - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author Clebert Suconic - * - * Created 15 Nov 2008 09:45:32 - * */ public class BroadcastGroupImpl implements BroadcastGroup, Runnable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionBridge.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionBridge.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionBridge.java index 51e9745..ec4fcc9 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionBridge.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionBridge.java @@ -54,10 +54,6 @@ import org.apache.activemq.utils.UUIDGenerator; * A bridge with extra functionality only available when the server is clustered. * <p> * Such as such adding extra properties and setting up notifications between the nodes. - * - * @author tim - * @author Clebert Suconic - * @author <a href="mtaylor@redhat,com">Martyn Taylor</a> */ public class ClusterConnectionBridge extends BridgeImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionImpl.java index 212c785..6578e63 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/ClusterConnectionImpl.java @@ -73,9 +73,6 @@ import org.apache.activemq.utils.TypedProperties; /** * A ClusterConnectionImpl - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author Clebert Suconic */ public final class ClusterConnectionImpl implements ClusterConnection, AfterConnectInternalListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/Redistributor.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/Redistributor.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/Redistributor.java index d8d6b99..1f30fc7 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/Redistributor.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/Redistributor.java @@ -39,10 +39,6 @@ import org.apache.activemq.utils.ReusableLatch; /** * A Redistributor - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * <p/> - * Created 8 Feb 2009 14:23:41 */ public class Redistributor implements Consumer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/RemoteQueueBindingImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/RemoteQueueBindingImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/RemoteQueueBindingImpl.java index afdb00c..7e894c7 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/RemoteQueueBindingImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/impl/RemoteQueueBindingImpl.java @@ -37,12 +37,6 @@ import org.apache.activemq.core.server.cluster.RemoteQueueBinding; /** * A RemoteQueueBindingImpl - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 21 Jan 2009 18:55:22 - * - * */ public class RemoteQueueBindingImpl implements RemoteQueueBinding { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/qourum/SharedNothingBackupQuorum.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/qourum/SharedNothingBackupQuorum.java b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/qourum/SharedNothingBackupQuorum.java index aef677f..967a551 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/qourum/SharedNothingBackupQuorum.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/cluster/qourum/SharedNothingBackupQuorum.java @@ -31,10 +31,6 @@ import org.apache.activemq.core.remoting.FailureListener; import org.apache.activemq.core.server.ActiveMQServerLogger; import org.apache.activemq.core.server.NodeManager; -/** - * @author Andy Taylor - */ - public class SharedNothingBackupQuorum implements Quorum, FailureListener { public enum BACKUP_ACTIVATION http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/embedded/EmbeddedActiveMQ.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/embedded/EmbeddedActiveMQ.java b/activemq-server/src/main/java/org/apache/activemq/core/server/embedded/EmbeddedActiveMQ.java index 45deccc..4290848 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/embedded/EmbeddedActiveMQ.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/embedded/EmbeddedActiveMQ.java @@ -28,9 +28,6 @@ import org.apache.activemq.spi.core.security.ActiveMQSecurityManagerImpl; /** * Helper class to simplify bootstrap of ActiveMQ server. Bootstraps from classpath-based config files. - * - * @author <a href="mailto:[email protected]";>Bill Burke</a> - * @version $Revision: 1 $ */ public class EmbeddedActiveMQ { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/group/GroupingHandler.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/group/GroupingHandler.java b/activemq-server/src/main/java/org/apache/activemq/core/server/group/GroupingHandler.java index 964f617..7e44eb7 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/group/GroupingHandler.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/group/GroupingHandler.java @@ -23,9 +23,6 @@ import org.apache.activemq.core.server.group.impl.Proposal; import org.apache.activemq.core.server.group.impl.Response; import org.apache.activemq.core.server.management.NotificationListener; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - */ public interface GroupingHandler extends NotificationListener, ActiveMQComponent { // this method should maintain a WeakHash list, no need to remove the elements http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/group/UnproposalListener.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/group/UnproposalListener.java b/activemq-server/src/main/java/org/apache/activemq/core/server/group/UnproposalListener.java index db83512..9e48196 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/group/UnproposalListener.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/group/UnproposalListener.java @@ -18,10 +18,6 @@ package org.apache.activemq.core.server.group; import org.apache.activemq.api.core.SimpleString; -/** - * @author Clebert Suconic - */ - public interface UnproposalListener { void unproposed(SimpleString groupID); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupBinding.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupBinding.java b/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupBinding.java index 418b49d..fdb4d13 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupBinding.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupBinding.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.SimpleString; /** * A group binding - * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * Created Oct 19, 2009 */ public class GroupBinding { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupHandlingAbstract.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupHandlingAbstract.java b/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupHandlingAbstract.java index 994ce7a..96232c9 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupHandlingAbstract.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/group/impl/GroupHandlingAbstract.java @@ -32,10 +32,6 @@ import org.apache.activemq.core.server.management.ManagementService; import org.apache.activemq.core.server.management.Notification; import org.apache.activemq.utils.TypedProperties; -/** - * @author Clebert Suconic - */ - public abstract class GroupHandlingAbstract implements GroupingHandler { protected final Executor executor;
