public class TapConnectionProvider extends TapConnectionProvider implements Reconfigurable
authDescriptor, authMonitor, conn, opFact, shuttingDown, tcService
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(MemcachedNode node,
java.lang.String key) |
void |
reconfigure(Bucket bucket)
Call on a configuration update.
|
boolean |
removeObserver(ConnectionObserver obs)
Remove a connection observer.
|
void |
shutdown()
Shut down immediately.
|
addObserver, addTapAckOp, broadcastOp, connectionEstablished, connectionLost, getOpFactory, shutdown, waitForQueues
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
ConfigurationException
public TapConnectionProvider(CouchbaseConnectionFactory cf) throws java.io.IOException
cf
- A connection factory to create the tap stream withjava.io.IOException
ConfigurationException
public boolean removeObserver(ConnectionObserver obs)
removeObserver
in class TapConnectionProvider
obs
- the ConnectionObserver you wish to addpublic void reconfigure(Bucket bucket)
Reconfigurable
reconfigure
in interface Reconfigurable
bucket
- updated vbucket configurationpublic boolean isPrimaryForKey(MemcachedNode node, java.lang.String key)
public void shutdown()
TapConnectionProvider
shutdown
in class TapConnectionProvider
Copyright © 2006-2009 Dustin Sallings, 2009-2014 Couchbase, Inc.