[jboss-remoting-commits] JBoss Remoting SVN: r4854 - remoting3/trunk/core/src/main/java/org/jboss/remoting/core.
jboss-remoting-commits at lists.jboss.org
jboss-remoting-commits at lists.jboss.org
Thu Feb 26 12:58:02 EST 2009
Author: david.lloyd at 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;
More information about the jboss-remoting-commits
mailing list