http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.java index 06ea3a8..eeadf84 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/NullResponseMessage.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 class NullResponseMessage extends PacketImpl {
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java index 19c855c..11cf330 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/PacketsConfirmedMessage.java @@ -20,11 +20,7 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** - * * A PacketsConfirmedMessage - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class PacketsConfirmedMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java index 6a04bdb..7d08543 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/Ping.java @@ -23,7 +23,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; * Ping is sent on the client side by {@link org.apache.activemq.core.client.impl.ClientSessionFactoryImpl}. At the server's * side it is handled by {@link org.apache.activemq.core.remoting.server.impl.RemotingServiceImpl} * @see org.apache.activemq.spi.core.protocol.RemotingConnection#checkDataReceived() - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public final class Ping extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java index 857e9dbe..666ccf3 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionMessage.java @@ -20,11 +20,7 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** - * * A ReattachSessionMessage - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class ReattachSessionMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java index 46bda5a..68d5093 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/ReattachSessionResponseMessage.java @@ -20,11 +20,7 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** - * * A ReattachSessionResponseMessage - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class ReattachSessionResponseMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java index 340c73a..76aeb7b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/RollbackMessage.java @@ -21,7 +21,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A RollbackMessage - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public class RollbackMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java index 3279c28..eba4825 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAcknowledgeMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionAcknowledgeMessage extends PacketImpl { private long consumerID; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java index 2712a57..d92939f 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessage.java @@ -23,10 +23,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; * A SessionAddMetaDataMessage * * Packet deprecated: It exists only to support old formats - * - * @author <a href="mailto:[email protected]";>Howard Gao</a> - * - * */ public class SessionAddMetaDataMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java index 00e9b6f..2735be6 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionAddMetaDataMessageV2.java @@ -23,10 +23,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; * A SessionAddMetaDataMessage * * This packet replaces {@link SessionAddMetaDataMessage} - * - * @author Clebert Suconic - * - * */ public class SessionAddMetaDataMessageV2 extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java index 8c98c84..007dd00 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryMessage.java @@ -21,11 +21,7 @@ import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** - * * A SessionQueueQueryMessage - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class SessionBindingQueryMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java index dc56506..4638a66 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage.java @@ -26,9 +26,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * * A SessionBindingQueryResponseMessage - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class SessionBindingQueryResponseMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage_V2.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage_V2.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage_V2.java index 2a9e440..2568671 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage_V2.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionBindingQueryResponseMessage_V2.java @@ -21,10 +21,6 @@ import java.util.List; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; -/** - * @author Justin Bertram - * - */ public class SessionBindingQueryResponseMessage_V2 extends SessionBindingQueryResponseMessage { private boolean autoCreateJmsQueues; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.java index dc61860..647076a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCloseMessage.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 class SessionCloseMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java index 1b1e081..95725d5 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCommitMessage.java @@ -20,7 +20,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A SessionCommitMessage - * @author tim */ public class SessionCommitMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java index 04150f4..dc704f5 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerCloseMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionConsumerCloseMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerFlowCreditMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerFlowCreditMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerFlowCreditMessage.java index 76a1d6e..c6eae6a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerFlowCreditMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionConsumerFlowCreditMessage.java @@ -19,11 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a>. - * - */ public class SessionConsumerFlowCreditMessage extends PacketImpl { private long consumerID; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java index 4f1d33a..698452d 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionContinuationMessage.java @@ -24,12 +24,6 @@ import org.apache.activemq.utils.DataConstants; /** * A SessionContinuationMessage - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * Created Dec 5, 2008 10:08:40 AM - * - * */ public abstract class SessionContinuationMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java index 2eb24ba..91ee54a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionCreateConsumerMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionDeleteQueueMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionDeleteQueueMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionDeleteQueueMessage.java index 2c7fb1a..36576e8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionDeleteQueueMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionDeleteQueueMessage.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - - */ public class SessionDeleteQueueMessage extends PacketImpl { private SimpleString queueName; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionExpireMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionExpireMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionExpireMessage.java index 3fb6b42..0169fbb 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionExpireMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionExpireMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionExpireMessage extends PacketImpl { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionForceConsumerDelivery.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionForceConsumerDelivery.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionForceConsumerDelivery.java index 3c5ca08..c30bb9b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionForceConsumerDelivery.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionForceConsumerDelivery.java @@ -22,9 +22,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * * A SessionConsumerForceDelivery - * - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * */ public class SessionForceConsumerDelivery extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionIndividualAcknowledgeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionIndividualAcknowledgeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionIndividualAcknowledgeMessage.java index 33957d9..8267970 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionIndividualAcknowledgeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionIndividualAcknowledgeMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionIndividualAcknowledgeMessage extends PacketImpl { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsFailMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsFailMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsFailMessage.java index d7c4d55..6cc261a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsFailMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsFailMessage.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author Justin Bertram - * - */ public class SessionProducerCreditsFailMessage extends PacketImpl { private int credits; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java index c290f8d..cf88747 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionProducerCreditsMessage.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionProducerCreditsMessage extends PacketImpl { private int credits; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java index cef8071..8059015 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryMessage.java @@ -21,11 +21,7 @@ import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** - * * A SessionQueueQueryMessage - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class SessionQueueQueryMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java index d7d031a..6358769 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage.java @@ -24,11 +24,7 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.core.server.QueueQueryResult; /** - * * A SessionQueueQueryResponseMessage - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class SessionQueueQueryResponseMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage_V2.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage_V2.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage_V2.java index 4c6b474..d89b895 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage_V2.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionQueueQueryResponseMessage_V2.java @@ -22,10 +22,6 @@ import org.apache.activemq.api.core.client.ClientSession; import org.apache.activemq.core.client.impl.QueueQueryImpl; import org.apache.activemq.core.server.QueueQueryResult; -/** - * @author Justin Bertram - * - */ public class SessionQueueQueryResponseMessage_V2 extends SessionQueueQueryResponseMessage { private boolean autoCreationEnabled; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveClientLargeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveClientLargeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveClientLargeMessage.java index a4352a9..aa2a26e 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveClientLargeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveClientLargeMessage.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.client.impl.ClientLargeMessageInternal; import org.apache.activemq.core.message.impl.MessageInternal; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * 10/12/12 - */ public class SessionReceiveClientLargeMessage extends SessionReceiveLargeMessage { public SessionReceiveClientLargeMessage(MessageInternal message) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java index 7ddf244..fd9c9bc 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveContinuationMessage.java @@ -21,12 +21,6 @@ import org.apache.activemq.utils.DataConstants; /** * A SessionSendContinuationMessage - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * Created Dec 4, 2008 12:25:14 PM - * - * */ public class SessionReceiveContinuationMessage extends SessionContinuationMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java index 62636d0..b4aa9e4 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java @@ -22,10 +22,6 @@ import org.apache.activemq.core.protocol.core.impl.PacketImpl; /** * A SessionReceiveLargeMessage - * - * @author Clebert Suconic - * - * */ public class SessionReceiveLargeMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveMessage.java index 3a4ce29..829e339 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionReceiveMessage.java @@ -21,10 +21,6 @@ import org.apache.activemq.core.message.impl.MessageInternal; import org.apache.activemq.spi.core.protocol.RemotingConnection; import org.apache.activemq.utils.DataConstants; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionReceiveMessage extends MessagePacket { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionRequestProducerCreditsMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionRequestProducerCreditsMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionRequestProducerCreditsMessage.java index a809e10..4034b99 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionRequestProducerCreditsMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionRequestProducerCreditsMessage.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionRequestProducerCreditsMessage extends PacketImpl { private int credits; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendContinuationMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendContinuationMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendContinuationMessage.java index a86f2d2..e21bb0f 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendContinuationMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendContinuationMessage.java @@ -22,9 +22,6 @@ import org.apache.activemq.core.message.impl.MessageInternal; /** * A SessionSendContinuationMessage<br> - * Created Dec 4, 2008 12:25:14 PM - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public class SessionSendContinuationMessage extends SessionContinuationMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendLargeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendLargeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendLargeMessage.java index 8708b90..2ded85f 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendLargeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendLargeMessage.java @@ -20,12 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.message.impl.MessageInternal; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - */ public class SessionSendLargeMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendMessage.java index 4e35e88..97661aa 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionSendMessage.java @@ -22,9 +22,6 @@ import org.apache.activemq.core.message.impl.MessageInternal; import org.apache.activemq.spi.core.protocol.RemotingConnection; import org.apache.activemq.utils.DataConstants; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionSendMessage extends MessagePacket { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java index f6d977e..f793eed 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionUniqueAddMetaDataMessage.java @@ -19,10 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; /** * A SessionUniqueAddMetaDataMessageV2 - * - * @author clebertsuconic - * - * */ public class SessionUniqueAddMetaDataMessage extends SessionAddMetaDataMessageV2 { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAAfterFailedMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAAfterFailedMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAAfterFailedMessage.java index 7308ed3..cd445a1 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAAfterFailedMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAAfterFailedMessage.java @@ -24,9 +24,7 @@ import org.apache.activemq.utils.XidCodecSupport; /** * to be called after a failure on an XA Session - * @author Clebert Suconic */ - public class SessionXAAfterFailedMessage extends PacketImpl { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXACommitMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXACommitMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXACommitMessage.java index 14668cb..d32022a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXACommitMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXACommitMessage.java @@ -22,10 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionXACommitMessage extends PacketImpl { private boolean onePhase; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAEndMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAEndMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAEndMessage.java index e5345bd..85bcd7a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAEndMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAEndMessage.java @@ -22,9 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionXAEndMessage extends PacketImpl { private Xid xid; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAForgetMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAForgetMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAForgetMessage.java index 3b7321c..7742a1e 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAForgetMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAForgetMessage.java @@ -22,9 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionXAForgetMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetInDoubtXidsResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetInDoubtXidsResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetInDoubtXidsResponseMessage.java index 04549a3..1818019 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetInDoubtXidsResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetInDoubtXidsResponseMessage.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionXAGetInDoubtXidsResponseMessage extends PacketImpl { private List<Xid> xids; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetTimeoutResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetTimeoutResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetTimeoutResponseMessage.java index ee5226f..6a94198 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetTimeoutResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAGetTimeoutResponseMessage.java @@ -19,10 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionXAGetTimeoutResponseMessage extends PacketImpl { private int timeoutSeconds; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAJoinMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAJoinMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAJoinMessage.java index cb2c2d9..b7453cd 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAJoinMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAJoinMessage.java @@ -22,10 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionXAJoinMessage extends PacketImpl { private Xid xid; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAPrepareMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAPrepareMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAPrepareMessage.java index 8ff5b15..e94bf57 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAPrepareMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAPrepareMessage.java @@ -22,10 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionXAPrepareMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResponseMessage.java index 0c0e671..050924a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResponseMessage.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionXAResponseMessage extends PacketImpl { private boolean error; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResumeMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResumeMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResumeMessage.java index 88cbc76..126c163 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResumeMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAResumeMessage.java @@ -22,9 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - */ public class SessionXAResumeMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXARollbackMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXARollbackMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXARollbackMessage.java index 272386d..26084c0 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXARollbackMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXARollbackMessage.java @@ -22,10 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionXARollbackMessage extends PacketImpl { private Xid xid; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutMessage.java index 07d61b1..96be0d3 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutMessage.java @@ -19,10 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionXASetTimeoutMessage extends PacketImpl { private int timeoutSeconds; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutResponseMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutResponseMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutResponseMessage.java index 8d80010..79e79c8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutResponseMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXASetTimeoutResponseMessage.java @@ -19,10 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionXASetTimeoutResponseMessage extends PacketImpl { private boolean ok; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAStartMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAStartMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAStartMessage.java index d78afda..040e85c 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAStartMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SessionXAStartMessage.java @@ -22,10 +22,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.utils.XidCodecSupport; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SessionXAStartMessage extends PacketImpl { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessage.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessage.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessage.java index 920fff7..0fabed8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessage.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessage.java @@ -19,10 +19,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.protocol.core.impl.PacketImpl; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SubscribeClusterTopologyUpdatesMessage extends PacketImpl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessageV2.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessageV2.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessageV2.java index 52dc814..b87f7ce 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessageV2.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/wireformat/SubscribeClusterTopologyUpdatesMessageV2.java @@ -18,10 +18,6 @@ package org.apache.activemq.core.protocol.core.impl.wireformat; import org.apache.activemq.api.core.ActiveMQBuffer; -/** - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - */ public class SubscribeClusterTopologyUpdatesMessageV2 extends SubscribeClusterTopologyUpdatesMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/CloseListener.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/CloseListener.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/CloseListener.java index 5703355..7ee2284 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/CloseListener.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/CloseListener.java @@ -20,8 +20,6 @@ package org.apache.activemq.core.remoting; * CloseListeners can be registered with a {@link org.apache.activemq.spi.core.protocol.RemotingConnection} to get notified when the connection is closed. * <p> * {@link org.apache.activemq.spi.core.protocol.RemotingConnection#addCloseListener(CloseListener)} - * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> */ public interface CloseListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/FailureListener.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/FailureListener.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/FailureListener.java index ea7df3a..8386ec8 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/FailureListener.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/FailureListener.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.ActiveMQException; /** * A FailureListener notifies the user when a connection failure occurred. - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> */ public interface FailureListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/TransportConfigurationUtil.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/TransportConfigurationUtil.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/TransportConfigurationUtil.java index 84dbddb..1a72026 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/TransportConfigurationUtil.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/TransportConfigurationUtil.java @@ -27,8 +27,6 @@ import org.apache.activemq.utils.ClassloadingUtil; /** * Stores static mappings of class names to ConnectorFactory instances to act as a central repo for ConnectorFactory * objects. - * - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> */ public class TransportConfigurationUtil http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQAMQPFrameDecoder.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQAMQPFrameDecoder.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQAMQPFrameDecoder.java index c43b914..2a1ce73 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQAMQPFrameDecoder.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQAMQPFrameDecoder.java @@ -22,10 +22,6 @@ import io.netty.handler.codec.LengthFieldBasedFrameDecoder; /** * A Netty decoder specially optimised to to decode messages on the core protocol only - * - * @author <a href="[email protected]">Trustin Lee</a> - * @author <a href="[email protected]">Norman Maurer</a> - * @version $Revision: 7839 $, $Date: 2009-08-21 02:26:39 +0900 (2009-08-21, ê¸) $ */ public class ActiveMQAMQPFrameDecoder extends LengthFieldBasedFrameDecoder { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQChannelHandler.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQChannelHandler.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQChannelHandler.java index 119a6de..ae16a17 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQChannelHandler.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQChannelHandler.java @@ -31,10 +31,6 @@ import org.apache.activemq.spi.core.remoting.ConnectionLifeCycleListener; /** * Common handler implementation for client and server side handler. - * - * @author <a href="mailto:[email protected]";>Trustin Lee</a> - * @author <a href="mailto:[email protected]";>Norman Maurer</a> - * @version $Rev$, $Date$ */ public class ActiveMQChannelHandler extends ChannelDuplexHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQFrameDecoder2.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQFrameDecoder2.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQFrameDecoder2.java index 41983a4..745951a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQFrameDecoder2.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/ActiveMQFrameDecoder2.java @@ -23,10 +23,6 @@ import org.apache.activemq.utils.DataConstants; /** * A Netty decoder specially optimised to to decode messages on the core protocol only - * - * @author <a href="[email protected]">Trustin Lee</a> - * @author <a href="[email protected]">Norman Maurer</a> - * @version $Revision: 7839 $, $Date: 2009-08-21 02:26:39 +0900 (2009-08-21, ê¸) $ */ public class ActiveMQFrameDecoder2 extends LengthFieldBasedFrameDecoder { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnection.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnection.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnection.java index c7eafe7..440305d 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnection.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnection.java @@ -41,12 +41,6 @@ import org.apache.activemq.spi.core.remoting.ConnectionLifeCycleListener; import org.apache.activemq.spi.core.remoting.ReadyListener; import org.apache.activemq.utils.ConcurrentHashSet; -/** - * @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="[email protected]">Norman Maurer</a> - */ public class NettyConnection implements Connection { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java index 4f63fef..fe5d1aa 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnector.java @@ -105,11 +105,6 @@ import static org.apache.activemq.utils.Base64.encodeBytes; /** * A NettyConnector - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Trustin Lee</a> - * @author <a href="mailto:[email protected]";>Norman Maurer</a> - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> */ public class NettyConnector extends AbstractConnector { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java index d7d8dce..dea675d 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/NettyConnectorFactory.java @@ -28,9 +28,6 @@ import org.apache.activemq.spi.core.remoting.ConnectorFactory; /** * A NettyConnectorFactory - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Martyn Taylor</a> */ public class NettyConnectorFactory implements ConnectorFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/PartialPooledByteBufAllocator.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/PartialPooledByteBufAllocator.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/PartialPooledByteBufAllocator.java index 7c29407..83d6cb6 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/PartialPooledByteBufAllocator.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/PartialPooledByteBufAllocator.java @@ -26,8 +26,6 @@ import io.netty.buffer.UnpooledByteBufAllocator; /** * A {@link ByteBufAllocator} which is partial pooled. Which means only direct {@link ByteBuf}s are pooled. The rest * is unpooled. - * - * @author <a href="mailto:[email protected]";>Norman Maurer</a> */ public class PartialPooledByteBufAllocator implements ByteBufAllocator { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/SharedNioEventLoopGroup.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/SharedNioEventLoopGroup.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/SharedNioEventLoopGroup.java index 41dc586..ae125c4 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/SharedNioEventLoopGroup.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/SharedNioEventLoopGroup.java @@ -32,9 +32,6 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicReference; -/** - * @author <a href="[email protected]">Norman Maurer</a> - */ public class SharedNioEventLoopGroup extends NioEventLoopGroup { private static SharedNioEventLoopGroup instance; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java index 5cf9681..235b4b5 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/netty/TransportConstants.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.config.ActiveMQDefaultConfiguration; /** * A TransportConstants - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author ClebertSuconic */ public class TransportConstants { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/ssl/SSLSupport.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/ssl/SSLSupport.java b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/ssl/SSLSupport.java index 9e8b2cb..7a50ff5 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/ssl/SSLSupport.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/remoting/impl/ssl/SSLSupport.java @@ -35,9 +35,6 @@ import javax.net.ssl.TrustManagerFactory; import org.apache.activemq.utils.ClassloadingUtil; /** - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author Justin Bertram - * * Please note, this class supports PKCS#11 keystores, but there are no specific tests in the ActiveMQ test-suite to * validate/verify this works because this requires a functioning PKCS#11 provider which is not available by default * (see java.security.Security#getProviders()). The main thing to keep in mind is that PKCS#11 keystores will have a http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/security/ActiveMQPrincipal.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/security/ActiveMQPrincipal.java b/activemq-core-client/src/main/java/org/apache/activemq/core/security/ActiveMQPrincipal.java index 869c702..1b0f386 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/security/ActiveMQPrincipal.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/security/ActiveMQPrincipal.java @@ -16,10 +16,6 @@ */ package org.apache.activemq.core.security; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * 1/30/12 - */ public class ActiveMQPrincipal { private final String userName; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/security/Role.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/security/Role.java b/activemq-core-client/src/main/java/org/apache/activemq/core/security/Role.java index ad71107..a56e414 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/security/Role.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/security/Role.java @@ -20,8 +20,6 @@ import java.io.Serializable; /** * A role is used by the security store to define access rights and is configured on a connection factory or an address. - * - * @author <a href="[email protected]">Andy Taylor</a> */ public class Role implements Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java b/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java index 3b7cbf6..7357543 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/server/QueueQueryResult.java @@ -19,11 +19,7 @@ package org.apache.activemq.core.server; import org.apache.activemq.api.core.SimpleString; /** - * * A QueueQueryResult - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public class QueueQueryResult { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/Notification.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/Notification.java b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/Notification.java index 1d8f09b..43b0f1b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/Notification.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/Notification.java @@ -23,7 +23,6 @@ import org.apache.activemq.utils.TypedProperties; * A Notification * @see org.apache.activemq.core.server.management.NotificationListener * @see NotificationType - * @author <a href="mailto:[email protected]";>Tim Fox</a> Created 22 Jan 2009 16:41:12 */ public final class Notification { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java index c27e8c8..b7f0422 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationListener.java @@ -19,12 +19,6 @@ package org.apache.activemq.core.server.management; /** * A NotificationListener - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * - * Created 22 Jan 2009 16:48:27 - * - * */ public interface NotificationListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java index e6a084f..e06d759 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/server/management/NotificationService.java @@ -18,8 +18,6 @@ package org.apache.activemq.core.server.management; /** * A NotificationService - * - * @author jmesnil */ public interface NotificationService { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java b/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java index 2a23a5d..17f96db 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/settings/impl/AddressFullMessagePolicy.java @@ -18,10 +18,6 @@ package org.apache.activemq.core.settings.impl; /** * A AddressFullMessagePolicy - * - * @author Tim Fox - * - * */ public enum AddressFullMessagePolicy { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/transaction/impl/XidImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/transaction/impl/XidImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/transaction/impl/XidImpl.java index 23f0527..27c5e8e 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/transaction/impl/XidImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/transaction/impl/XidImpl.java @@ -24,14 +24,7 @@ import javax.transaction.xa.Xid; import org.apache.activemq.utils.Base64; /** - * * Xid implementation - * - * @author <a href="mailto:[email protected]";>Adrian Brock</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Juha Lindfors</a> - * - * @version $Revision 1.1 $ */ public class XidImpl implements Xid, Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java b/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java index b8817fb..06f521b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/version/Version.java @@ -17,11 +17,7 @@ package org.apache.activemq.core.version; /** - * * A VersionImpl - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public interface Version { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java index 4ee690d..6fc25c6 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/version/impl/VersionImpl.java @@ -23,8 +23,6 @@ import org.apache.activemq.core.version.Version; /** * A VersionImpl - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public class VersionImpl implements Version, Serializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/reader/BytesMessageUtil.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/reader/BytesMessageUtil.java b/activemq-core-client/src/main/java/org/apache/activemq/reader/BytesMessageUtil.java index a53429e..8db73de 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/reader/BytesMessageUtil.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/reader/BytesMessageUtil.java @@ -18,10 +18,6 @@ package org.apache.activemq.reader; import org.apache.activemq.api.core.Message; -/** - * @author Clebert Suconic - */ - public class BytesMessageUtil extends MessageUtil { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/reader/MapMessageUtil.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/reader/MapMessageUtil.java b/activemq-core-client/src/main/java/org/apache/activemq/reader/MapMessageUtil.java index 0de06bd..6ea119e 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/reader/MapMessageUtil.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/reader/MapMessageUtil.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.Message; import org.apache.activemq.utils.TypedProperties; -/** - * @author Clebert Suconic - */ - public class MapMessageUtil extends MessageUtil { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/reader/MessageUtil.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/reader/MessageUtil.java b/activemq-core-client/src/main/java/org/apache/activemq/reader/MessageUtil.java index 07f5c57..29eab1e 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/reader/MessageUtil.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/reader/MessageUtil.java @@ -31,10 +31,7 @@ import org.apache.activemq.api.core.SimpleString; * static methods intended for import static on JMS like messages. * * This provides a helper for core message to act some of the JMS functions used by the JMS wrapper - * - * @author Clebert Suconic */ - public class MessageUtil { public static final SimpleString CORRELATIONID_HEADER_NAME = new SimpleString("JMSCorrelationID"); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/reader/StreamMessageUtil.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/reader/StreamMessageUtil.java b/activemq-core-client/src/main/java/org/apache/activemq/reader/StreamMessageUtil.java index adc6a77..5ad4b2a 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/reader/StreamMessageUtil.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/reader/StreamMessageUtil.java @@ -21,10 +21,6 @@ import org.apache.activemq.api.core.Message; import org.apache.activemq.api.core.Pair; import org.apache.activemq.utils.DataConstants; -/** - * @author Clebert Suconic - */ - public class StreamMessageUtil extends MessageUtil { /** http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/reader/TextMessageUtil.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/reader/TextMessageUtil.java b/activemq-core-client/src/main/java/org/apache/activemq/reader/TextMessageUtil.java index 7e7d2e6..dc9947b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/reader/TextMessageUtil.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/reader/TextMessageUtil.java @@ -20,10 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.Message; import org.apache.activemq.api.core.SimpleString; -/** - * @author Clebert Suconic - */ - public class TextMessageUtil extends MessageUtil { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/AbstractRemotingConnection.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/AbstractRemotingConnection.java b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/AbstractRemotingConnection.java index 22b26ee..605e618 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/AbstractRemotingConnection.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/AbstractRemotingConnection.java @@ -30,10 +30,6 @@ import org.apache.activemq.core.remoting.CloseListener; import org.apache.activemq.core.remoting.FailureListener; import org.apache.activemq.spi.core.remoting.Connection; -/** - * @author Clebert Suconic - */ - public abstract class AbstractRemotingConnection implements RemotingConnection { protected final List<FailureListener> failureListeners = new CopyOnWriteArrayList<FailureListener>(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java index ffd9135..53455a9 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/spi/core/protocol/ConnectionEntry.java @@ -21,10 +21,6 @@ import java.util.concurrent.Executor; /** * A ConnectionEntry - * - * @author Tim Fox - * - * */ public class ConnectionEntry {
