com.couchbase.client
Class ViewNode
java.lang.Object
net.spy.memcached.compat.SpyObject
com.couchbase.client.ViewNode
public class ViewNode
- extends net.spy.memcached.compat.SpyObject
Establishes a HTTP connection to a single Couchbase node.
Based upon http://hc.apache.org/httpcomponents-core-ga/httpcore-nio/
examples/org/apache/http/examples/nio/NHttpClientConnManagement.java
Constructor Summary |
ViewNode(java.net.InetSocketAddress a,
AsyncConnectionManager mgr,
long queueLen,
long maxBlockTime,
long operationTimeout,
java.lang.String usr,
java.lang.String pwd)
|
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 |
ViewNode
public ViewNode(java.net.InetSocketAddress a,
AsyncConnectionManager mgr,
long queueLen,
long maxBlockTime,
long operationTimeout,
java.lang.String usr,
java.lang.String pwd)
init
public void init()
throws org.apache.http.nio.reactor.IOReactorException
- Throws:
org.apache.http.nio.reactor.IOReactorException
writeOp
public boolean writeOp(HttpOperation op)
hasWriteOps
public boolean hasWriteOps()
getSocketAddress
public java.net.InetSocketAddress getSocketAddress()
shutdown
public void shutdown()
throws java.io.IOException
- Throws:
java.io.IOException
shutdown
public void shutdown(long time,
java.util.concurrent.TimeUnit unit)
throws java.io.IOException
- Throws:
java.io.IOException
isShuttingDown
public boolean isShuttingDown()
Copyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.