Author: david.lloyd(a)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() {
Show replies by date