public class CouchbaseConfigConnection extends CouchbaseConnection
CouchbaseConnection
that is used for binary config
fetching.
It is used to customize different codepaths and also transparently redirect
logging so that it makes sense as part of the overall application (without
having to modify a lot of code from the inherited classes).Modifier and Type | Class and Description |
---|---|
static class |
CouchbaseConfigConnection.LoggerProxy |
ALLOWED_IDLE_TIME, cf, lastWrite, reconfiguring
Constructor and Description |
---|
CouchbaseConfigConnection(int bufSize,
CouchbaseConnectionFactory f,
java.util.List<java.net.InetSocketAddress> a,
java.util.Collection<net.spy.memcached.ConnectionObserver> obs,
net.spy.memcached.FailureMode fm,
net.spy.memcached.OperationFactory opfactory) |
Modifier and Type | Method and Description |
---|---|
protected net.spy.memcached.compat.log.Logger |
getLogger() |
protected void |
handleWokenUpSelector()
Make sure that if the selector is woken up manually for an extended period
of time that the sockets are still alive.
|
java.lang.String |
toString() |
addOperation, addOperations, handleRetryInformation, queueReconnect, reconfigure, replaceConfigWildcards, run, updateLastWrite
addObserver, addOperation, broadcastOperation, broadcastOperation, checkState, connectionsStatus, createConnections, enqueueOperation, getLocator, handleIO, insertOperation, isShutDown, opSucceeded, opTimedOut, redistributeOperation, redistributeOperations, registerMetrics, removeObserver, retryOperation, shutdown
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield
public CouchbaseConfigConnection(int bufSize, CouchbaseConnectionFactory f, java.util.List<java.net.InetSocketAddress> a, java.util.Collection<net.spy.memcached.ConnectionObserver> obs, net.spy.memcached.FailureMode fm, net.spy.memcached.OperationFactory opfactory) throws java.io.IOException
java.io.IOException
public java.lang.String toString()
toString
in class net.spy.memcached.MemcachedConnection
protected void handleWokenUpSelector()
CouchbaseConnection
This is done by broadcasting a operation so that disconnected sockets are discovered even when no load is applied.
handleWokenUpSelector
in class CouchbaseConnection
protected net.spy.memcached.compat.log.Logger getLogger()
getLogger
in class net.spy.memcached.compat.SpyThread
Copyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.