http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerReceiverContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerReceiverContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerReceiverContext.java index 5e4ccc1..71bef17 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerReceiverContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerReceiverContext.java @@ -34,10 +34,6 @@ import org.proton.plug.logger.ActiveMQAMQPProtocolMessageBundle; import static org.proton.plug.util.DeliveryUtil.readDelivery; -/** - * @author Clebert Suconic - */ - public class ProtonServerReceiverContext extends AbstractProtonReceiverContext {
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java index b22927e..f2c6d68 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java @@ -39,10 +39,6 @@ import org.proton.plug.logger.ActiveMQAMQPProtocolMessageBundle; import org.proton.plug.context.ProtonPlugSender; import org.apache.qpid.proton.amqp.messaging.Source; -/** - * @author Clebert Suconic - */ - public class ProtonServerSenderContext extends AbstractProtonContextSender implements ProtonPlugSender { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSessionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSessionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSessionContext.java index 5a9bea3..99bae30 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSessionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSessionContext.java @@ -32,10 +32,6 @@ import org.proton.plug.context.AbstractProtonSessionContext; import org.proton.plug.context.ProtonTransactionHandler; import org.proton.plug.exceptions.ActiveMQAMQPException; -/** - * @author Clebert Suconic - */ - public class ProtonServerSessionContext extends AbstractProtonSessionContext { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPException.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPException.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPException.java index cd0e719..ec9f656 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPException.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPException.java @@ -18,10 +18,6 @@ package org.proton.plug.exceptions; import org.apache.qpid.proton.amqp.Symbol; -/** - * @author <a href="mailto:[email protected]">Andy Taylor</a> - * 6/6/13 - */ public class ActiveMQAMQPException extends Exception { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPIllegalStateException.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPIllegalStateException.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPIllegalStateException.java index 87e0ee6..6f7fff8 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPIllegalStateException.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPIllegalStateException.java @@ -18,10 +18,6 @@ package org.proton.plug.exceptions; import org.apache.qpid.proton.amqp.transport.AmqpError; -/** - * @author <a href="mailto:[email protected]">Andy Taylor</a> - * 6/6/13 - */ public class ActiveMQAMQPIllegalStateException extends ActiveMQAMQPException { public ActiveMQAMQPIllegalStateException(String message) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInternalErrorException.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInternalErrorException.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInternalErrorException.java index 344fa25..decf7d9 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInternalErrorException.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInternalErrorException.java @@ -18,10 +18,6 @@ package org.proton.plug.exceptions; import org.apache.qpid.proton.amqp.transport.AmqpError; -/** - * @author <a href="mailto:[email protected]">Andy Taylor</a> - * 6/6/13 - */ public class ActiveMQAMQPInternalErrorException extends ActiveMQAMQPException { public ActiveMQAMQPInternalErrorException(String message, Throwable e) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInvalidFieldException.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInvalidFieldException.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInvalidFieldException.java index 502afbc..c934be0 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInvalidFieldException.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPInvalidFieldException.java @@ -18,10 +18,6 @@ package org.proton.plug.exceptions; import org.apache.qpid.proton.amqp.transport.AmqpError; -/** - * @author <a href="mailto:[email protected]">Andy Taylor</a> - * 6/6/13 - */ public class ActiveMQAMQPInvalidFieldException extends ActiveMQAMQPException { public ActiveMQAMQPInvalidFieldException(String message) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPNotImplementedException.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPNotImplementedException.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPNotImplementedException.java index c9419d3..31dd3ab 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPNotImplementedException.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPNotImplementedException.java @@ -18,10 +18,6 @@ package org.proton.plug.exceptions; import org.apache.qpid.proton.amqp.transport.AmqpError; -/** - * @author <a href="mailto:[email protected]">Andy Taylor</a> - * 6/19/13 - */ public class ActiveMQAMQPNotImplementedException extends ActiveMQAMQPException { public ActiveMQAMQPNotImplementedException(String message) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPTimeoutException.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPTimeoutException.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPTimeoutException.java index ea48cca..fd66d71 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPTimeoutException.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/exceptions/ActiveMQAMQPTimeoutException.java @@ -18,10 +18,6 @@ package org.proton.plug.exceptions; import org.apache.qpid.proton.amqp.transport.AmqpError; -/** - * @author Clebert Suconic - */ - public class ActiveMQAMQPTimeoutException extends ActiveMQAMQPException { public ActiveMQAMQPTimeoutException(String message) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/EventHandler.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/EventHandler.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/EventHandler.java index afdbd92..54eab43 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/EventHandler.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/EventHandler.java @@ -24,11 +24,7 @@ import org.apache.qpid.proton.engine.Transport; /** * EventHandler - * <p/> - * - * @author rhs */ - public interface EventHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/Events.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/Events.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/Events.java index 6b7c75a..cff3162 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/Events.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/Events.java @@ -21,10 +21,7 @@ import org.apache.qpid.proton.engine.Transport; /** * TODO : this needs a better home - * - * @author rhs */ - public final class Events { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/ProtonHandler.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/ProtonHandler.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/ProtonHandler.java index dfbc341..277bc72 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/ProtonHandler.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/ProtonHandler.java @@ -26,10 +26,7 @@ import org.proton.plug.handler.impl.ProtonHandlerImpl; /** * This is a definition of the public interface for {@link org.proton.plug.handler.impl.ProtonHandlerImpl} - * - * @author Clebert Suconic */ - public interface ProtonHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/impl/DefaultEventHandler.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/impl/DefaultEventHandler.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/impl/DefaultEventHandler.java index afe26f1..c4d89de 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/impl/DefaultEventHandler.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/handler/impl/DefaultEventHandler.java @@ -25,8 +25,6 @@ import org.proton.plug.handler.EventHandler; /** * This is useful for cases where you only want to implement a few methods - * - * @author Clebert Suconic */ public abstract class DefaultEventHandler implements EventHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/logger/ActiveMQAMQPProtocolMessageBundle.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/logger/ActiveMQAMQPProtocolMessageBundle.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/logger/ActiveMQAMQPProtocolMessageBundle.java index bddc665..c2aa7fc 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/logger/ActiveMQAMQPProtocolMessageBundle.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/logger/ActiveMQAMQPProtocolMessageBundle.java @@ -31,8 +31,6 @@ import org.jboss.logging.Messages; * <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 ActiveMQAMQPProtocolMessageBundle http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/AnonymousServerSASL.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/AnonymousServerSASL.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/AnonymousServerSASL.java index 5dc59ee..46af760 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/AnonymousServerSASL.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/AnonymousServerSASL.java @@ -19,10 +19,6 @@ package org.proton.plug.sasl; import org.proton.plug.SASLResult; import org.proton.plug.ServerSASL; -/** - * @author Clebert Suconic - */ - public class AnonymousServerSASL implements ServerSASL { public AnonymousServerSASL() http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ClientSASLPlain.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ClientSASLPlain.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ClientSASLPlain.java index e63d011..3e0e886 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ClientSASLPlain.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ClientSASLPlain.java @@ -21,8 +21,6 @@ import org.proton.plug.ClientSASL; /** * This is a simple implementation provided with just user/password * TODO: this interface will probaby change as we are challenged with more SASL cases where there is a communication between client and server to determine the authentication - * - * @author Clebert Suconic */ public class ClientSASLPlain implements ClientSASL { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/PlainSASLResult.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/PlainSASLResult.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/PlainSASLResult.java index 05c24c2..b3ba6f2 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/PlainSASLResult.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/PlainSASLResult.java @@ -18,10 +18,6 @@ package org.proton.plug.sasl; import org.proton.plug.SASLResult; -/** - * @author Clebert Suconic - */ - public class PlainSASLResult implements SASLResult { private boolean success; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ServerSASLPlain.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ServerSASLPlain.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ServerSASLPlain.java index 158f37e..1e66b14 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ServerSASLPlain.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/sasl/ServerSASLPlain.java @@ -19,10 +19,6 @@ package org.proton.plug.sasl; import org.proton.plug.SASLResult; import org.proton.plug.ServerSASL; -/** - * @author Clebert Suconic - */ - public class ServerSASLPlain implements ServerSASL { public static final String NAME = "PLAIN"; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ByteUtil.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ByteUtil.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ByteUtil.java index ef07818..ea5a581 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ByteUtil.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ByteUtil.java @@ -19,10 +19,6 @@ package org.proton.plug.util; import io.netty.buffer.ByteBuf; import io.netty.buffer.UnpooledByteBufAllocator; -/** - * @author Clebert Suconic - */ - public class ByteUtil { public static void debugFrame(String message, ByteBuf byteIn) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CodecCache.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CodecCache.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CodecCache.java index e1f00d9..5218e2f 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CodecCache.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CodecCache.java @@ -20,10 +20,6 @@ import org.apache.qpid.proton.codec.AMQPDefinedTypes; import org.apache.qpid.proton.codec.DecoderImpl; import org.apache.qpid.proton.codec.EncoderImpl; -/** - * @author Clebert Suconic - */ - public class CodecCache { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java index 49d851b..3753449 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/CreditsSemaphore.java @@ -18,10 +18,6 @@ package org.proton.plug.util; import java.util.concurrent.locks.AbstractQueuedSynchronizer; -/** - * @author Clebert Suconic - */ - public class CreditsSemaphore { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DebugInfo.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DebugInfo.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DebugInfo.java index 9ab87cc..d6591da 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DebugInfo.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DebugInfo.java @@ -16,10 +16,6 @@ */ package org.proton.plug.util; -/** - * @author Clebert Suconic - */ - public class DebugInfo { public static final boolean debug = false; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DeliveryUtil.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DeliveryUtil.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DeliveryUtil.java index 5e94783..912c1a8 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DeliveryUtil.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/DeliveryUtil.java @@ -21,10 +21,6 @@ import org.apache.qpid.proton.engine.Receiver; import org.apache.qpid.proton.message.Message; import org.apache.qpid.proton.message.impl.MessageImpl; -/** - * @author Clebert Suconic - */ - public class DeliveryUtil { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/FutureRunnable.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/FutureRunnable.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/FutureRunnable.java index 95807d2..2467018 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/FutureRunnable.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/FutureRunnable.java @@ -18,10 +18,6 @@ package org.proton.plug.util; import java.util.concurrent.TimeUnit; -/** - * @author Clebert Suconic - */ - public class FutureRunnable implements Runnable { private final ReusableLatch latch; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/NettyWritable.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/NettyWritable.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/NettyWritable.java index 5f072a8..6838c02 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/NettyWritable.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/NettyWritable.java @@ -16,11 +16,6 @@ */ package org.proton.plug.util; -/** - * @author Clebert Suconic - */ - - import java.nio.ByteBuffer; import io.netty.buffer.ByteBuf; @@ -28,8 +23,6 @@ import org.apache.qpid.proton.codec.WritableBuffer; /** * This is to use NettyBuffer within Proton - * - * @author Clebert Suconic */ public class NettyWritable implements WritableBuffer http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ProtonServerMessage.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ProtonServerMessage.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ProtonServerMessage.java index 268c04d..2a53c59 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ProtonServerMessage.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ProtonServerMessage.java @@ -34,8 +34,6 @@ import org.apache.qpid.proton.message.ProtonJMessage; /** * This is a serverMessage that won't deal with the body - * - * @author Clebert Suconic */ public class ProtonServerMessage implements ProtonJMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java index cbca43c..2a3fabe 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/util/ReusableLatch.java @@ -32,8 +32,6 @@ import java.util.concurrent.locks.AbstractQueuedSynchronizer; * <p>Note: This latch is reusable. Once it reaches zero, you can call up again, and reuse it on further waits.</p> * <p/> * <p>For example: prepareTransaction will wait for the current completions, and further adds will be called on the latch. Later on when commit is called you can reuse the same latch.</p> - * - * @author Clebert Suconic */ public class ReusableLatch { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/AbstractJMSTest.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/AbstractJMSTest.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/AbstractJMSTest.java index c27d104..b7196d9 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/AbstractJMSTest.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/AbstractJMSTest.java @@ -31,10 +31,6 @@ import org.apache.qpid.amqp_1_0.jms.impl.QueueImpl; import org.proton.plug.test.minimalserver.DumbServer; import org.proton.plug.test.minimalserver.MinimalServer; -/** - * @author Clebert Suconic - */ - public class AbstractJMSTest { protected final boolean useHawtJMS; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/Constants.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/Constants.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/Constants.java index 330ac29..73cd9ec 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/Constants.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/Constants.java @@ -16,10 +16,6 @@ */ package org.proton.plug.test; -/** - * @author Clebert Suconic - */ - public class Constants { public static final int PORT = 5672; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/ProtonTest.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/ProtonTest.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/ProtonTest.java index ee50c0a..704d7ce 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/ProtonTest.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/ProtonTest.java @@ -53,8 +53,6 @@ import org.proton.plug.util.ByteUtil; /** * This is simulating a JMS client against a simple server - * @author <a href="mailto:[email protected]">Andy Taylor</a> - * @author Clebert Suconic */ @RunWith(Parameterized.class) public class ProtonTest extends AbstractJMSTest http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/InVMTestConnector.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/InVMTestConnector.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/InVMTestConnector.java index 9b735c8..9f06937 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/InVMTestConnector.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/InVMTestConnector.java @@ -22,8 +22,6 @@ import org.proton.plug.test.minimalclient.Connector; /** * This is used for testing, where we bypass Netty or any networking for test conditions only - * - * @author Clebert Suconic */ public class InVMTestConnector implements Connector { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/ProtonINVMSPI.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/ProtonINVMSPI.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/ProtonINVMSPI.java index 5ec633d..20060a8 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/ProtonINVMSPI.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/invm/ProtonINVMSPI.java @@ -31,10 +31,6 @@ import org.proton.plug.test.minimalserver.MinimalSessionSPI; import org.proton.plug.util.ByteUtil; import org.proton.plug.util.DebugInfo; -/** - * @author Clebert Suconic - */ - public class ProtonINVMSPI implements AMQPConnectionCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/AMQPClientSPI.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/AMQPClientSPI.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/AMQPClientSPI.java index d81b5d0..6165843 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/AMQPClientSPI.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/AMQPClientSPI.java @@ -32,10 +32,6 @@ import org.proton.plug.util.ByteUtil; import org.proton.plug.util.DebugInfo; import org.proton.plug.util.ReusableLatch; -/** - * @author Clebert Suconic - */ - public class AMQPClientSPI implements AMQPConnectionCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/Connector.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/Connector.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/Connector.java index faa342f..7ae9f5e 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/Connector.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/Connector.java @@ -18,10 +18,6 @@ package org.proton.plug.test.minimalclient; import org.proton.plug.AMQPClientConnectionContext; -/** - * @author Clebert Suconic - */ - public interface Connector { void start(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/SimpleAMQPConnector.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/SimpleAMQPConnector.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/SimpleAMQPConnector.java index cbfdc45..6945f37 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/SimpleAMQPConnector.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalclient/SimpleAMQPConnector.java @@ -31,10 +31,6 @@ import io.netty.channel.socket.nio.NioSocketChannel; import org.proton.plug.AMQPClientConnectionContext; import org.proton.plug.context.client.ProtonClientConnectionContextFactory; -/** - * @author Clebert Suconic - */ - public class SimpleAMQPConnector implements Connector { private Bootstrap bootstrap; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/DumbServer.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/DumbServer.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/DumbServer.java index 2c1a86b..fd3601c 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/DumbServer.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/DumbServer.java @@ -20,11 +20,6 @@ import java.util.concurrent.BlockingDeque; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.LinkedBlockingDeque; - -/** - * @author Clebert Suconic - */ - public class DumbServer { static ConcurrentHashMap<String, BlockingDeque<Object>> maps = new ConcurrentHashMap<>(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalConnectionSPI.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalConnectionSPI.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalConnectionSPI.java index fc07ed3..5b6e77f 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalConnectionSPI.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalConnectionSPI.java @@ -34,10 +34,6 @@ import org.proton.plug.util.ByteUtil; import org.proton.plug.util.DebugInfo; import org.proton.plug.util.ReusableLatch; -/** - * @author Clebert Suconic - */ - public class MinimalConnectionSPI implements AMQPConnectionCallback { Channel channel; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java index 35af8d2..5c43d6f 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalServer.java @@ -46,13 +46,6 @@ import org.proton.plug.test.Constants; /** * 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 MinimalServer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalSessionSPI.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalSessionSPI.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalSessionSPI.java index 6d8902d..e590c28 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalSessionSPI.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/MinimalSessionSPI.java @@ -32,10 +32,6 @@ import org.proton.plug.context.server.ProtonServerSessionContext; import org.proton.plug.SASLResult; import org.proton.plug.util.ProtonServerMessage; -/** - * @author Clebert Suconic - */ - public class MinimalSessionSPI implements AMQPSessionCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java index 076ebbd..e9aac6a 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java @@ -23,8 +23,6 @@ import java.util.concurrent.atomic.AtomicInteger; /** * A ActiveMQThreadFactory - * - * @author <a href="mailto:[email protected]">Tim Fox</a> */ public final class SimpleServerThreadFactory implements ThreadFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/sasl/PlainSASLTest.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/sasl/PlainSASLTest.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/sasl/PlainSASLTest.java index 608fde5..f34c96b 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/sasl/PlainSASLTest.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/sasl/PlainSASLTest.java @@ -22,10 +22,6 @@ import org.proton.plug.sasl.ClientSASLPlain; import org.proton.plug.sasl.PlainSASLResult; import org.proton.plug.sasl.ServerSASLPlain; -/** - * @author Clebert Suconic - */ - public class PlainSASLTest { @Test http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/CreditsSemaphoreTest.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/CreditsSemaphoreTest.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/CreditsSemaphoreTest.java index b5c286f..29d2124 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/CreditsSemaphoreTest.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/CreditsSemaphoreTest.java @@ -24,10 +24,6 @@ import org.junit.Assert; import org.junit.Test; import org.proton.plug.util.CreditsSemaphore; -/** - * @author Clebert Suconic - */ - public class CreditsSemaphoreTest { final CreditsSemaphore semaphore = new CreditsSemaphore(10); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/ReusableLatchTest.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/ReusableLatchTest.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/ReusableLatchTest.java index 19373d1..609faed 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/ReusableLatchTest.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/ReusableLatchTest.java @@ -22,9 +22,6 @@ import org.junit.Assert; import org.junit.Test; import org.proton.plug.util.ReusableLatch; -/** - * @author <a href="mailto:[email protected]">Clebert Suconic</a> - */ public class ReusableLatchTest { @Test http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/SimpleServerAbstractTest.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/SimpleServerAbstractTest.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/SimpleServerAbstractTest.java index deef4c5..a17091e 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/SimpleServerAbstractTest.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/util/SimpleServerAbstractTest.java @@ -26,10 +26,6 @@ import org.proton.plug.test.minimalserver.MinimalServer; import org.junit.After; import org.junit.Before; -/** - * @author Clebert Suconic - */ - public class SimpleServerAbstractTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompException.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompException.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompException.java index 176c05e..0f795c4 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompException.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompException.java @@ -20,9 +20,6 @@ import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.List; -/** - * @author <a href="mailto:[email protected]">Howard Gao</a> - */ public class ActiveMQStompException extends Exception { public static final int NONE = 0; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolLogger.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolLogger.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolLogger.java index 236b38c..1cceeeb 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolLogger.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolLogger.java @@ -24,9 +24,6 @@ import org.jboss.logging.annotations.Message; import org.jboss.logging.annotations.MessageLogger; /** - * @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-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolMessageBundle.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolMessageBundle.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolMessageBundle.java index b410860..8cf2a90 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolMessageBundle.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/ActiveMQStompProtocolMessageBundle.java @@ -30,8 +30,6 @@ import org.jboss.logging.Messages; * <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> - * @author <a href="mailto:[email protected]">Howard Gao</a> */ @MessageBundle(projectCode = "AMQ") http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/FrameEventListener.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/FrameEventListener.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/FrameEventListener.java index 3aebea4..f52f213 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/FrameEventListener.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/FrameEventListener.java @@ -16,10 +16,6 @@ */ package org.apache.activemq.core.protocol.stomp; -/** - * - * @author <a href="mailto:[email protected]">Howard Gao</a> - */ public interface FrameEventListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java index 9a4e7b7..482a7fa 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java @@ -48,8 +48,6 @@ import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessa /** * A StompConnection - * - * @author <a href="mailto:[email protected]">Jeff Mesnil</a> */ public final class StompConnection implements RemotingConnection { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java index 2c93407..ebb5963 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java @@ -25,8 +25,6 @@ import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessa /** * A StompDecoder - * - * @author Tim Fox */ public class StompDecoder { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompFrame.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompFrame.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompFrame.java index 20fc274..e475c54 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompFrame.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompFrame.java @@ -26,9 +26,6 @@ import org.apache.activemq.api.core.ActiveMQBuffers; /** * Represents all the data in a STOMP frame. - * - * @author <a href="http://hiramchirino.com">chirino</a> - * @author Tim Fox */ public class StompFrame { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManager.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManager.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManager.java index 73443fa..1b71987 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManager.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManager.java @@ -61,8 +61,6 @@ import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessa /** * StompProtocolManager - * - * @author <a href="mailto:[email protected]">Jeff Mesnil</a> */ class StompProtocolManager implements ProtocolManager, NotificationListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java index 257537d..a658cbc 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java @@ -25,10 +25,6 @@ import org.apache.activemq.spi.core.protocol.ProtocolManagerFactory; /** * A StompProtocolManagerFactory - * - * @author <a href="mailto:[email protected]">Jeff Mesnil</a> - * - * */ public class StompProtocolManagerFactory implements ProtocolManagerFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java index dc16365..64d2f95 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java @@ -49,8 +49,6 @@ import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessa /** * A StompSession - * - * @author <a href="mailto:[email protected]">Jeff Mesnil</a> */ public class StompSession implements SessionCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java index 124959a..dda1a73 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java @@ -18,10 +18,6 @@ package org.apache.activemq.core.protocol.stomp; /** * A StompSubscription - * - * @author <a href="mailto:[email protected]">Jeff Mesnil</a> - * - * */ public class StompSubscription { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java index bba6a8a..3640edd 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java @@ -29,8 +29,6 @@ import org.apache.activemq.core.server.impl.ServerMessageImpl; /** * A StompUtils - * - * @author <a href="mailto:[email protected]">Jeff Mesnil</a> */ public class StompUtils { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompVersions.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompVersions.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompVersions.java index 3af78e5..c353736 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompVersions.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompVersions.java @@ -18,8 +18,6 @@ package org.apache.activemq.core.protocol.stomp; /** * Stomp Spec Versions - * - * @author <a href="mailto:[email protected]">Howard Gao</a> */ public enum StompVersions { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/VersionedStompFrameHandler.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/VersionedStompFrameHandler.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/VersionedStompFrameHandler.java index d37485e..18c6038 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/VersionedStompFrameHandler.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/VersionedStompFrameHandler.java @@ -32,9 +32,6 @@ import org.apache.activemq.utils.DataConstants; import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessageBundle.BUNDLE; -/** - * @author <a href="mailto:[email protected]">Howard Gao</a> - */ public abstract class VersionedStompFrameHandler { protected StompConnection connection; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameHandlerV10.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameHandlerV10.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameHandlerV10.java index 79a4658..3ce103d 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameHandlerV10.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameHandlerV10.java @@ -29,10 +29,6 @@ import org.apache.activemq.core.server.ActiveMQServerLogger; import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessageBundle.BUNDLE; -/** -* -* @author <a href="mailto:[email protected]">Howard Gao</a> -*/ public class StompFrameHandlerV10 extends VersionedStompFrameHandler implements FrameEventListener { public StompFrameHandlerV10(StompConnection connection) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameV10.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameV10.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameV10.java index 1cc423d..e8d203d 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameV10.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v10/StompFrameV10.java @@ -18,10 +18,6 @@ package org.apache.activemq.core.protocol.stomp.v10; import org.apache.activemq.core.protocol.stomp.StompFrame; -/** - * - * @author <a href="mailto:[email protected]">Howard Gao</a> - */ public class StompFrameV10 extends StompFrame { public StompFrameV10(String command) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameHandlerV11.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameHandlerV11.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameHandlerV11.java index b70f55f..42559d8 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameHandlerV11.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameHandlerV11.java @@ -31,9 +31,6 @@ import org.apache.activemq.core.server.ActiveMQServerLogger; import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessageBundle.BUNDLE; -/** - * @author <a href="mailto:[email protected]">Howard Gao</a> - */ public class StompFrameHandlerV11 extends VersionedStompFrameHandler implements FrameEventListener { protected static final char ESC_CHAR = '\\'; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameV11.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameV11.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameV11.java index 45b0a2b..e08e269 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameV11.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v11/StompFrameV11.java @@ -26,9 +26,6 @@ import org.apache.activemq.api.core.ActiveMQBuffers; import org.apache.activemq.core.protocol.stomp.Stomp; import org.apache.activemq.core.protocol.stomp.StompFrame; -/** - * @author <a href="mailto:[email protected]">Howard Gao</a> - */ public class StompFrameV11 extends StompFrame { private static final byte[] END_OF_FRAME = new byte[]{0, '\n'}; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameHandlerV12.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameHandlerV12.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameHandlerV12.java index 994d1a5..3c58ac7 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameHandlerV12.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameHandlerV12.java @@ -30,9 +30,6 @@ import org.apache.activemq.core.server.ServerMessage; import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessageBundle.BUNDLE; -/** - * @author <a href="mailto:[email protected]">Howard Gao</a> - */ public class StompFrameHandlerV12 extends StompFrameHandlerV11 implements FrameEventListener { public StompFrameHandlerV12(StompConnection connection) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameV12.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameV12.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameV12.java index 96ce3c3..d65081c 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameV12.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/v12/StompFrameV12.java @@ -26,9 +26,6 @@ import org.apache.activemq.api.core.ActiveMQBuffers; import org.apache.activemq.core.protocol.stomp.Stomp; import org.apache.activemq.core.protocol.stomp.StompFrame; -/** - * @author <a href="mailto:[email protected]">Howard Gao</a> - */ public class StompFrameV12 extends StompFrame { private static final byte[] END_OF_FRAME = new byte[]{0, '\n'}; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABundle.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABundle.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABundle.java index 051a58a..dfc3556 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABundle.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABundle.java @@ -28,9 +28,6 @@ import javax.jms.JMSRuntimeException; import javax.resource.NotSupportedException; /** - * @author <a href="mailto:[email protected]">Andy Taylor</a> - * 3/12/12 - * * Logger Code 15 * * each message id must be 6 digits long starting with 15, the 3rd digit should be 9 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABytesMessage.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABytesMessage.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABytesMessage.java index 594f1db..75b8f29 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABytesMessage.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRABytesMessage.java @@ -24,9 +24,6 @@ import javax.jms.JMSException; /** * A wrapper for a message - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRABytesMessage extends ActiveMQRAMessage implements BytesMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactory.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactory.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactory.java index 3debb6a..64404ad 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactory.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactory.java @@ -26,9 +26,6 @@ import org.apache.activemq.jms.client.ActiveMQConnectionFactory; /** * An aggregate interface for the JMS connection factories - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public interface ActiveMQRAConnectionFactory extends XAQueueConnectionFactory, XATopicConnectionFactory, Serializable, Referenceable http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactoryImpl.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactoryImpl.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactoryImpl.java index c281bb1..92e5d1d 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactoryImpl.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionFactoryImpl.java @@ -40,9 +40,6 @@ import org.apache.activemq.jms.referenceable.SerializableObjectRefAddr; /** * The connection factory - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAConnectionFactoryImpl implements ActiveMQRAConnectionFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionManager.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionManager.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionManager.java index 5aefed3..39c598b 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionManager.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionManager.java @@ -27,9 +27,6 @@ import org.apache.activemq.utils.ConcurrentHashSet; /** * The connection manager used in non-managed environments. - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAConnectionManager implements ConnectionManager { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionMetaData.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionMetaData.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionMetaData.java index f8778c6..bb1cc83 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionMetaData.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionMetaData.java @@ -24,9 +24,6 @@ import javax.jms.ConnectionMetaData; /** * This class implements javax.jms.ConnectionMetaData - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAConnectionMetaData implements ConnectionMetaData { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionRequestInfo.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionRequestInfo.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionRequestInfo.java index a8581b1..804c167 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionRequestInfo.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAConnectionRequestInfo.java @@ -22,10 +22,6 @@ import javax.resource.spi.ConnectionRequestInfo; /** * Connection request information - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> - * @author <a href="mailto:[email protected]">Andy Taylor</a> */ public class ActiveMQRAConnectionRequestInfo implements ConnectionRequestInfo { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRACredential.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRACredential.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRACredential.java index f6969cb..cb13478 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRACredential.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRACredential.java @@ -30,10 +30,6 @@ import javax.security.auth.Subject; /** * Credential information - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> - * @version $Revision: 71554 $ */ public class ActiveMQRACredential implements Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALocalTransaction.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALocalTransaction.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALocalTransaction.java index c97c1c3..76599ea 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALocalTransaction.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALocalTransaction.java @@ -23,9 +23,6 @@ import javax.resource.spi.LocalTransaction; /** * JMS Local transaction - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRALocalTransaction implements LocalTransaction { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALogger.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALogger.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALogger.java index caa35d2..a90153a 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALogger.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRALogger.java @@ -40,8 +40,6 @@ import org.jboss.logging.annotations.MessageLogger; * </pre> * <p/> * so an INFO message would be 151000 to 151999 - * - * @author <a href="mailto:[email protected]">Andy Taylor</a> 3/15/12 */ @MessageLogger(projectCode = "AMQ") public interface ActiveMQRALogger extends BasicLogger http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMCFProperties.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMCFProperties.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMCFProperties.java index 3880f8d..1c53013 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMCFProperties.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMCFProperties.java @@ -24,11 +24,6 @@ import javax.jms.Topic; /** * The MCF default properties - these are set in the <tx-connection-factory> at the jms-ds.xml - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> - * @author <a href="mailto:[email protected]">Clebert Suconic</a> - * @author <a href="mailto:[email protected]">Andy Taylor</a> */ public class ActiveMQRAMCFProperties extends ConnectionFactoryProperties implements Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnection.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnection.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnection.java index 0086f92..72caf91 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnection.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnection.java @@ -58,10 +58,6 @@ import org.apache.activemq.utils.VersionLoader; /** * The managed connection - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> - * @author <a href="mailto:[email protected]">Martyn Taylor</a> */ public final class ActiveMQRAManagedConnection implements ManagedConnection, ExceptionListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnectionFactory.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnectionFactory.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnectionFactory.java index 7cd6a48..42546c4 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnectionFactory.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAManagedConnectionFactory.java @@ -34,10 +34,6 @@ import org.apache.activemq.service.extensions.xa.recovery.XARecoveryConfig; /** * ActiveMQ ManagedConnectionFactory - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a>. - * @author <a href="mailto:[email protected]">Andy Taylor</a> */ public final class ActiveMQRAManagedConnectionFactory implements ManagedConnectionFactory, ResourceAdapterAssociation { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMapMessage.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMapMessage.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMapMessage.java index 8bf1cec..73ef393 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMapMessage.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMapMessage.java @@ -25,10 +25,6 @@ import javax.jms.MapMessage; /** * A wrapper for a message - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> - * @version $Revision: 71554 $ */ public class ActiveMQRAMapMessage extends ActiveMQRAMessage implements MapMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessage.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessage.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessage.java index 7403a09..df633b1 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessage.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessage.java @@ -25,9 +25,6 @@ import java.util.Enumeration; /** * A wrapper for a message - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAMessage implements Message { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageConsumer.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageConsumer.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageConsumer.java index 8234f1f..c5aee77 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageConsumer.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageConsumer.java @@ -29,9 +29,6 @@ import javax.jms.TextMessage; /** * A wrapper for a message consumer - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAMessageConsumer implements MessageConsumer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageListener.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageListener.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageListener.java index 07f6e4c..5dae6f9 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageListener.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageListener.java @@ -22,8 +22,6 @@ import javax.jms.MessageListener; /** * A wrapper for a message listener - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAMessageListener implements MessageListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageProducer.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageProducer.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageProducer.java index 8882dbb..c769bf7 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageProducer.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMessageProducer.java @@ -25,9 +25,6 @@ import javax.jms.MessageProducer; /** * ActiveMQMessageProducer. - * - * @author <a href="[email protected]">Adrian Brock</a> - * @author <a href="[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAMessageProducer implements MessageProducer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMetaData.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMetaData.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMetaData.java index c15e4e9..66a025c 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMetaData.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAMetaData.java @@ -22,9 +22,6 @@ import javax.resource.spi.ManagedConnectionMetaData; /** * Managed connection meta data - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAMetaData implements ManagedConnectionMetaData { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAObjectMessage.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAObjectMessage.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAObjectMessage.java index 9cf0219..1e92163 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAObjectMessage.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAObjectMessage.java @@ -24,9 +24,6 @@ import javax.jms.ObjectMessage; /** * A wrapper for a message - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAObjectMessage extends ActiveMQRAMessage implements ObjectMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAProperties.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAProperties.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAProperties.java index 51282f6..48cb10d 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAProperties.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAProperties.java @@ -27,10 +27,6 @@ import org.apache.activemq.utils.SensitiveDataCodec; /** * The RA default properties - these are set in the ra.xml file - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> - * @author <a href="mailto:[email protected]">Andy Taylor</a> */ public class ActiveMQRAProperties extends ConnectionFactoryProperties implements Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueReceiver.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueReceiver.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueReceiver.java index 7c5a29b..2692d3d 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueReceiver.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueReceiver.java @@ -23,9 +23,6 @@ import javax.jms.QueueReceiver; /** * A wrapper for a queue receiver - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAQueueReceiver extends ActiveMQRAMessageConsumer implements QueueReceiver { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueSender.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueSender.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueSender.java index 0d882ee..0991420 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueSender.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAQueueSender.java @@ -24,9 +24,6 @@ import javax.jms.QueueSender; /** * ActiveMQQueueSender. - * - * @author <a href="[email protected]">Adrian Brock</a> - * @author <a href="[email protected]">Jesper Pedersen</a> */ public class ActiveMQRAQueueSender extends ActiveMQRAMessageProducer implements QueueSender { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAService.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAService.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAService.java index 535ff5e..0eab375 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAService.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRAService.java @@ -26,10 +26,6 @@ import javax.management.ObjectName; /** * A ActiveMQRAService ensures that ActiveMQ Resource Adapter will be stopped *before* the ActiveMQ server. * https://jira.jboss.org/browse/HORNETQ-339 - * - * @author <a href="mailto:[email protected]">Jeff Mesnil</a> - * - * */ public class ActiveMQRAService { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRASession.java ---------------------------------------------------------------------- diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRASession.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRASession.java index 5c876a5..cdfa0c6 100644 --- a/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRASession.java +++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQRASession.java @@ -59,10 +59,6 @@ import org.apache.activemq.jms.client.ActiveMQSession; /** * A joint interface for JMS sessions - * - * @author <a href="mailto:[email protected]">Adrian Brock</a> - * @author <a href="mailto:[email protected]">Jesper Pedersen</a> - * @author <a href="mailto:[email protected]">Martyn Taylor</a> */ public final class ActiveMQRASession implements QueueSession, TopicSession, XAQueueSession, XATopicSession {
