[jboss-remoting-commits] JBoss Remoting SVN: r4363 - remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core.

[jboss-remoting-commits at lists.jboss.org]

Author: david.lloyd at jboss.com
Date: 2008-07-03 21:57:58 -0400 (Thu, 03 Jul 2008)
New Revision: 4363

Modified:
   remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/EndpointImpl.java
Log:
Lifecycle management goes to the container

Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/EndpointImpl.java
===================================================================
--- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/EndpointImpl.java	2008-07-04 01:44:26 UTC (rev 4362)
+++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/EndpointImpl.java	2008-07-04 01:57:58 UTC (rev 4363)
@@ -10,7 +10,6 @@
 import org.jboss.cx.remoting.core.util.OrderedExecutorFactory;
 import org.jboss.cx.remoting.spi.remote.RemoteClientEndpoint;
 import org.jboss.cx.remoting.spi.remote.RemoteServiceEndpoint;
-import org.jboss.cx.remoting.util.AtomicStateMachine;
 import org.jboss.cx.remoting.util.CollectionUtil;
 import org.jboss.cx.remoting.util.NamingThreadFactory;
 import org.jboss.cx.remoting.version.Version;
@@ -26,20 +25,8 @@
         Logger.getLogger("org.jboss.cx.remoting").info("JBoss Remoting version %s", Version.VERSION);
     }
 
-    private enum State implements org.jboss.cx.remoting.util.State<State> {
-        INITIAL,
-        UP,
-        DOWN;
-
-        public boolean isReachable(final State dest) {
-            return compareTo(dest) < 0;
-        }
-    }
-
     private String name;
 
-    private final AtomicStateMachine<State> state = AtomicStateMachine.start(State.INITIAL);
-
     private OrderedExecutorFactory orderedExecutorFactory;
     private ExecutorService executorService;
 
@@ -83,7 +70,6 @@
             executor = executorService = Executors.newCachedThreadPool(new NamingThreadFactory(Executors.defaultThreadFactory(), "Remoting endpoint %s"));
             setExecutor(executorService);
         }
-        state.requireTransition(State.INITIAL, State.UP);
     }
 
     public void stop() {