Project JXTA

net.jxta.impl.pipe
Class NonBlockingOutputPipe.workerState

java.lang.Object
  extended bynet.jxta.impl.pipe.NonBlockingOutputPipe.workerState
Enclosing class:
NonBlockingOutputPipe

static class NonBlockingOutputPipe.workerState
extends Object

Tracks the state of our worker thread.


Field Summary
static NonBlockingOutputPipe.workerState ACQUIREMESSENGER
          Acquire a messenger to the destination peer.
static NonBlockingOutputPipe.workerState CLOSED
          Exit.
static NonBlockingOutputPipe.workerState PENDINGMIGRATE
          Issue resolution queries and wait for responses
static NonBlockingOutputPipe.workerState PENDINGVERIFY
          Issue verify queries and wait for responses
static NonBlockingOutputPipe.workerState SENDMESSAGES
          Send messages via the messenger to the destination peer.
static NonBlockingOutputPipe.workerState STARTMIGRATE
          Find a new eligible destination peer which is listening on the pipe.
static NonBlockingOutputPipe.workerState STARTVERIFY
          Determine if the destination peer is still listening on the pipe.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

STARTMIGRATE

public static final NonBlockingOutputPipe.workerState STARTMIGRATE
Find a new eligible destination peer which is listening on the pipe.


PENDINGMIGRATE

public static final NonBlockingOutputPipe.workerState PENDINGMIGRATE
Issue resolution queries and wait for responses


STARTVERIFY

public static final NonBlockingOutputPipe.workerState STARTVERIFY
Determine if the destination peer is still listening on the pipe.


PENDINGVERIFY

public static final NonBlockingOutputPipe.workerState PENDINGVERIFY
Issue verify queries and wait for responses


ACQUIREMESSENGER

public static final NonBlockingOutputPipe.workerState ACQUIREMESSENGER
Acquire a messenger to the destination peer.


SENDMESSAGES

public static final NonBlockingOutputPipe.workerState SENDMESSAGES
Send messages via the messenger to the destination peer.


CLOSED

public static final NonBlockingOutputPipe.workerState CLOSED
Exit.


JXTA J2SE