[jbosscache-commits] JBoss Cache SVN: r5762 - core/trunk/src/main/java/org/jboss/cache/loader.
jbosscache-commits at lists.jboss.org
jbosscache-commits at lists.jboss.org
Tue Apr 29 19:27:26 EDT 2008
Author: manik.surtani at 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();
More information about the jbosscache-commits
mailing list