[jbosscache-commits] JBoss Cache SVN: r5762 - core/trunk/src/main/java/org/jboss/cache/loader.

Author: manik.surtani(a)jboss.com Date: 2008-04-29 19:27:26 -0400 (Tue, 29 Apr 2008) New Revision: 5762 Modified: core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java Log: Removed unused states Modified: core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java 2008-04-29 23:26:38 UTC (rev 5761) +++ core/trunk/src/main/java/org/jboss/cache/loader/TcpDelegatingCacheLoader.java 2008-04-29 23:27:26 UTC (rev 5762) @@ -48,13 +48,7 @@ ObjectOutputStream out; private static final Log log = LogFactory.getLog(TcpDelegatingCacheLoader.class); private static Method GET_CHILDREN_METHOD, GET_METHOD, PUT_KEY_METHOD, PUT_DATA_METHOD, REMOVE_KEY_METHOD, REMOVE_METHOD, PUT_MODS_METHOD, EXISTS_METHOD, REMOVE_DATA_METHOD; - private State state = State.STOPPED; - private enum State - { - STOPPED, STARTING, STARTED - } - static { try @@ -375,18 +369,15 @@ @Override public void start() throws IOException { - state = State.STARTING; sock = new Socket(config.getHost(), config.getPort()); out = new ObjectOutputStream(new BufferedOutputStream(sock.getOutputStream())); out.flush(); in = new ObjectInputStream(new BufferedInputStream(sock.getInputStream())); - state = State.STARTED; } @Override public void stop() { - state = State.STOPPED; try { if (in != null) in.close();