com.couchbase.client
Class ViewNode

java.lang.Object
  extended by net.spy.memcached.compat.SpyObject
      extended by 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)
           
 
Method Summary
 java.net.InetSocketAddress getSocketAddress()
           
 boolean hasWriteOps()
           
 void init()
           
 boolean isShuttingDown()
           
 void shutdown()
           
 void shutdown(long time, java.util.concurrent.TimeUnit unit)
           
 boolean writeOp(HttpOperation op)
           
 
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

ViewNode

public ViewNode(java.net.InetSocketAddress a,
                AsyncConnectionManager mgr,
                long queueLen,
                long maxBlockTime,
                long operationTimeout,
                java.lang.String usr,
                java.lang.String pwd)
Method Detail

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.