public class TapConnectionProvider extends net.spy.memcached.TapConnectionProvider implements Reconfigurable
Constructor and Description |
---|
TapConnectionProvider(CouchbaseConnectionFactory cf)
Get a tap connection based on the REST response from a Couchbase server.
|
TapConnectionProvider(java.util.List<java.net.URI> baseList,
java.lang.String bucketName,
java.lang.String pwd)
Get a tap connection based on the REST response from a Couchbase server.
|
Modifier and Type | Method and Description |
---|---|
boolean |
isPrimaryForKey(net.spy.memcached.MemcachedNode node,
java.lang.String key) |
void |
reconfigure(Bucket bucket)
Call on a configuration update.
|
boolean |
removeObserver(net.spy.memcached.ConnectionObserver obs)
Remove a connection observer.
|
void |
shutdown() |
public TapConnectionProvider(java.util.List<java.net.URI> baseList, java.lang.String bucketName, java.lang.String pwd) throws java.io.IOException, javax.naming.ConfigurationException
baseList
- A list of URI's to use for getting cluster information.bucketName
- The name of the bucket to connect to.pwd
- The password for the bucket.java.io.IOException
javax.naming.ConfigurationException
public TapConnectionProvider(CouchbaseConnectionFactory cf) throws java.io.IOException, javax.naming.ConfigurationException
cf
- A connection factory to create the tap stream withjava.io.IOException
javax.naming.ConfigurationException
public boolean removeObserver(net.spy.memcached.ConnectionObserver obs)
removeObserver
in class net.spy.memcached.TapConnectionProvider
obs
- the ConnectionObserver you wish to addpublic void reconfigure(Bucket bucket)
Reconfigurable
reconfigure
in interface Reconfigurable
bucket
- updated vbucket configurationpublic boolean isPrimaryForKey(net.spy.memcached.MemcachedNode node, java.lang.String key)
public void shutdown()
shutdown
in class net.spy.memcached.TapConnectionProvider
Copyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.