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();
Show replies by date