You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2015/03/10 22:00:40 UTC
[23/30] activemq-6 git commit: ACTIVEMQ6-87 Strip @author tags
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:tim.fox@jboss.com">Tim Fox</a>
- * @author <a href="mailto:clebert.suconic@jboss.com">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:tim.fox@jboss.com">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:tim.fox@jboss.com">Tim Fox</a>
- * @author <a href="mailto:clebert.suconic@jboss.com">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:clebert.suconic@jboss.org">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:tim.fox@jboss.com">Tim Fox</a>
- * @author <a href="mailto:clebert.suconic@jboss.com">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:tim.fox@jboss.com">Tim Fox</a>
- * @author <a href="mailto:clebert.suconic@jboss.com">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:tim.fox@jboss.com">Tim Fox</a>
- * @author <a href="mailto:clebert.suconic@jboss.com">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:tim.fox@jboss.com">Tim Fox</a>
- * @author <a href="mailto:clebert.suconic@jboss.com">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:tim.fox@jboss.com">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:clebert.suconic@jboss.org">Clebert Suconic</a>
- * @author <a href="mailto:tim.fox@jboss.com">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:clebert.suconic@jboss.org">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:andy.taylor@jboss.org">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:andy.taylor@jboss.org">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:andy.taylor@jboss.com">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:andy.taylor@jboss.com">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:andy.taylor@jboss.com">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:andy.taylor@jboss.com">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:andy.taylor@jboss.org">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:andy.taylor@jboss.org">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:ovidiu@feodorov.com">Ovidiu Feodorov</a>
- * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a>
- * @author <a href="mailto:csuconic@redhat.com">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:andy.taylor@jboss.org">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:andy.taylor@jboss.org">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 (Norbert.Lataille@m4x.org)
- * @author <a href="mailto:adrian@jboss.org">Adrian Brock</a>
- * @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
- * @author <a href="mailto:ovidiu@feodorov.com">Ovidiu Feodorov</a>
- * @author <a href="mailto:ataylor@redhat.com">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 (Norbert.Lataille@m4x.org)
- * @author <a href="mailto:jason@planet57.com">Jason Dillon</a>
- * @author <a href="mailto:adrian@jboss.org">Adrian Brock</a>
- * @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
- * @author <a href="mailto:ovidiu@feodorov.com">Ovidiu Feodorov</a>
- * @author <a href="mailto:ataylor@redhat.com">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:hgao@redhat.com">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:hgao@redhat.com">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:andy.taylor@jboss.org">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:andy.taylor@jboss.org">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:andy.taylor@jboss.org">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();