Author: david.lloyd(a)jboss.com Date: 2009-02-26 12:58:02 -0500 (Thu, 26 Feb 2009) New Revision: 4854 Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/AbstractContextImpl.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientContextImpl.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientExternalizer.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientImpl.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientSourceExternalizer.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientSourceImpl.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ConcurrentReferenceHashMap.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/EndpointImpl.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/FutureClientSource.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/FutureReplyImpl.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/LocalRequestHandler.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/LocalRequestHandlerSource.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/OrderedExecutor.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/QueueExecutor.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/RequestContextImpl.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/RequestListenerExecutor.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ServiceContextImpl.java remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ServiceRegistration.java Log: public -> package private Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/AbstractContextImpl.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/AbstractContextImpl.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/AbstractContextImpl.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -30,11 +30,11 @@ /** * */ -public abstract class AbstractContextImpl<T> extends AbstractHandleableCloseable<T> { +abstract class AbstractContextImpl<T> extends AbstractHandleableCloseable<T> { private final ConcurrentMap<Object, Object> attributes = new ConcurrentHashMap<Object, Object>(); - protected AbstractContextImpl(final Executor executor) { + AbstractContextImpl(final Executor executor) { super(executor); } Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientContextImpl.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientContextImpl.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientContextImpl.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -30,7 +30,7 @@ /** * */ -public final class ClientContextImpl extends AbstractContextImpl<ClientContext> implements ClientContext { +final class ClientContextImpl extends AbstractContextImpl<ClientContext> implements ClientContext { private static final Logger log = Logger.getLogger("org.jboss.remoting.client-context"); Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientExternalizer.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientExternalizer.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientExternalizer.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -32,7 +32,7 @@ /** * */ -public final class ClientExternalizer implements Externalizer { +final class ClientExternalizer implements Externalizer { private static final long serialVersionUID = 814228455390899997L; Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientImpl.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientImpl.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientImpl.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -28,7 +28,6 @@ import org.jboss.remoting.CloseHandler; import org.jboss.remoting.IndeterminateOutcomeException; import org.jboss.remoting.RemoteRequestException; -import org.jboss.remoting.core.QueueExecutor; import org.jboss.remoting.spi.Handle; import org.jboss.remoting.spi.RemoteRequestContext; import org.jboss.remoting.spi.ReplyHandler; @@ -40,7 +39,7 @@ /** * */ -public final class ClientImpl<I, O> extends AbstractContextImpl<Client<I, O>> implements Client<I, O> { +final class ClientImpl<I, O> extends AbstractContextImpl<Client<I, O>> implements Client<I, O> { private static final Logger log = Logger.getLogger("org.jboss.remoting.client"); Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientSourceExternalizer.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientSourceExternalizer.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientSourceExternalizer.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -32,7 +32,7 @@ /** * */ -public final class ClientSourceExternalizer implements Externalizer { +final class ClientSourceExternalizer implements Externalizer { private static final long serialVersionUID = 814228455390899997L; Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientSourceImpl.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientSourceImpl.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientSourceImpl.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -37,7 +37,7 @@ /** * */ -public final class ClientSourceImpl<I, O> extends AbstractHandleableCloseable<ClientSource<I, O>> implements ClientSource<I, O> { +final class ClientSourceImpl<I, O> extends AbstractHandleableCloseable<ClientSource<I, O>> implements ClientSource<I, O> { private static final Logger log = Logger.getLogger("org.jboss.remoting.client-source"); Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ConcurrentReferenceHashMap.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ConcurrentReferenceHashMap.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ConcurrentReferenceHashMap.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -124,7 +124,7 @@ * @param <K> the type of keys maintained by this map * @param <V> the type of mapped values */ -public class ConcurrentReferenceHashMap<K, V> extends AbstractMap<K, V> +class ConcurrentReferenceHashMap<K, V> extends AbstractMap<K, V> implements java.util.concurrent.ConcurrentMap<K, V>, Serializable { private static final long serialVersionUID = 7249069246763182397L; Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/EndpointImpl.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/EndpointImpl.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/EndpointImpl.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -40,7 +40,7 @@ /** * */ -public final class EndpointImpl extends AbstractHandleableCloseable<Endpoint> implements Endpoint { +final class EndpointImpl extends AbstractHandleableCloseable<Endpoint> implements Endpoint { static { // Print Remoting "greeting" message Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/FutureClientSource.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/FutureClientSource.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/FutureClientSource.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -32,7 +32,7 @@ /** * */ -public final class FutureClientSource<I, O> extends AbstractIoFuture<ClientSource<I, O>> { +final class FutureClientSource<I, O> extends AbstractIoFuture<ClientSource<I, O>> { private volatile SimpleCloseable listenerHandle; Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/FutureReplyImpl.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/FutureReplyImpl.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/FutureReplyImpl.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -33,14 +33,14 @@ /** * */ -public final class FutureReplyImpl<O> extends AbstractIoFuture<O> { +final class FutureReplyImpl<O> extends AbstractIoFuture<O> { private final Executor executor; private final Class<O> replyType; private final ReplyHandler replyHandler = new Handler(); private volatile RemoteRequestContext remoteRequestContext; - public FutureReplyImpl(final Executor executor, final Class<O> replyType) { + FutureReplyImpl(final Executor executor, final Class<O> replyType) { this.executor = executor; this.replyType = replyType; } Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/LocalRequestHandler.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/LocalRequestHandler.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/LocalRequestHandler.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -38,7 +38,7 @@ /** * */ -public final class LocalRequestHandler<I, O> extends AbstractAutoCloseable<RequestHandler> implements RequestHandler { +final class LocalRequestHandler<I, O> extends AbstractAutoCloseable<RequestHandler> implements RequestHandler { private final RequestListener<I, O> requestListener; private final ClientContextImpl clientContext; Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/LocalRequestHandlerSource.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/LocalRequestHandlerSource.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/LocalRequestHandlerSource.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -35,7 +35,7 @@ /** * */ -public final class LocalRequestHandlerSource<I, O> extends AbstractAutoCloseable<RequestHandlerSource> implements RequestHandlerSource { +final class LocalRequestHandlerSource<I, O> extends AbstractAutoCloseable<RequestHandlerSource> implements RequestHandlerSource { private final RequestListener<I, O> requestListener; private final ServiceContextImpl serviceContext; Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/OrderedExecutor.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/OrderedExecutor.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/OrderedExecutor.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -32,7 +32,7 @@ * More specifically, any call B to the {@link #execute(Runnable)} method that happens-after another call A to the * same method, will result in B's task running after A's. */ -public final class OrderedExecutor implements Executor { +final class OrderedExecutor implements Executor { private static final Logger log = Logger.getLogger(OrderedExecutor.class); // @protectedby tasks @@ -47,7 +47,7 @@ * * @param parent the parent executor */ - public OrderedExecutor(final Executor parent) { + OrderedExecutor(final Executor parent) { this.parent = parent; runner = new Runnable() { public void run() { Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/QueueExecutor.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/QueueExecutor.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/QueueExecutor.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -11,7 +11,7 @@ * Only one thread should invoke the {@code runQueue()} method, which will run until the executor is * shut down. */ -public final class QueueExecutor implements CloseableExecutor { +final class QueueExecutor implements CloseableExecutor { private static final Logger log = org.jboss.xnio.log.Logger.getLogger(QueueExecutor.class); private final Queue<Runnable> queue = new LinkedList<Runnable>(); Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/RequestContextImpl.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/RequestContextImpl.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/RequestContextImpl.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -40,7 +40,7 @@ /** * */ -public final class RequestContextImpl<O> implements RequestContext<O> { +final class RequestContextImpl<O> implements RequestContext<O> { private final AtomicBoolean closed = new AtomicBoolean(); private final Object cancelLock = new Object(); Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/RequestListenerExecutor.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/RequestListenerExecutor.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/RequestListenerExecutor.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -30,7 +30,7 @@ /** * */ -public final class RequestListenerExecutor implements Executor { +final class RequestListenerExecutor implements Executor { private final Set<Task> tasks = Collections.synchronizedSet(new HashSet<Task>()); private final Executor executor; Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ServiceContextImpl.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ServiceContextImpl.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ServiceContextImpl.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -29,7 +29,7 @@ /** * */ -public final class ServiceContextImpl extends AbstractContextImpl<ServiceContext> implements ServiceContext { +final class ServiceContextImpl extends AbstractContextImpl<ServiceContext> implements ServiceContext { private static final Logger log = Logger.getLogger("org.jboss.remoting.service-context"); protected ServiceContextImpl(final Executor executor) { Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ServiceRegistration.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ServiceRegistration.java 2009-02-26 02:48:28 UTC (rev 4853) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ServiceRegistration.java 2009-02-26 17:58:02 UTC (rev 4854) @@ -28,7 +28,7 @@ /** * */ -public final class ServiceRegistration { +final class ServiceRegistration { private final boolean remote; private final String serviceType; private final String groupName;