public class CouchbaseConnection extends net.spy.memcached.MemcachedConnection implements Reconfigurable
Modifier and Type | Field and Description |
---|---|
protected boolean |
reconfiguring |
Constructor and Description |
---|
CouchbaseConnection(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 |
---|---|
void |
addOperation(java.lang.String key,
net.spy.memcached.ops.Operation o)
Add an operation to the given connection.
|
void |
addOperations(java.util.Map<net.spy.memcached.MemcachedNode,net.spy.memcached.ops.Operation> ops) |
void |
reconfigure(Bucket bucket)
Call on a configuration update.
|
void |
run()
Infinitely loop processing IO.
|
addObserver, addOperation, broadcastOperation, broadcastOperation, checkState, createConnections, enqueueOperation, getLocator, handleIO, insertOperation, opSucceeded, opTimedOut, queueReconnect, removeObserver, shutdown, toString
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 CouchbaseConnection(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 void reconfigure(Bucket bucket)
Reconfigurable
reconfigure
in interface Reconfigurable
bucket
- updated vbucket configurationpublic void addOperation(java.lang.String key, net.spy.memcached.ops.Operation o)
addOperation
in class net.spy.memcached.MemcachedConnection
key
- the key the operation is operating upono
- the operationpublic void addOperations(java.util.Map<net.spy.memcached.MemcachedNode,net.spy.memcached.ops.Operation> ops)
addOperations
in class net.spy.memcached.MemcachedConnection
public void run()
run
in interface java.lang.Runnable
run
in class net.spy.memcached.MemcachedConnection
Copyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.