net.spy.memcached
Class CouchbaseNode

java.lang.Object
  net.spy.memcached.compat.SpyObject
      net.spy.memcached.CouchbaseNode

public class CouchbaseNode
extends SpyObject

Constructor Summary

CouchbaseNode(InetSocketAddress a, AsyncConnectionManager mgr, LinkedBlockingQueue<HttpOperation> linkedBlockingQueue, long maxBlockTime, long operationTimeout)

Method Summary

void	addOp(HttpOperation op)
Collection<HttpOperation>	destroyWriteQueue()
void	doWrites()
InetSocketAddress	getSocketAddress()
boolean	hasWriteOps()
void	init()
void	shutdown()
void	shutdown(long time, TimeUnit unit)

Methods inherited from class net.spy.memcached.compat.SpyObject

getLogger

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CouchbaseNode

public CouchbaseNode(InetSocketAddress a,
                     AsyncConnectionManager mgr,
                     LinkedBlockingQueue<HttpOperation> linkedBlockingQueue,
                     long maxBlockTime,
                     long operationTimeout)

Method Detail

init

public void init()
          throws org.apache.http.nio.reactor.IOReactorException

Throws:

org.apache.http.nio.reactor.IOReactorException

doWrites

public void doWrites()

destroyWriteQueue

public Collection<HttpOperation> destroyWriteQueue()

hasWriteOps

public boolean hasWriteOps()

addOp

public void addOp(HttpOperation op)

getSocketAddress

public InetSocketAddress getSocketAddress()

shutdown

public void shutdown()
              throws IOException

Throws:

IOException

shutdown

public void shutdown(long time,
                     TimeUnit unit)
              throws IOException

Throws:

IOException