http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFileFactory.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFileFactory.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFileFactory.java index f5fc745..b3acaec 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFileFactory.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFileFactory.java @@ -36,12 +36,7 @@ import org.apache.activemq.journal.ActiveMQJournalLogger; import org.apache.activemq.utils.ActiveMQThreadFactory; /** - * * An abstract SequentialFileFactory containing basic functionality for both AIO and NIO SequentialFactories - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * */ abstract class AbstractSequentialFileFactory implements SequentialFileFactory {
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/CompactJournal.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/CompactJournal.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/CompactJournal.java index 8be393f..8f02297 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/CompactJournal.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/CompactJournal.java @@ -24,7 +24,6 @@ import org.apache.activemq.core.journal.IOCriticalErrorListener; * It may be used under special cases, but it shouldn't be needed under regular circumstances as the * system should detect the need for compacting. The regular use is to configure min-compact * parameters. - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public final class CompactJournal // NO_UCD { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java index f12fd2e..584b470 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java @@ -20,10 +20,6 @@ import org.apache.activemq.journal.ActiveMQJournalLogger; /** * A DummyCallback - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * */ class DummyCallback extends SyncIOCompletion { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java index 2a49b41..d0b1f27 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java @@ -42,10 +42,6 @@ import org.apache.activemq.journal.ActiveMQJournalLogger; /** * A JournalCompactor - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class JournalCompactor extends AbstractJournalUpdateTask implements JournalRecordProvider { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java index be64489..7c23204 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java @@ -19,11 +19,7 @@ package org.apache.activemq.core.journal.impl; import org.apache.activemq.core.journal.SequentialFile; /** - * * A JournalFile - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * */ public interface JournalFile { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java index ec53bd6..0a7b938 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java @@ -24,12 +24,7 @@ import java.util.concurrent.atomic.AtomicInteger; import org.apache.activemq.core.journal.SequentialFile; /** - * * A JournalFileImpl - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * */ public class JournalFileImpl implements JournalFile { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFilesRepository.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFilesRepository.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFilesRepository.java index a695758..baf3c92 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFilesRepository.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFilesRepository.java @@ -38,8 +38,6 @@ import org.apache.activemq.journal.ActiveMQJournalLogger; /** * This is a helper class for the Journal, which will control access to dataFiles, openedFiles and freeFiles * Guaranteeing that they will be delivered in order to the Journal - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public class JournalFilesRepository { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalImpl.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalImpl.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalImpl.java index 085db0e..6f7af47 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalImpl.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalImpl.java @@ -75,9 +75,6 @@ import org.apache.activemq.utils.DataConstants; * <p>A circular log implementation.</p * <p/> * <p>Look at {@link JournalImpl#load(LoaderCallback)} for the file layout - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public class JournalImpl extends JournalBase implements TestableJournal, JournalRecordProvider { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java index 23c0099..ebf6ff2 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java @@ -20,10 +20,6 @@ import org.apache.activemq.core.journal.RecordInfo; /** * A JournalReader - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * */ public interface JournalReaderCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java index 880f805..e4efe6f 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java @@ -20,10 +20,6 @@ import org.apache.activemq.core.journal.RecordInfo; /** * A JournalReaderCallbackAbstract - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class JournalReaderCallbackAbstract implements JournalReaderCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecord.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecord.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecord.java index ee7c367..13e92c7 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecord.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecord.java @@ -26,8 +26,6 @@ import org.apache.activemq.api.core.Pair; * Note: This class used to be called PosFiles * * Used on the ref-count for reclaiming - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> * */ public class JournalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecordProvider.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecordProvider.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecordProvider.java index 8d7c7a3..f6d93a5 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecordProvider.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalRecordProvider.java @@ -24,10 +24,6 @@ import java.util.Map; * During a TX.commit, the JournalTransaction needs to get a valid list of records from either the JournalImpl or JournalCompactor. * * when a commit is read, the JournalTransaction will inquire the JournalCompactor about the existent records - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * */ public interface JournalRecordProvider { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java index b6fb897..7e05654 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java @@ -29,10 +29,6 @@ import org.apache.activemq.core.journal.impl.dataformat.JournalInternalRecord; /** * A JournalTransaction - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class JournalTransaction { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java index 7209a9a..2b29287 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java @@ -37,9 +37,6 @@ import org.apache.activemq.journal.ActiveMQJournalLogger; /** * A NIOSequentialFile - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> */ public final class NIOSequentialFile extends AbstractSequentialFile { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java index 919927c..36c8199 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java @@ -23,12 +23,7 @@ import org.apache.activemq.core.journal.IOCriticalErrorListener; import org.apache.activemq.core.journal.SequentialFile; /** - * * A NIOSequentialFileFactory - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * */ public class NIOSequentialFileFactory extends AbstractSequentialFileFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/Reclaimer.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/Reclaimer.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/Reclaimer.java index 195c6f5a..7fa51a6 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/Reclaimer.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/Reclaimer.java @@ -33,10 +33,6 @@ import org.apache.activemq.journal.ActiveMQJournalLogger; * * <p>2) All pos that correspond to any neg in file Fn, must all live in any file Fm where 0 <= m <= n * which are also marked for deletion in the same pass of the algorithm.</p> - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * */ public class Reclaimer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java index 68a10e0..f87db59 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java @@ -25,10 +25,6 @@ import org.apache.activemq.journal.ActiveMQJournalLogger; /** * A SimpleWaitIOCallback - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * */ public final class SimpleWaitIOCallback extends SyncIOCompletion { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncIOCompletion.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncIOCompletion.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncIOCompletion.java index 509d6cd..76ecebc 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncIOCompletion.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncIOCompletion.java @@ -20,10 +20,6 @@ import org.apache.activemq.core.journal.IOCompletion; /** * Internal class used to manage explicit syncs on the Journal through callbacks. - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public abstract class SyncIOCompletion implements IOCompletion { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncSpeedTest.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncSpeedTest.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncSpeedTest.java index 9ea73d2..c9fe29c 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncSpeedTest.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SyncSpeedTest.java @@ -36,10 +36,6 @@ import org.apache.activemq.journal.ActiveMQJournalLogger; * * This class just provides some diagnostics on how fast your disk can sync * Useful when determining performance issues - * - * @author <a href="mailto:[email protected]";>Tim Fox</a> fox - * - * */ public class SyncSpeedTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java index 5cbcce4..aea6014 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java @@ -35,9 +35,6 @@ import org.apache.activemq.journal.ActiveMQJournalLogger; /** * A TimedBuffer - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> */ public class TimedBuffer { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java index 5f42b24..8a518d3 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java @@ -23,10 +23,6 @@ import org.apache.activemq.core.journal.IOAsyncTask; /** * A TimedBufferObserver - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * */ public interface TimedBufferObserver { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java index b084b92..786d798 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java @@ -23,10 +23,6 @@ import org.apache.activemq.utils.ReusableLatch; /** * A TransactionCallback - * - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class TransactionCallback implements IOAsyncTask { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java index 26fe98b..19df23a 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java @@ -21,10 +21,6 @@ import org.apache.activemq.core.journal.EncodingSupport; /** * A ByteArrayEncoding - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class ByteArrayEncoding implements EncodingSupport { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java index 88ae3d9..f55683d 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java @@ -22,10 +22,6 @@ import org.apache.activemq.core.journal.impl.JournalImpl; /** * A JournalAddRecord - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class JournalAddRecord extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java index bf4ad34..471e4f0 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java @@ -22,10 +22,6 @@ import org.apache.activemq.core.journal.impl.JournalImpl; /** * A JournalAddRecordTX - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class JournalAddRecordTX extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalCompleteRecordTX.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalCompleteRecordTX.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalCompleteRecordTX.java index 7b50a15..399b064 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalCompleteRecordTX.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalCompleteRecordTX.java @@ -33,7 +33,6 @@ import org.apache.activemq.core.journal.impl.JournalImpl; * have to invalidate the transaction * <p> * The commit operation itself is not included in this total. - * @author <mailto:[email protected]";>Clebert Suconic</a> */ public class JournalCompleteRecordTX extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java index ca5f741..00c4ca0 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java @@ -21,10 +21,6 @@ import org.apache.activemq.core.journal.impl.JournalImpl; /** * A JournalDeleteRecord - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class JournalDeleteRecord extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java index 623abee..1f7e858 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java @@ -22,10 +22,6 @@ import org.apache.activemq.core.journal.impl.JournalImpl; /** * A JournalDeleteRecordTX - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class JournalDeleteRecordTX extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java index 799ea78..2798913 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java @@ -21,10 +21,6 @@ import org.apache.activemq.core.journal.EncodingSupport; /** * A InternalEncoder - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public abstract class JournalInternalRecord implements EncodingSupport { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java index ca6aef0..8377be8 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java @@ -21,10 +21,6 @@ import org.apache.activemq.core.journal.impl.JournalImpl; /** * A JournalRollbackRecordTX - * - * @author <mailto:[email protected]";>Clebert Suconic</a> - * - * */ public class JournalRollbackRecordTX extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalBundle.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalBundle.java b/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalBundle.java index 84d9e05..0754142 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalBundle.java +++ b/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalBundle.java @@ -23,9 +23,6 @@ import org.jboss.logging.annotations.MessageBundle; import org.jboss.logging.Messages; /** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * 3/12/12 - * * Logger Code 14 * * each message id must be 6 digits long starting with 14, the 3rd digit should be 9 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalLogger.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalLogger.java b/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalLogger.java index 6b26d19..882b425 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalLogger.java +++ b/activemq-journal/src/main/java/org/apache/activemq/journal/ActiveMQJournalLogger.java @@ -25,9 +25,6 @@ import org.jboss.logging.annotations.Message; import org.jboss.logging.annotations.MessageLogger; /** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * 3/15/12 - * * Logger Code 14 * * each message id must be 6 digits long starting with 14, the 3rd digit donates the level so http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClient.java ---------------------------------------------------------------------- diff --git a/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClient.java b/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClient.java index 8327e54..120bf21 100644 --- a/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClient.java +++ b/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClient.java @@ -16,11 +16,6 @@ */ package org.apache.activemq.maven; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * Date: 8/18/11 - * Time: 2:35 PM - */ public interface ActiveMQClient { void run(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClientPlugin.java ---------------------------------------------------------------------- diff --git a/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClientPlugin.java b/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClientPlugin.java index b964f4b..6dfd9f0 100644 --- a/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClientPlugin.java +++ b/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQClientPlugin.java @@ -24,8 +24,6 @@ import org.apache.maven.plugin.MojoExecutionException; import org.apache.maven.plugin.MojoFailureException; /** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * * Allows a Java Client to be run which must hve a static main(String[] args) method */ http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStartPlugin.java ---------------------------------------------------------------------- diff --git a/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStartPlugin.java b/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStartPlugin.java index 4966253..2d111d3 100644 --- a/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStartPlugin.java +++ b/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStartPlugin.java @@ -34,11 +34,6 @@ import org.apache.maven.plugin.descriptor.PluginDescriptor; import org.codehaus.classworlds.ClassRealm; import org.codehaus.classworlds.ClassWorld; - -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - */ - /** * @phase verify * @goal start http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStopPlugin.java ---------------------------------------------------------------------- diff --git a/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStopPlugin.java b/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStopPlugin.java index 6d8cc3e..99d1708 100644 --- a/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStopPlugin.java +++ b/activemq-maven-plugin/src/main/java/org/apache/activemq/maven/ActiveMQStopPlugin.java @@ -24,12 +24,6 @@ import java.io.File; import java.io.IOException; /** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * Date: 8/18/11 - * Time: 12:25 PM - */ - -/** * @phase verify * @goal stop */ http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-maven-plugin/src/main/java/org/apache/activemq/server/ActiveMQBootstrap.java ---------------------------------------------------------------------- diff --git a/activemq-maven-plugin/src/main/java/org/apache/activemq/server/ActiveMQBootstrap.java b/activemq-maven-plugin/src/main/java/org/apache/activemq/server/ActiveMQBootstrap.java index bb7faf4..2875afe 100644 --- a/activemq-maven-plugin/src/main/java/org/apache/activemq/server/ActiveMQBootstrap.java +++ b/activemq-maven-plugin/src/main/java/org/apache/activemq/server/ActiveMQBootstrap.java @@ -46,8 +46,6 @@ import org.apache.activemq.spi.core.security.ActiveMQSecurityManagerImpl; /** * This will bootstrap the HornetQ Server and also the naming server if required - * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> */ public class ActiveMQBootstrap { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedActiveMQBootstrap.java ---------------------------------------------------------------------- diff --git a/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedActiveMQBootstrap.java b/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedActiveMQBootstrap.java index 8ce8505..b44e5ed 100644 --- a/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedActiveMQBootstrap.java +++ b/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedActiveMQBootstrap.java @@ -17,9 +17,6 @@ package org.apache.activemq.server; /** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * 5/14/12 - * * This class will be spawned in a new vm and will call the bootstrap */ public class SpawnedActiveMQBootstrap http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedVMSupport.java ---------------------------------------------------------------------- diff --git a/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedVMSupport.java b/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedVMSupport.java index 55782d2..9f72bf8 100644 --- a/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedVMSupport.java +++ b/activemq-maven-plugin/src/main/java/org/apache/activemq/server/SpawnedVMSupport.java @@ -29,11 +29,6 @@ import java.util.concurrent.TimeUnit; import org.apache.maven.artifact.DefaultArtifact; -/** - * @author <a href="mailto:[email protected]";>Ovidiu Feodorov</a> - * @author <a href="mailto:[email protected]";>Jeff Mesnil</a> - * @author <a href="mailto:[email protected]";>Clebert Suconic</a> - */ public class SpawnedVMSupport { public static Process spawnVM(List<DefaultArtifact> arts, http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-native/src/main/java/org/apache/activemq/core/libaio/Native.java ---------------------------------------------------------------------- diff --git a/activemq-native/src/main/java/org/apache/activemq/core/libaio/Native.java b/activemq-native/src/main/java/org/apache/activemq/core/libaio/Native.java index a63edcb..bce218a 100644 --- a/activemq-native/src/main/java/org/apache/activemq/core/libaio/Native.java +++ b/activemq-native/src/main/java/org/apache/activemq/core/libaio/Native.java @@ -20,10 +20,6 @@ import java.nio.ByteBuffer; import org.apache.activemq.api.core.ActiveMQException; -/** - * @author Clebert Suconic - */ - public class Native { // Functions used for locking files ..... http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ActiveMQProtonRemotingConnection.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ActiveMQProtonRemotingConnection.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ActiveMQProtonRemotingConnection.java index d59338b..85834d2 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ActiveMQProtonRemotingConnection.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ActiveMQProtonRemotingConnection.java @@ -26,11 +26,8 @@ import org.apache.activemq.spi.core.remoting.Connection; import org.proton.plug.AMQPConnectionContext; /** - * * This is a Server's Connection representation used by ActiveMQ. - * @author Clebert Suconic */ - public class ActiveMQProtonRemotingConnection extends AbstractRemotingConnection { private final AMQPConnectionContext amqpConnection; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManager.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManager.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManager.java index 6dca01d..b3f3211 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManager.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManager.java @@ -38,8 +38,6 @@ import org.proton.plug.context.server.ProtonServerConnectionContextFactory; /** * A proton protocol manager, basically reads the Proton Input and maps proton resources to ActiveMQ resources - * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> */ public class ProtonProtocolManager implements ProtocolManager, NotificationListener { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManagerFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManagerFactory.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManagerFactory.java index f8d8037..c83f10c 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManagerFactory.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/ProtonProtocolManagerFactory.java @@ -23,9 +23,6 @@ import org.apache.activemq.spi.core.protocol.ProtocolManagerFactory; import java.util.List; -/** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - */ public class ProtonProtocolManagerFactory implements ProtocolManagerFactory { private static final String AMQP_PROTOCOL_NAME = "AMQP"; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ActiveMQJMSVendor.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ActiveMQJMSVendor.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ActiveMQJMSVendor.java index 127ad17..e675b98 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ActiveMQJMSVendor.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ActiveMQJMSVendor.java @@ -35,10 +35,6 @@ import org.apache.activemq.core.server.ServerMessage; import org.apache.activemq.core.server.impl.ServerMessageImpl; import org.apache.activemq.utils.IDGenerator; -/** - * @author Clebert Suconic - */ - public class ActiveMQJMSVendor extends JMSVendor { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ProtonMessageConverter.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ProtonMessageConverter.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ProtonMessageConverter.java index e197107..2f65675 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ProtonMessageConverter.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/ProtonMessageConverter.java @@ -25,10 +25,6 @@ import org.apache.activemq.core.server.ServerMessage; import org.apache.activemq.spi.core.protocol.MessageConverter; import org.apache.activemq.utils.IDGenerator; -/** - * @author Clebert Suconic - */ - public class ProtonMessageConverter implements MessageConverter { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSBytesMessage.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSBytesMessage.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSBytesMessage.java index f3e671f..b60191c 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSBytesMessage.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSBytesMessage.java @@ -47,11 +47,6 @@ import static org.apache.activemq.reader.BytesMessageUtil.bytesWriteObject; import static org.apache.activemq.reader.BytesMessageUtil.bytesWriteShort; import static org.apache.activemq.reader.BytesMessageUtil.bytesWriteUTF; - -/** - * @author Clebert Suconic - */ - public class ServerJMSBytesMessage extends ServerJMSMessage implements BytesMessage { public ServerJMSBytesMessage(MessageInternal message, int deliveryCount) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMapMessage.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMapMessage.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMapMessage.java index dd9acc9..a117c0f 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMapMessage.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMapMessage.java @@ -35,13 +35,6 @@ import static org.apache.activemq.reader.MapMessageUtil.writeBodyMap; /** * ActiveMQ implementation of a JMS MapMessage. - * - * @author Norbert Lataille ([email protected]) - * @author <a href="mailto:[email protected]";>Adrian Brock</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Ovidiu Feodorov</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @version $Revision: 3412 $ */ public final class ServerJMSMapMessage extends ServerJMSMessage implements MapMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMessage.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMessage.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMessage.java index 1e00c61..7d38065 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMessage.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSMessage.java @@ -30,10 +30,6 @@ import org.apache.activemq.jms.client.ActiveMQDestination; import org.apache.activemq.jms.client.ActiveMQQueue; import org.apache.activemq.reader.MessageUtil; -/** - * @author Clebert Suconic - */ - public class ServerJMSMessage implements Message { protected final MessageInternal message; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSTextMessage.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSTextMessage.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSTextMessage.java index 7fa0f8e..c8796f9 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSTextMessage.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/converter/jms/ServerJMSTextMessage.java @@ -31,14 +31,6 @@ import static org.apache.activemq.reader.TextMessageUtil.writeBodyText; * ActiveMQ implementation of a JMS TextMessage. * <br> * This class was ported from SpyTextMessage in JBossMQ. - * - * @author Norbert Lataille ([email protected]) - * @author <a href="mailto:[email protected]";>Jason Dillon</a> - * @author <a href="mailto:[email protected]";>Adrian Brock</a> - * @author <a href="mailto:[email protected]";>Tim Fox</a> - * @author <a href="mailto:[email protected]";>Ovidiu Feodorov</a> - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * @version $Revision: 3412 $ */ public class ServerJMSTextMessage extends ServerJMSMessage implements TextMessage { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ActiveMQProtonConnectionCallback.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ActiveMQProtonConnectionCallback.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ActiveMQProtonConnectionCallback.java index 09e843e..f57b9fd 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ActiveMQProtonConnectionCallback.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ActiveMQProtonConnectionCallback.java @@ -33,10 +33,6 @@ import org.proton.plug.AMQPSessionCallback; import org.proton.plug.ServerSASL; import org.proton.plug.sasl.AnonymousServerSASL; -/** - * @author Clebert Suconic - */ - public class ActiveMQProtonConnectionCallback implements AMQPConnectionCallback { private final ProtonProtocolManager manager; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ProtonSessionIntegrationCallback.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ProtonSessionIntegrationCallback.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ProtonSessionIntegrationCallback.java index 5e0a9de..e049175 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ProtonSessionIntegrationCallback.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/plug/ProtonSessionIntegrationCallback.java @@ -47,10 +47,6 @@ import org.proton.plug.SASLResult; import org.proton.plug.context.ProtonPlugSender; import org.proton.plug.sasl.PlainSASLResult; -/** - * @author Clebert Suconic - */ - public class ProtonSessionIntegrationCallback implements AMQPSessionCallback, SessionCallback { protected final IDGenerator consumerIDGenerator = new SimpleIDGenerator(0); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/sasl/ActiveMQPlainSASL.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/sasl/ActiveMQPlainSASL.java b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/sasl/ActiveMQPlainSASL.java index 45ce05a..966ffb4 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/sasl/ActiveMQPlainSASL.java +++ b/activemq-protocols/activemq-amqp-protocol/src/main/java/org/apache/activemq/core/protocol/proton/sasl/ActiveMQPlainSASL.java @@ -20,10 +20,6 @@ import org.apache.activemq.core.security.SecurityStore; import org.apache.activemq.spi.core.security.ActiveMQSecurityManager; import org.proton.plug.sasl.ServerSASLPlain; -/** - * @author Clebert Suconic - */ - public class ActiveMQPlainSASL extends ServerSASLPlain { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-amqp-protocol/src/test/java/org/apache/activemq/core/protocol/proton/TestConversions.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-amqp-protocol/src/test/java/org/apache/activemq/core/protocol/proton/TestConversions.java b/activemq-protocols/activemq-amqp-protocol/src/test/java/org/apache/activemq/core/protocol/proton/TestConversions.java index d6a917d..9195b53 100644 --- a/activemq-protocols/activemq-amqp-protocol/src/test/java/org/apache/activemq/core/protocol/proton/TestConversions.java +++ b/activemq-protocols/activemq-amqp-protocol/src/test/java/org/apache/activemq/core/protocol/proton/TestConversions.java @@ -48,10 +48,6 @@ import org.junit.Assert; import org.junit.Test; import org.proton.plug.util.NettyWritable; -/** - * @author Clebert Suconic - */ - public class TestConversions extends Assert { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/BrokerState.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/BrokerState.java b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/BrokerState.java index bd7beaf..33a9dc5 100644 --- a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/BrokerState.java +++ b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/BrokerState.java @@ -18,8 +18,6 @@ package org.apache.activemq.core.protocol.openwire; /** * The class holds related states of an activemq broker. - * @author howard - * */ public class BrokerState { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireConnection.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireConnection.java b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireConnection.java index bf906bc..1f7ec86 100644 --- a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireConnection.java +++ b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireConnection.java @@ -105,8 +105,6 @@ import org.apache.activemq.utils.ConcurrentHashSet; /** * Represents an activemq connection. - * @author howard - * */ public class OpenWireConnection implements RemotingConnection, CommandVisitor { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java index e5e34d7..b949616 100644 --- a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java +++ b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java @@ -25,10 +25,6 @@ import org.apache.activemq.spi.core.protocol.ProtocolManagerFactory; /** * A OpenWireProtocolManagerFactory - * - * @author <a href="mailto:[email protected]";>Howard Gao</a> - * - * */ public class OpenWireProtocolManagerFactory implements ProtocolManagerFactory { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/SendingResult.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/SendingResult.java b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/SendingResult.java index 51600b9..a6eb531 100644 --- a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/SendingResult.java +++ b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/SendingResult.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.paging.impl.PagingStoreImpl; import org.apache.activemq.core.settings.impl.AddressFullMessagePolicy; -/** - * @author <a href="mailto:[email protected]";>Howard Gao</a> - */ public class SendingResult { private boolean blockNextSend; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQSingleTransportConnectionStateRegister.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQSingleTransportConnectionStateRegister.java b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQSingleTransportConnectionStateRegister.java index 866f56b..808f26c 100644 --- a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQSingleTransportConnectionStateRegister.java +++ b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQSingleTransportConnectionStateRegister.java @@ -31,9 +31,6 @@ import org.apache.activemq.command.SessionId; /** * We just copy this structure from amq, but what's the purpose * and can it be removed ? - * - * @author howard - * */ public class AMQSingleTransportConnectionStateRegister implements AMQTransportConnectionStateRegister http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionState.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionState.java b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionState.java index 697ddbb..35c00ba 100644 --- a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionState.java +++ b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionState.java @@ -24,8 +24,6 @@ import org.apache.activemq.core.protocol.openwire.OpenWireConnection; /** * @See org.apache.activemq.broker.TransportConnectionState - * @author howard - * */ public class AMQTransportConnectionState extends ConnectionState { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionStateRegister.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionStateRegister.java b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionStateRegister.java index e2776bb..a62a0ff 100644 --- a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionStateRegister.java +++ b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/amq/AMQTransportConnectionStateRegister.java @@ -26,9 +26,6 @@ import org.apache.activemq.command.SessionId; /** * What's the purpose of this? - * - * @author howard - * */ public interface AMQTransportConnectionStateRegister { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientConnectionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientConnectionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientConnectionContext.java index a23b5a5..ac58127 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientConnectionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientConnectionContext.java @@ -20,10 +20,7 @@ import org.proton.plug.exceptions.ActiveMQAMQPException; /** * This is valid only on a client connection. - * - * @author Clebert Suconic */ - public interface AMQPClientConnectionContext extends AMQPConnectionContext { /** http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientReceiverContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientReceiverContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientReceiverContext.java index f8d5ee7..90f384b 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientReceiverContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientReceiverContext.java @@ -20,10 +20,6 @@ import java.util.concurrent.TimeUnit; import org.apache.qpid.proton.message.ProtonJMessage; -/** - * @author Clebert Suconic - */ - public interface AMQPClientReceiverContext { ProtonJMessage receiveMessage(int time, TimeUnit unit) throws Exception; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSenderContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSenderContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSenderContext.java index 40daa3e..74e1763 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSenderContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSenderContext.java @@ -18,10 +18,6 @@ package org.proton.plug; import org.apache.qpid.proton.message.ProtonJMessage; -/** - * @author Clebert Suconic - */ - public interface AMQPClientSenderContext { void send(ProtonJMessage message); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSessionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSessionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSessionContext.java index c7ebecd..b8be173 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSessionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPClientSessionContext.java @@ -18,10 +18,6 @@ package org.proton.plug; import org.proton.plug.exceptions.ActiveMQAMQPException; -/** - * @author Clebert Suconic - */ - public interface AMQPClientSessionContext extends AMQPSessionContext { AMQPClientSenderContext createSender(String address, boolean preSettled) throws ActiveMQAMQPException; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionCallback.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionCallback.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionCallback.java index c161aec..a00db53 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionCallback.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionCallback.java @@ -18,10 +18,6 @@ package org.proton.plug; import io.netty.buffer.ByteBuf; -/** - * @author Clebert Suconic - */ - public interface AMQPConnectionCallback { void close(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContext.java index 7cb9e85..af5930e 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContext.java @@ -18,10 +18,6 @@ package org.proton.plug; import io.netty.buffer.ByteBuf; -/** - * @author Clebert Suconic - */ - public interface AMQPConnectionContext { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContextFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContextFactory.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContextFactory.java index a0b32b2..fc61bfb 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContextFactory.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPConnectionContextFactory.java @@ -16,10 +16,6 @@ */ package org.proton.plug; -/** - * @author Clebert Suconic - */ - public abstract class AMQPConnectionContextFactory { /** http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPServerConnectionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPServerConnectionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPServerConnectionContext.java index ea087a6..335d93a 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPServerConnectionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPServerConnectionContext.java @@ -16,10 +16,6 @@ */ package org.proton.plug; -/** - * @author Clebert Suconic - */ - public interface AMQPServerConnectionContext extends AMQPConnectionContext { } http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionCallback.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionCallback.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionCallback.java index 605f6c6..5ff2944 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionCallback.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionCallback.java @@ -25,10 +25,7 @@ import org.proton.plug.context.ProtonPlugSender; /** * These are methods where the Proton Plug component will call your server - * - * @author Clebert Suconic */ - public interface AMQPSessionCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionContext.java index 858799a..39a9486 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/AMQPSessionContext.java @@ -20,10 +20,6 @@ import org.apache.qpid.proton.engine.Receiver; import org.apache.qpid.proton.engine.Sender; import org.proton.plug.exceptions.ActiveMQAMQPException; -/** - * @author Clebert Suconic - */ - public interface AMQPSessionContext { byte[] getTag(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ClientSASL.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ClientSASL.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ClientSASL.java index 2eac758..3c68439 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ClientSASL.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ClientSASL.java @@ -16,9 +16,6 @@ */ package org.proton.plug; -/** - * @author Clebert Suconic - */ public interface ClientSASL { byte[] getBytes(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/SASLResult.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/SASLResult.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/SASLResult.java index 7c28487..0faae6a 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/SASLResult.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/SASLResult.java @@ -16,10 +16,6 @@ */ package org.proton.plug; -/** - * @author Clebert Suconic - */ - public interface SASLResult { String getUser(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ServerSASL.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ServerSASL.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ServerSASL.java index 7c6cee0..426c9e2 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ServerSASL.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/ServerSASL.java @@ -16,10 +16,6 @@ */ package org.proton.plug; -/** - * @author Clebert Suconic - */ - public interface ServerSASL { String getName(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonContextSender.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonContextSender.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonContextSender.java index caa3409..9cd60a3 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonContextSender.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonContextSender.java @@ -29,8 +29,6 @@ import org.proton.plug.util.NettyWritable; /** * A this is a wrapper around a ActiveMQ ServerConsumer for handling outgoing messages and incoming acks via a Proton Sender - * - * @author <a href="mailto:[email protected]";>Andy Taylor</a> */ public abstract class AbstractProtonContextSender extends ProtonInitializable implements ProtonDeliveryHandler { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonReceiverContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonReceiverContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonReceiverContext.java index 9eddf6b..3055d18 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonReceiverContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonReceiverContext.java @@ -21,8 +21,6 @@ import org.proton.plug.AMQPSessionCallback; import org.proton.plug.exceptions.ActiveMQAMQPException; /** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * <p/> * handles incoming messages via a Proton Receiver and forwards them to ActiveMQ */ public abstract class AbstractProtonReceiverContext extends ProtonInitializable implements ProtonDeliveryHandler http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonSessionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonSessionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonSessionContext.java index e9550f8..6d1132e 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonSessionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/AbstractProtonSessionContext.java @@ -34,8 +34,6 @@ import org.proton.plug.exceptions.ActiveMQAMQPInternalErrorException; * ProtonSession is a direct representation of the session on the broker. * It has a link between a ProtonSession and a Broker or Client Session * The Broker Session is linked through the ProtonSessionSPI - * - * @author Clebert Suconic */ public abstract class AbstractProtonSessionContext extends ProtonInitializable implements AMQPSessionContext { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonDeliveryHandler.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonDeliveryHandler.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonDeliveryHandler.java index 76236b6..bc7b509 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonDeliveryHandler.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonDeliveryHandler.java @@ -20,8 +20,6 @@ import org.apache.qpid.proton.engine.Delivery; import org.proton.plug.exceptions.ActiveMQAMQPException; /** - * @author <a href="mailto:[email protected]";>Andy Taylor</a> - * <p/> * An interface to handle deliveries, either messages, acks or transaction calls */ public interface ProtonDeliveryHandler http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonInitializable.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonInitializable.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonInitializable.java index 8acbad0..6b2a1f8 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonInitializable.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonInitializable.java @@ -23,10 +23,6 @@ import org.proton.plug.exceptions.ActiveMQAMQPIllegalStateException; import org.proton.plug.exceptions.ActiveMQAMQPTimeoutException; import org.proton.plug.util.FutureRunnable; -/** - * @author Clebert Suconic - */ - public class ProtonInitializable { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonPlugSender.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonPlugSender.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonPlugSender.java index 750af77..c454fbc 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonPlugSender.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/ProtonPlugSender.java @@ -18,10 +18,6 @@ package org.proton.plug.context; import org.apache.qpid.proton.engine.Sender; -/** - * @author Clebert Suconic - */ - public interface ProtonPlugSender { int deliverMessage(Object message, int deliveryCount) throws Exception; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContext.java index 522bb14..9e22e52 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContext.java @@ -29,10 +29,6 @@ import org.proton.plug.exceptions.ActiveMQAMQPException; import org.proton.plug.context.ProtonInitializable; import org.proton.plug.util.FutureRunnable; -/** - * @author Clebert Suconic - */ - public class ProtonClientConnectionContext extends AbstractConnectionContext implements AMQPClientConnectionContext { public ProtonClientConnectionContext(AMQPConnectionCallback connectionCallback) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContextFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContextFactory.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContextFactory.java index 8fd1846..c6bde90 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContextFactory.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientConnectionContextFactory.java @@ -20,10 +20,6 @@ import org.proton.plug.AMQPConnectionContext; import org.proton.plug.AMQPConnectionContextFactory; import org.proton.plug.AMQPConnectionCallback; -/** - * @author Clebert Suconic - */ - public class ProtonClientConnectionContextFactory extends AMQPConnectionContextFactory { private static final AMQPConnectionContextFactory theInstance = new ProtonClientConnectionContextFactory(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientContext.java index 6173ead..b269b00 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientContext.java @@ -31,10 +31,6 @@ import org.proton.plug.context.AbstractProtonSessionContext; import org.proton.plug.exceptions.ActiveMQAMQPException; import org.proton.plug.util.FutureRunnable; -/** - * @author Clebert Suconic - */ - public class ProtonClientContext extends AbstractProtonContextSender implements AMQPClientSenderContext { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientReceiverContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientReceiverContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientReceiverContext.java index d0554ea..645c23d 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientReceiverContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientReceiverContext.java @@ -36,9 +36,6 @@ import org.proton.plug.exceptions.ActiveMQAMQPException; import static org.proton.plug.util.DeliveryUtil.readDelivery; import static org.proton.plug.util.DeliveryUtil.decodeMessageImpl; -/** - * @author Clebert Suconic - */ public class ProtonClientReceiverContext extends AbstractProtonReceiverContext implements AMQPClientReceiverContext { public ProtonClientReceiverContext(AMQPSessionCallback sessionSPI, AbstractConnectionContext connection, AbstractProtonSessionContext protonSession, Receiver receiver) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/88ed03e2/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientSessionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientSessionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientSessionContext.java index 1d7cd3a..480cc18 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientSessionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/client/ProtonClientSessionContext.java @@ -31,10 +31,6 @@ import org.proton.plug.context.AbstractProtonSessionContext; import org.proton.plug.exceptions.ActiveMQAMQPException; import org.proton.plug.util.FutureRunnable; -/** - * @author Clebert Suconic - */ - public class ProtonClientSessionContext extends AbstractProtonSessionContext implements AMQPClientSessionContext { public ProtonClientSessionContext(AMQPSessionCallback sessionSPI, AbstractConnectionContext connection, Session session) 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/ProtonServerConnectionContext.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerConnectionContext.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerConnectionContext.java index 1982461..7adf763 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerConnectionContext.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerConnectionContext.java @@ -28,10 +28,6 @@ import org.proton.plug.context.AbstractConnectionContext; import org.proton.plug.context.AbstractProtonSessionContext; import org.proton.plug.exceptions.ActiveMQAMQPException; -/** - * @author Clebert Suconic - */ - public class ProtonServerConnectionContext extends AbstractConnectionContext implements AMQPServerConnectionContext { public ProtonServerConnectionContext(AMQPConnectionCallback connectionSP) 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/ProtonServerConnectionContextFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerConnectionContextFactory.java b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerConnectionContextFactory.java index 76a2c7a..af452c2 100644 --- a/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerConnectionContextFactory.java +++ b/activemq-protocols/activemq-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerConnectionContextFactory.java @@ -20,10 +20,6 @@ import org.proton.plug.AMQPConnectionContextFactory; import org.proton.plug.AMQPConnectionCallback; import org.proton.plug.AMQPServerConnectionContext; -/** - * @author Clebert Suconic - */ - public class ProtonServerConnectionContextFactory extends AMQPConnectionContextFactory { private static final ProtonServerConnectionContextFactory theInstance = new ProtonServerConnectionContextFactory();
