ACTIVEMQ6-87 Strip @author tags

This commit is contained in:
jbertram 2015-03-10 14:28:20 -05:00
parent d29f495771
commit 88ed03e2bd
1824 changed files with 12 additions and 6115 deletions

View File

@ -22,9 +22,6 @@ import org.apache.activemq.dto.SecurityDTO;
import org.apache.activemq.spi.core.security.ActiveMQSecurityManager; import org.apache.activemq.spi.core.security.ActiveMQSecurityManager;
import org.apache.activemq.spi.core.security.ActiveMQSecurityManagerImpl; import org.apache.activemq.spi.core.security.ActiveMQSecurityManagerImpl;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class BasicSecurityHandler implements SecurityHandler public class BasicSecurityHandler implements SecurityHandler
{ {
@Override @Override

View File

@ -20,9 +20,6 @@ import org.apache.activemq.dto.ServerDTO;
import org.apache.activemq.integration.Broker; import org.apache.activemq.integration.Broker;
import org.apache.activemq.spi.core.security.ActiveMQSecurityManager; import org.apache.activemq.spi.core.security.ActiveMQSecurityManager;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public interface BrokerHandler public interface BrokerHandler
{ {
Broker createServer(ServerDTO brokerDTO, ActiveMQSecurityManager security); Broker createServer(ServerDTO brokerDTO, ActiveMQSecurityManager security);

View File

@ -21,9 +21,6 @@ import org.apache.activemq.integration.Broker;
import org.apache.activemq.integration.FileBroker; import org.apache.activemq.integration.FileBroker;
import org.apache.activemq.spi.core.security.ActiveMQSecurityManager; import org.apache.activemq.spi.core.security.ActiveMQSecurityManager;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class FileBrokerHandler implements BrokerHandler public class FileBrokerHandler implements BrokerHandler
{ {
@Override @Override

View File

@ -19,9 +19,6 @@ package org.apache.activemq.factory;
import org.apache.activemq.dto.SecurityDTO; import org.apache.activemq.dto.SecurityDTO;
import org.apache.activemq.spi.core.security.ActiveMQSecurityManager; import org.apache.activemq.spi.core.security.ActiveMQSecurityManager;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public interface SecurityHandler public interface SecurityHandler
{ {
ActiveMQSecurityManager createSecurityManager(SecurityDTO securityDTO) throws Exception; ActiveMQSecurityManager createSecurityManager(SecurityDTO securityDTO) throws Exception;

View File

@ -28,9 +28,6 @@ import java.lang.management.ManagementFactory;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Map; import java.util.Map;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class FileBroker implements Broker public class FileBroker implements Broker
{ {
private final String configurationUrl; private final String configurationUrl;

View File

@ -20,9 +20,6 @@ package org.apache.activemq.integration.bootstrap;
import org.jboss.logging.annotations.MessageBundle; import org.jboss.logging.annotations.MessageBundle;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* 3/12/12
*
* Logger Code 10 * Logger Code 10
* *
* each message id must be 6 digits long starting with 10, the 3rd digit should be 9 * each message id must be 6 digits long starting with 10, the 3rd digit should be 9

View File

@ -24,9 +24,6 @@ import org.jboss.logging.annotations.Message;
import org.jboss.logging.annotations.MessageLogger; import org.jboss.logging.annotations.MessageLogger;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* 3/15/12
*
* Logger Code 10 * Logger Code 10
* *
* each message id must be 6 digits long starting with 10, the 3rd digit donates the level so * each message id must be 6 digits long starting with 10, the 3rd digit donates the level so

View File

@ -24,9 +24,6 @@ import org.apache.activemq.spi.core.security.ActiveMQSecurityManagerImpl;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class FileBrokerTest public class FileBrokerTest
{ {
@Test @Test

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.ADDRESS_EXISTS;
/** /**
* An operation failed because an address exists on the server. * An operation failed because an address exists on the server.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQAddressExistsException extends ActiveMQException public final class ActiveMQAddressExistsException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.ADDRESS_FULL;
/** /**
* An address is full. * An address is full.
* @author Justin Bertram
*/ */
public final class ActiveMQAddressFullException extends ActiveMQException public final class ActiveMQAddressFullException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.ALREADY_REPLICA
/** /**
* The server is already paired with a replicating backup. * The server is already paired with a replicating backup.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQAlreadyReplicatingException extends ActiveMQException public final class ActiveMQAlreadyReplicatingException extends ActiveMQException
{ {

View File

@ -26,7 +26,6 @@ import io.netty.buffer.ByteBuf;
* Instances of it can be obtained from {@link ActiveMQBuffers} factory. * Instances of it can be obtained from {@link ActiveMQBuffers} factory.
* <p> * <p>
* Much of it derived from Netty ChannelBuffer by Trustin Lee * Much of it derived from Netty ChannelBuffer by Trustin Lee
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @see ActiveMQBuffers * @see ActiveMQBuffers
*/ */
public interface ActiveMQBuffer public interface ActiveMQBuffer

View File

@ -23,7 +23,6 @@ import org.apache.activemq.core.buffers.impl.ChannelBufferWrapper;
/** /**
* Factory class to create instances of {@link ActiveMQBuffer}. * Factory class to create instances of {@link ActiveMQBuffer}.
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public final class ActiveMQBuffers public final class ActiveMQBuffers
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.CONNECTION_TIME
/** /**
* A client timed out will connecting to ActiveMQ server. * A client timed out will connecting to ActiveMQ server.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQConnectionTimedOutException extends ActiveMQException public final class ActiveMQConnectionTimedOutException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.DISCONNECTED;
/** /**
* A client was disconnected from ActiveMQ server when the server has shut down. * A client was disconnected from ActiveMQ server when the server has shut down.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQDisconnectedException extends ActiveMQException public final class ActiveMQDisconnectedException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.DUPLICATE_ID_RE
/** /**
* A DuplicateID was rejected. * A DuplicateID was rejected.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQDuplicateIdException extends ActiveMQException public final class ActiveMQDuplicateIdException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.DUPLICATE_METAD
/** /**
* A Session Metadata was set in duplication * A Session Metadata was set in duplication
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQDuplicateMetaDataException extends ActiveMQException public final class ActiveMQDuplicateMetaDataException extends ActiveMQException
{ {

View File

@ -18,8 +18,6 @@ package org.apache.activemq.api.core;
/** /**
* ActiveMQException is the root exception for the ActiveMQ API. * ActiveMQException is the root exception for the ActiveMQ API.
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/ */
public class ActiveMQException extends Exception public class ActiveMQException extends Exception
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.IO_ERROR;
/** /**
* Unexpected I/O error occurred on the server. * Unexpected I/O error occurred on the server.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQIOErrorException extends ActiveMQException public final class ActiveMQIOErrorException extends ActiveMQException
{ {

View File

@ -21,7 +21,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.ILLEGAL_STATE;
/** /**
* A ActiveMQ resource is not in a legal state (e.g. calling ClientConsumer.receive() if a * A ActiveMQ resource is not in a legal state (e.g. calling ClientConsumer.receive() if a
* MessageHandler is set). * MessageHandler is set).
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQIllegalStateException extends ActiveMQException public final class ActiveMQIllegalStateException extends ActiveMQException
{ {

View File

@ -22,7 +22,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.INCOMPATIBLE_CL
* The server version and the client version are incompatible. * The server version and the client version are incompatible.
* <p> * <p>
* Normally this means you are trying to use a newer client on an older server. * Normally this means you are trying to use a newer client on an older server.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/ */
public final class ActiveMQIncompatibleClientServerException extends ActiveMQException public final class ActiveMQIncompatibleClientServerException extends ActiveMQException
{ {

View File

@ -21,7 +21,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.INTERCEPTOR_REJ
/** /**
* An outgoing interceptor returned false. * An outgoing interceptor returned false.
* See org.apache.activemq.api.core.client.ServerLocator#addOutgoingInterceptor(org.apache.activemq.api.core.Interceptor) * See org.apache.activemq.api.core.client.ServerLocator#addOutgoingInterceptor(org.apache.activemq.api.core.Interceptor)
* @author Justin Bertram
*/ */
// XXX I doubt any reader will make much sense of this Javadoc's text. // XXX I doubt any reader will make much sense of this Javadoc's text.
public final class ActiveMQInterceptorRejectedPacketException extends ActiveMQException public final class ActiveMQInterceptorRejectedPacketException extends ActiveMQException

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.INTERNAL_ERROR;
/** /**
* Internal error which prevented ActiveMQ from performing an important operation. * Internal error which prevented ActiveMQ from performing an important operation.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQInternalErrorException extends ActiveMQException public final class ActiveMQInternalErrorException extends ActiveMQException
{ {

View File

@ -18,7 +18,6 @@ package org.apache.activemq.api.core;
/** /**
* When an interruption happens, we will just throw a non-checked exception. * When an interruption happens, we will just throw a non-checked exception.
* @author clebertsuconic
*/ */
public final class ActiveMQInterruptedException extends RuntimeException public final class ActiveMQInterruptedException extends RuntimeException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.INVALID_FILTER_
/** /**
* A filter expression was found to be invalid. * A filter expression was found to be invalid.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQInvalidFilterExpressionException extends ActiveMQException public final class ActiveMQInvalidFilterExpressionException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.INVALID_TRANSIE
/** /**
* An operation failed because a queue exists on the server. * An operation failed because a queue exists on the server.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQInvalidTransientQueueUseException extends ActiveMQException public final class ActiveMQInvalidTransientQueueUseException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.LARGE_MESSAGE_E
/** /**
* A problem occurred while manipulating the body of a large message. * A problem occurred while manipulating the body of a large message.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQLargeMessageException extends ActiveMQException public final class ActiveMQLargeMessageException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ package org.apache.activemq.api.core;
import static org.apache.activemq.api.core.ActiveMQExceptionType.LARGE_MESSAGE_INTERRUPTED; import static org.apache.activemq.api.core.ActiveMQExceptionType.LARGE_MESSAGE_INTERRUPTED;
/** /**
* @author Clebert
*/ */
// XXX // XXX
public class ActiveMQLargeMessageInterruptedException extends ActiveMQException public class ActiveMQLargeMessageInterruptedException extends ActiveMQException

View File

@ -19,7 +19,6 @@ package org.apache.activemq.api.core;
/** /**
* An error has happened at ActiveMQ's native (non-Java) code used in reading and writing data. * An error has happened at ActiveMQ's native (non-Java) code used in reading and writing data.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/4/12
*/ */
// XXX // XXX
public final class ActiveMQNativeIOError extends ActiveMQException public final class ActiveMQNativeIOError extends ActiveMQException

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.QUEUE_DOES_NOT_
/** /**
* An operation failed because a queue does not exist on the server. * An operation failed because a queue does not exist on the server.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQNonExistentQueueException extends ActiveMQException public final class ActiveMQNonExistentQueueException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.NOT_CONNECTED;
/** /**
* A client is not able to connect to ActiveMQ server. * A client is not able to connect to ActiveMQ server.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQNotConnectedException extends ActiveMQException public final class ActiveMQNotConnectedException extends ActiveMQException
{ {

View File

@ -21,7 +21,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.OBJECT_CLOSED;
/** /**
* A client operation failed because the calling resource (ClientSession, ClientProducer, etc.) is * A client operation failed because the calling resource (ClientSession, ClientProducer, etc.) is
* closed. * closed.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQObjectClosedException extends ActiveMQException public final class ActiveMQObjectClosedException extends ActiveMQException
{ {

View File

@ -19,7 +19,6 @@ package org.apache.activemq.api.core;
/** /**
* A PropertyConversionException is thrown by {@code org.apache.activemq.api.core.Message} methods when a * A PropertyConversionException is thrown by {@code org.apache.activemq.api.core.Message} methods when a
* property can not be converted to the expected type. * property can not be converted to the expected type.
* @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a>
*/ */
public final class ActiveMQPropertyConversionException extends RuntimeException public final class ActiveMQPropertyConversionException extends RuntimeException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.QUEUE_EXISTS;
/** /**
* An operation failed because a queue exists on the server. * An operation failed because a queue exists on the server.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQQueueExistsException extends ActiveMQException public final class ActiveMQQueueExistsException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.SECURITY_EXCEPT
/** /**
* A security problem occurred (authentication issues, permission issues,...) * A security problem occurred (authentication issues, permission issues,...)
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQSecurityException extends ActiveMQException public final class ActiveMQSecurityException extends ActiveMQException
{ {

View File

@ -21,7 +21,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.SESSION_CREATIO
/** /**
* The creation of a session was rejected by the server (e.g. if the server is starting and has not * The creation of a session was rejected by the server (e.g. if the server is starting and has not
* finish to be initialized. * finish to be initialized.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQSessionCreationException extends ActiveMQException public final class ActiveMQSessionCreationException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.TRANSACTION_OUT
/** /**
* The outcome of a transaction is unknown. * The outcome of a transaction is unknown.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQTransactionOutcomeUnknownException extends ActiveMQException public final class ActiveMQTransactionOutcomeUnknownException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.TRANSACTION_ROL
/** /**
* A transaction was rolled back. * A transaction was rolled back.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 5/2/12
*/ */
public final class ActiveMQTransactionRolledBackException extends ActiveMQException public final class ActiveMQTransactionRolledBackException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.UNBLOCKED;
/** /**
* A blocking call from a client was unblocked during failover. * A blocking call from a client was unblocked during failover.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQUnBlockedException extends ActiveMQException public final class ActiveMQUnBlockedException extends ActiveMQException
{ {

View File

@ -20,7 +20,6 @@ import static org.apache.activemq.api.core.ActiveMQExceptionType.UNSUPPORTED_PAC
/** /**
* A packet of unsupported type was received by ActiveMQ PacketHandler. * A packet of unsupported type was received by ActiveMQ PacketHandler.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> 4/30/12
*/ */
public final class ActiveMQUnsupportedPacketException extends ActiveMQException public final class ActiveMQUnsupportedPacketException extends ActiveMQException
{ {

View File

@ -22,7 +22,6 @@ import java.io.Serializable;
* A Pair is a holder for 2 objects. * A Pair is a holder for 2 objects.
* <p> * <p>
* This is a utility class. * This is a utility class.
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public final class Pair<A, B> implements Serializable public final class Pair<A, B> implements Serializable
{ {

View File

@ -28,7 +28,6 @@ import org.apache.activemq.utils.DataConstants;
* <p> * <p>
* This object is used heavily throughout ActiveMQ for performance reasons. * This object is used heavily throughout ActiveMQ for performance reasons.
* *
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public final class SimpleString implements CharSequence, Serializable, Comparable<SimpleString> public final class SimpleString implements CharSequence, Serializable, Comparable<SimpleString>
{ {

View File

@ -27,8 +27,6 @@ import org.apache.activemq.utils.UTF8Util;
/** /**
* A ChannelBufferWrapper * A ChannelBufferWrapper
*
* @author Tim Fox
*/ */
public class ChannelBufferWrapper implements ActiveMQBuffer public class ChannelBufferWrapper implements ActiveMQBuffer
{ {

View File

@ -18,11 +18,6 @@ package org.apache.activemq.core.server;
/** /**
* A ActiveMQComponent * A ActiveMQComponent
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @version <tt>$Revision: 2796 $</tt>
*
*
*/ */
public interface ActiveMQComponent public interface ActiveMQComponent
{ {

View File

@ -24,9 +24,6 @@ import org.jboss.logging.annotations.MessageBundle;
import org.jboss.logging.Messages; import org.jboss.logging.Messages;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* 3/12/12
*
* Logger Code 20 * Logger Code 20
* *
* each message id must be 6 digits long starting with 20, the 3rd digit should be 9 * each message id must be 6 digits long starting with 20, the 3rd digit should be 9

View File

@ -23,9 +23,6 @@ import org.jboss.logging.annotations.Message;
import org.jboss.logging.annotations.MessageLogger; import org.jboss.logging.annotations.MessageLogger;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
* 3/15/12
*
* Logger Code 20 * Logger Code 20
* *
* each message id must be 6 digits long starting with 20, the 3rd digit donates the level so * each message id must be 6 digits long starting with 20, the 3rd digit donates the level so

View File

@ -27,9 +27,7 @@ import org.jboss.logmanager.ExtLogRecord;
* This class contains a tool where programs could intercept for LogMessage given an interval of time between {@link #startCapture()} * This class contains a tool where programs could intercept for LogMessage given an interval of time between {@link #startCapture()}
* and {@link #stopCapture()} * and {@link #stopCapture()}
* <p/> * <p/>
* Be careful with this use as this is intended for testing only (such as testcases) * * Be careful with this use as this is intended for testing only (such as testcases)
*
* @author <a href="mailto:ehugonne@redhat.com">Emmanuel Hugonnet</a> (c) 2013 Red Hat, inc.
*/ */
public class AssertionLoggerHandler extends ExtHandler public class AssertionLoggerHandler extends ExtHandler
{ {

View File

@ -23,11 +23,7 @@ import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
/** /**
*
* A ActiveMQThreadFactory * A ActiveMQThreadFactory
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*
*/ */
public final class ActiveMQThreadFactory implements ThreadFactory public final class ActiveMQThreadFactory implements ThreadFactory
{ {

View File

@ -92,10 +92,6 @@ import java.nio.charset.StandardCharsets;
* Please visit <a href="http://iharder.net/base64">http://iharder.net/base64</a> * Please visit <a href="http://iharder.net/base64">http://iharder.net/base64</a>
* periodically to check for updates or to contribute improvements. * periodically to check for updates or to contribute improvements.
* </p> * </p>
*
* @author Robert Harder
* @author rob@iharder.net
* @version 2.2.2
*/ */
public class Base64 public class Base64
{ {

View File

@ -19,10 +19,6 @@ package org.apache.activemq.utils;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
import io.netty.buffer.UnpooledByteBufAllocator; import io.netty.buffer.UnpooledByteBufAllocator;
/**
* @author Clebert Suconic
*/
public class ByteUtil public class ByteUtil
{ {

View File

@ -23,8 +23,6 @@ import java.net.URL;
* such as load a class first using TCCL, and then the classLoader used by ActiveMQ (ClassloadingUtil.getClass().getClassLoader()). * such as load a class first using TCCL, and then the classLoader used by ActiveMQ (ClassloadingUtil.getClass().getClassLoader()).
* <p> * <p>
* Is't required to use a Security Block on any calls to this class. * Is't required to use a Security Block on any calls to this class.
*
* @author <a href="mailto:hgao@redhat.com">Howard Gao</a>
*/ */
public final class ClassloadingUtil public final class ClassloadingUtil

View File

@ -27,9 +27,6 @@ import java.util.concurrent.ConcurrentMap;
* *
* Offers same concurrency as ConcurrentHashMap but for a Set * Offers same concurrency as ConcurrentHashMap but for a Set
* *
* @author <a href="tim.fox@jboss.com">Tim Fox</a>
* @version <tt>$Revision: 1935 $</tt>
*
*/ */
public class ConcurrentHashSet<E> extends AbstractSet<E> implements ConcurrentSet<E> public class ConcurrentHashSet<E> extends AbstractSet<E> implements ConcurrentSet<E>
{ {

View File

@ -22,8 +22,6 @@ import java.util.Set;
* *
* A ConcurrentSet * A ConcurrentSet
* *
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*
* @param <E> The generic class * @param <E> The generic class
*/ */
public interface ConcurrentSet<E> extends Set<E> public interface ConcurrentSet<E> extends Set<E>

View File

@ -17,11 +17,7 @@
package org.apache.activemq.utils; package org.apache.activemq.utils;
/** /**
*
* A DataConstants * A DataConstants
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*
*/ */
public final class DataConstants public final class DataConstants
{ {

View File

@ -37,10 +37,6 @@ import javax.crypto.spec.SecretKeySpec;
* *
* The decode() and encode() method is copied originally from * The decode() and encode() method is copied originally from
* JBoss AS code base. * JBoss AS code base.
*
* @author <a href="mailto:hgao@redhat.com">Howard Gao</a>
*
*
*/ */
public class DefaultSensitiveStringCodec implements SensitiveDataCodec<String> public class DefaultSensitiveStringCodec implements SensitiveDataCodec<String>
{ {

View File

@ -27,10 +27,6 @@ import org.apache.activemq.logs.ActiveMQUtilBundle;
/** /**
* A PasswordMarkingUtil * A PasswordMarkingUtil
*
* @author <a href="mailto:hgao@redhat.com">Howard Gao</a>
*
*
*/ */
public class PasswordMaskingUtil public class PasswordMaskingUtil
{ {

View File

@ -16,10 +16,6 @@
*/ */
package org.apache.activemq.utils; package org.apache.activemq.utils;
/**
* @author Clebert Suconic
*/
public interface ReferenceCounter public interface ReferenceCounter
{ {
int increment(); int increment();

View File

@ -19,10 +19,6 @@ package org.apache.activemq.utils;
import java.util.concurrent.Executor; import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
/**
* @author Clebert Suconic
*/
public class ReferenceCounterUtil implements ReferenceCounter public class ReferenceCounterUtil implements ReferenceCounter
{ {
private final Runnable runnable; private final Runnable runnable;

View File

@ -34,8 +34,7 @@ import java.util.concurrent.locks.AbstractQueuedSynchronizer;
* *
* <p>For example: prepareTransaction will wait for the current completions, and further adds will be called on the latch. Later on when commit is called you can reuse the same latch.</p> * <p>For example: prepareTransaction will wait for the current completions, and further adds will be called on the latch. Later on when commit is called you can reuse the same latch.</p>
* *
* @author Clebert Suconic */
* */
public class ReusableLatch public class ReusableLatch
{ {
/** /**

View File

@ -24,10 +24,6 @@ import java.util.Map;
* This interface is used for implementing a value decoder. * This interface is used for implementing a value decoder.
* *
* It takes in a mask value and decode it. * It takes in a mask value and decode it.
*
* @author <a href="mailto:hgao@redhat.com">Howard Gao</a>
*
*
*/ */
public interface SensitiveDataCodec<T> public interface SensitiveDataCodec<T>
{ {

View File

@ -48,9 +48,6 @@ import static org.apache.activemq.utils.DataConstants.STRING;
* (Version 1.1 April 12, 2002). * (Version 1.1 April 12, 2002).
* <p> * <p>
* TODO - should have typed property getters and do conversions herein * TODO - should have typed property getters and do conversions herein
*
* @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 TypedProperties public final class TypedProperties
{ {

View File

@ -23,16 +23,9 @@ import org.apache.activemq.logs.ActiveMQUtilBundle;
import org.apache.activemq.logs.ActiveMQUtilLogger; import org.apache.activemq.logs.ActiveMQUtilLogger;
/** /**
*
* A UTF8Util * A UTF8Util
* *
* This class will write UTFs directly to the ByteOutput (through the MessageBuffer interface) * This class will write UTFs directly to the ByteOutput (through the MessageBuffer interface)
*
* @author <a href="mailto:clebert.suconic@jboss.org">Clebert Suconic</a>
*
* Created Feb 20, 2009 1:37:18 PM
*
*
*/ */
public final class UTF8Util public final class UTF8Util
{ {

View File

@ -16,9 +16,6 @@
*/ */
package org.apache.activemq.utils.uri; package org.apache.activemq.utils.uri;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class SchemaConstants public class SchemaConstants
{ {
public static final String TCP = "tcp"; public static final String TCP = "tcp";

View File

@ -22,9 +22,6 @@ import java.net.URISyntaxException;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
/**
* @author clebertsuconic
*/
public class URIFactory<T, P> public class URIFactory<T, P>
{ {

View File

@ -29,10 +29,6 @@ import java.util.Set;
import org.apache.commons.beanutils.BeanUtilsBean; import org.apache.commons.beanutils.BeanUtilsBean;
import org.apache.commons.beanutils.FluentPropertyBeanIntrospector; import org.apache.commons.beanutils.FluentPropertyBeanIntrospector;
/**
* @author clebertsuconic
*/
public abstract class URISchema<T, P> public abstract class URISchema<T, P>
{ {
public abstract String getSchemaName(); public abstract String getSchemaName();

View File

@ -19,10 +19,6 @@ package org.apache.activemq.utils;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
/**
* @author Clebert Suconic
*/
public class ByteUtilTest public class ByteUtilTest
{ {
@Test @Test

View File

@ -26,10 +26,6 @@ import java.util.concurrent.atomic.AtomicInteger;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
/**
* @author Clebert Suconic
*/
public class ReferenceCounterTest extends Assert public class ReferenceCounterTest extends Assert
{ {

View File

@ -25,10 +25,6 @@ import org.junit.Test;
import java.net.URI; import java.net.URI;
import java.util.Map; import java.util.Map;
/**
* @author clebertsuconic
*/
public class URIParserTest public class URIParserTest
{ {

View File

@ -34,8 +34,6 @@ import java.util.concurrent.TimeUnit;
* of this interface may use different broadcasting techniques like UDP multicasting or * of this interface may use different broadcasting techniques like UDP multicasting or
* JGroups channels. * JGroups channels.
* *
* @author Tomohisa
* @author Howard Gao
* @see JGroupsBroadcastEndpoint * @see JGroupsBroadcastEndpoint
* @see UDPBroadcastEndpoint * @see UDPBroadcastEndpoint
*/ */

View File

@ -25,10 +25,6 @@ import org.apache.activemq.api.config.ActiveMQDefaultConfiguration;
/** /**
* The basic configuration used to determine how the server will broadcast members * The basic configuration used to determine how the server will broadcast members
* This is analogous to {@link org.apache.activemq.api.core.DiscoveryGroupConfiguration} * This is analogous to {@link org.apache.activemq.api.core.DiscoveryGroupConfiguration}
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @author <a href="mailto:hgao@redhat.com">Howard Gao</a>
*
*/ */
public final class BroadcastGroupConfiguration implements Serializable public final class BroadcastGroupConfiguration implements Serializable
{ {

View File

@ -18,9 +18,6 @@ package org.apache.activemq.api.core;
import org.jgroups.JChannel; import org.jgroups.JChannel;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class ChannelBroadcastEndpointFactory implements BroadcastEndpointFactory public class ChannelBroadcastEndpointFactory implements BroadcastEndpointFactory
{ {
private final JChannel channel; private final JChannel channel;

View File

@ -31,8 +31,6 @@ import org.apache.activemq.utils.UUIDGenerator;
* will be filled.<br> * will be filled.<br>
* If by any reason, both properties are filled, the JGroups takes precedence. That means, if * If by any reason, both properties are filled, the JGroups takes precedence. That means, if
* {@code jgroupsFile != null} then the Grouping method used will be JGroups. * {@code jgroupsFile != null} then the Grouping method used will be JGroups.
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @author Clebert Suconic
*/ */
public final class DiscoveryGroupConfiguration implements Serializable public final class DiscoveryGroupConfiguration implements Serializable
{ {

View File

@ -19,7 +19,6 @@ package org.apache.activemq.api.core;
/** /**
* Constants representing pre-defined message attributes that can be referenced in ActiveMQ core * Constants representing pre-defined message attributes that can be referenced in ActiveMQ core
* filter expressions. * filter expressions.
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public final class FilterConstants public final class FilterConstants
{ {

View File

@ -25,9 +25,6 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection;
* To add an interceptor to ActiveMQ server, you have to modify the server configuration file * To add an interceptor to ActiveMQ server, you have to modify the server configuration file
* {@literal activemq-configuration.xml}.<br> * {@literal activemq-configuration.xml}.<br>
* To add it to a client, use {@link org.apache.activemq.api.core.client.ServerLocator#addIncomingInterceptor(Interceptor)} * To add it to a client, use {@link org.apache.activemq.api.core.client.ServerLocator#addIncomingInterceptor(Interceptor)}
*
* @author clebert.suconic@jboss.com
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public interface Interceptor public interface Interceptor
{ {

View File

@ -29,8 +29,6 @@ import java.util.concurrent.TimeUnit;
/** /**
* This class is the implementation of ActiveMQ members discovery that will use JGroups. * This class is the implementation of ActiveMQ members discovery that will use JGroups.
*
* @author Howard Gao
*/ */
public abstract class JGroupsBroadcastEndpoint implements BroadcastEndpoint public abstract class JGroupsBroadcastEndpoint implements BroadcastEndpoint
{ {

View File

@ -18,9 +18,6 @@ package org.apache.activemq.api.core;
import org.jgroups.JChannel; import org.jgroups.JChannel;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class JGroupsChannelBroadcastEndpoint extends JGroupsBroadcastEndpoint public class JGroupsChannelBroadcastEndpoint extends JGroupsBroadcastEndpoint
{ {
private final JChannel jChannel; private final JChannel jChannel;

View File

@ -22,8 +22,6 @@ import java.net.URL;
/** /**
* This class is the implementation of ActiveMQ members discovery that will use JGroups. * This class is the implementation of ActiveMQ members discovery that will use JGroups.
*
* @author Howard Gao
*/ */
public final class JGroupsFileBroadcastEndpoint extends JGroupsBroadcastEndpoint public final class JGroupsFileBroadcastEndpoint extends JGroupsBroadcastEndpoint
{ {

View File

@ -16,9 +16,6 @@
*/ */
package org.apache.activemq.api.core; package org.apache.activemq.api.core;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class JGroupsFileBroadcastEndpointFactory implements BroadcastEndpointFactory public class JGroupsFileBroadcastEndpointFactory implements BroadcastEndpointFactory
{ {
private String file; private String file;

View File

@ -21,8 +21,6 @@ import org.jgroups.conf.PlainConfigurator;
/** /**
* This class is the implementation of ActiveMQ members discovery that will use JGroups. * This class is the implementation of ActiveMQ members discovery that will use JGroups.
*
* @author Howard Gao
*/ */
public final class JGroupsPropertiesBroadcastEndpoint extends JGroupsBroadcastEndpoint public final class JGroupsPropertiesBroadcastEndpoint extends JGroupsBroadcastEndpoint
{ {

View File

@ -16,9 +16,6 @@
*/ */
package org.apache.activemq.api.core; package org.apache.activemq.api.core;
/**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/
public class JGroupsPropertiesBroadcastEndpointFactory implements BroadcastEndpointFactory public class JGroupsPropertiesBroadcastEndpointFactory implements BroadcastEndpointFactory
{ {
private String properties; private String properties;

View File

@ -49,10 +49,6 @@ import org.apache.activemq.utils.UUID;
* <p> * <p>
* If conversion is not allowed (for example calling {@code getFloatProperty} on a property set a * If conversion is not allowed (for example calling {@code getFloatProperty} on a property set a
* {@code boolean}), a {@link ActiveMQPropertyConversionException} will be thrown. * {@code boolean}), a {@link ActiveMQPropertyConversionException} will be thrown.
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @author <a href="mailto:clebert.suconic@jboss.com">ClebertSuconic</a>
* @version <tt>$Revision: 3341 $</tt> $Id: Message.java 3341 2007-11-19 14:34:57Z timfox $
*/ */
public interface Message public interface Message
{ {

View File

@ -40,7 +40,6 @@ import org.apache.activemq.utils.UUIDGenerator;
* TransportConfiguration config = new TransportConfiguration(InVMConnectorFactory.class.getName(), map); * TransportConfiguration config = new TransportConfiguration(InVMConnectorFactory.class.getName(), map);
* ClientSessionFactory sf = new ClientSessionFactoryImpl(config); * ClientSessionFactory sf = new ClientSessionFactoryImpl(config);
* </pre> * </pre>
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public class TransportConfiguration implements Serializable public class TransportConfiguration implements Serializable
{ {

View File

@ -20,8 +20,6 @@ import java.util.Map;
/** /**
* Helper interface for specifying default parameters on Transport Configurations. * Helper interface for specifying default parameters on Transport Configurations.
*
* @author <a href="mailto:mtaylor@redhat.com">Martyn Taylor</a>
*/ */
public interface TransportConfigurationHelper public interface TransportConfigurationHelper
{ {

View File

@ -33,8 +33,6 @@ import org.apache.activemq.core.client.ActiveMQClientLogger;
* The configuration used to determine how the server will broadcast members. * The configuration used to determine how the server will broadcast members.
* <p> * <p>
* This is analogous to {@link org.apache.activemq.api.core.DiscoveryGroupConfiguration} * This is analogous to {@link org.apache.activemq.api.core.DiscoveryGroupConfiguration}
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a> Created 18 Nov 2008 08:44:30
*/ */
public final class UDPBroadcastEndpointFactory implements BroadcastEndpointFactory public final class UDPBroadcastEndpointFactory implements BroadcastEndpointFactory
{ {
@ -106,10 +104,6 @@ public final class UDPBroadcastEndpointFactory implements BroadcastEndpointFacto
/** /**
* <p> This is the member discovery implementation using direct UDP. It was extracted as a refactoring from * <p> This is the member discovery implementation using direct UDP. It was extracted as a refactoring from
* {@link org.apache.activemq.core.cluster.DiscoveryGroup}</p> * {@link org.apache.activemq.core.cluster.DiscoveryGroup}</p>
*
* @author Tomohisa
* @author Howard Gao
* @author Clebert Suconic
*/ */
private static class UDPBroadcastEndpoint implements BroadcastEndpoint private static class UDPBroadcastEndpoint implements BroadcastEndpoint
{ {

View File

@ -31,7 +31,6 @@ import java.net.URI;
* Once a {@link ClientSessionFactory} has been created, it can be further configured using its * Once a {@link ClientSessionFactory} has been created, it can be further configured using its
* setter methods before creating the sessions. Once a session is created, the factory can no longer * setter methods before creating the sessions. Once a session is created, the factory can no longer
* be modified (its setter methods will throw a {@link IllegalStateException}. * be modified (its setter methods will throw a {@link IllegalStateException}.
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
*/ */
public final class ActiveMQClient public final class ActiveMQClient
{ {

View File

@ -29,10 +29,6 @@ import org.apache.activemq.spi.core.remoting.ConsumerContext;
* These 2 types of consumption are exclusive: a ClientConsumer with a MessageHandler set will * These 2 types of consumption are exclusive: a ClientConsumer with a MessageHandler set will
* throw ActiveMQException if its <code>receive()</code> methods are called. * throw ActiveMQException if its <code>receive()</code> methods are called.
* *
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @author <a href="mailto:clebert.suconic@jboss.org">Clebert Suconic</a>
* @author <a href="mailto:ataylor@redhat.com">Andy Taylor</a>
*
* @see ClientSession#createConsumer(String) * @see ClientSession#createConsumer(String)
*/ */
public interface ClientConsumer extends AutoCloseable public interface ClientConsumer extends AutoCloseable

View File

@ -26,10 +26,6 @@ import org.apache.activemq.api.core.SimpleString;
/** /**
* *
* A ClientMessage represents a message sent and/or received by ActiveMQ. * A ClientMessage represents a message sent and/or received by ActiveMQ.
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @author <a href="mailto:clebert.suconic@jboss.com">Clebert Suconic</a>
*
*/ */
public interface ClientMessage extends Message public interface ClientMessage extends Message
{ {

View File

@ -36,8 +36,6 @@ import org.apache.activemq.api.core.SimpleString;
* The send rate can also be controlled via {@link ServerLocator#setProducerMaxRate(int)} and the * The send rate can also be controlled via {@link ServerLocator#setProducerMaxRate(int)} and the
* {@link org.apache.activemq.api.core.client.ServerLocator#setProducerWindowSize(int)}. <br> * {@link org.apache.activemq.api.core.client.ServerLocator#setProducerWindowSize(int)}. <br>
* <br> * <br>
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @author <a href="mailto:ataylor@redhat.com">Andy Taylor</a>
*/ */
public interface ClientProducer extends AutoCloseable public interface ClientProducer extends AutoCloseable
{ {

View File

@ -26,8 +26,6 @@ import org.apache.activemq.core.client.impl.ClientMessageImpl;
* <br> * <br>
* The ClientRequestor constructor is given a ClientSession and a request address. * The ClientRequestor constructor is given a ClientSession and a request address.
* It creates a temporary queue for the responses and provides a request method that sends the request message and waits for its reply. * It creates a temporary queue for the responses and provides a request method that sends the request message and waits for its reply.
*
* @author <a href="jmesnil@redhat.com">Jeff Mesnil</a>
*/ */
public final class ClientRequestor public final class ClientRequestor
{ {

View File

@ -24,11 +24,6 @@ import org.apache.activemq.api.core.SimpleString;
/** /**
* A ClientSession is a single-thread object required for producing and consuming messages. * A ClientSession is a single-thread object required for producing and consuming messages.
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @author <a href="mailto:clebert.suconic@jboss.org">Clebert Suconic</a>
* @author <a href="mailto:ataylor@redhat.com">Andy Taylor</a>
* @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a>
*/ */
public interface ClientSession extends XAResource, AutoCloseable public interface ClientSession extends XAResource, AutoCloseable
{ {

View File

@ -26,8 +26,6 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection;
* <br> * <br>
* It is possible to configure a factory using the setter methods only if no session has been created. * It is possible to configure a factory using the setter methods only if no session has been created.
* Once a session is created, the configuration is fixed and any call to a setter method will throw a IllegalStateException. * Once a session is created, the configuration is fixed and any call to a setter method will throw a IllegalStateException.
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public interface ClientSessionFactory extends AutoCloseable public interface ClientSessionFactory extends AutoCloseable
{ {

View File

@ -22,7 +22,6 @@ package org.apache.activemq.api.core.client;
* Used to get notification of topology events. After adding a listener to the cluster connection, * Used to get notification of topology events. After adding a listener to the cluster connection,
* the listener receives {@link #nodeUP(TopologyMember, boolean)} for all the current topology * the listener receives {@link #nodeUP(TopologyMember, boolean)} for all the current topology
* members. * members.
* @author tim
*/ */
public interface ClusterTopologyListener public interface ClusterTopologyListener
{ {

View File

@ -18,8 +18,6 @@ package org.apache.activemq.api.core.client;
/** /**
* A FailoverEvent notifies the client the state if the connection changes occurred on the session. * A FailoverEvent notifies the client the state if the connection changes occurred on the session.
*
* @author <a href="mailto:flemming.harms@gmail.com">Flemming Harms</a>
*/ */
public interface FailoverEventListener public interface FailoverEventListener
{ {

View File

@ -21,7 +21,6 @@ package org.apache.activemq.api.core.client;
* <p> * <p>
* To receive messages asynchronously, a MessageHandler is set on a ClientConsumer. Every time the * To receive messages asynchronously, a MessageHandler is set on a ClientConsumer. Every time the
* consumer will receive a message, it will call the handler's {@code onMessage()} method. * consumer will receive a message, it will call the handler's {@code onMessage()} method.
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
* @see ClientConsumer#setMessageHandler(MessageHandler) * @see ClientConsumer#setMessageHandler(MessageHandler)
*/ */
public interface MessageHandler public interface MessageHandler

View File

@ -32,7 +32,6 @@ import org.apache.activemq.api.core.Message;
* <p> * <p>
* Notice that this notification will only take place if {@code ConfirmationWindowSize} is set to a * Notice that this notification will only take place if {@code ConfirmationWindowSize} is set to a
* positive value at {@link ServerLocator#setConfirmationWindowSize(int)}. * positive value at {@link ServerLocator#setConfirmationWindowSize(int)}.
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public interface SendAcknowledgementHandler public interface SendAcknowledgementHandler
{ {

View File

@ -32,8 +32,6 @@ import org.apache.activemq.spi.core.remoting.ClientProtocolManagerFactory;
* If you use UDP or JGroups (exclusively JGroups or UDP), the initial discovery is done by the * If you use UDP or JGroups (exclusively JGroups or UDP), the initial discovery is done by the
* grouping finder, after the initial connection is made the server will always send updates to the * grouping finder, after the initial connection is made the server will always send updates to the
* client. But the listeners will listen for updates on grouping. * client. But the listeners will listen for updates on grouping.
*
* @author Tim Fox
*/ */
public interface ServerLocator extends AutoCloseable public interface ServerLocator extends AutoCloseable
{ {

View File

@ -21,8 +21,6 @@ import org.apache.activemq.core.remoting.FailureListener;
/** /**
* A SessionFailureListener notifies the client when a failure occurred on the session. * A SessionFailureListener notifies the client when a failure occurred on the session.
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public interface SessionFailureListener extends FailureListener public interface SessionFailureListener extends FailureListener
{ {

View File

@ -18,8 +18,6 @@ package org.apache.activemq.api.core.client.loadbalance;
/** /**
* A ConnectionLoadBalancingPolicy defines a policy to load balance between connections. * A ConnectionLoadBalancingPolicy defines a policy to load balance between connections.
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*/ */
public interface ConnectionLoadBalancingPolicy public interface ConnectionLoadBalancingPolicy
{ {

View File

@ -19,10 +19,6 @@ package org.apache.activemq.api.core.client.loadbalance;
/** /**
* A {@link FirstElementConnectionLoadBalancingPolicy#select(int)} always returns 0. * A {@link FirstElementConnectionLoadBalancingPolicy#select(int)} always returns 0.
*
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
*
* Created 28 Nov 2008 10:56:59
*/ */
public final class FirstElementConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy public final class FirstElementConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy
{ {

View File

@ -21,7 +21,6 @@ import org.apache.activemq.utils.Random;
/** /**
* {@link RandomConnectionLoadBalancingPolicy#select(int)} returns a (pseudo) random integer between * {@link RandomConnectionLoadBalancingPolicy#select(int)} returns a (pseudo) random integer between
* {@code 0} (inclusive) and {@code max} (exclusive). * {@code 0} (inclusive) and {@code max} (exclusive).
* @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a> Created 28 Nov 2008 10:24:11
*/ */
public final class RandomConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy public final class RandomConnectionLoadBalancingPolicy implements ConnectionLoadBalancingPolicy
{ {

Some files were not shown because too many files have changed in this diff Show More