com.couchbase.client

Class TapConnectionProvider

java.lang.Object

net.spy.memcached.compat.SpyObject

net.spy.memcached.TapConnectionProvider

com.couchbase.client.TapConnectionProvider

All Implemented Interfaces:

Reconfigurable, ConnectionObserver

public class TapConnectionProvider
extends TapConnectionProvider
implements Reconfigurable

A TapConnectionProvider for Couchbase Server.

Field Summary

Fields inherited from class net.spy.memcached.TapConnectionProvider

authDescriptor, authMonitor, conn, opFact, shuttingDown, tcService

Constructor Summary

Constructors

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.

Method Summary

Methods

Modifier and Type	Method and Description
void	reconfigure(Bucket bucket) Call on a configuration update.
boolean	removeObserver(ConnectionObserver obs) Remove a connection observer.
void	shutdown() Shut down immediately.

Methods inherited from class net.spy.memcached.TapConnectionProvider

addObserver, addTapAckOp, broadcastOp, connectionEstablished, connectionLost, getOpFactory, shutdown, waitForQueues

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

TapConnectionProvider

public TapConnectionProvider(java.util.List<java.net.URI> baseList,
                     java.lang.String bucketName,
                     java.lang.String pwd)
                      throws java.io.IOException,
                             javax.naming.ConfigurationException

Get a tap connection based on the REST response from a Couchbase server.

Parameters:

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.

Throws:

java.io.IOException

ConfigurationException

TapConnectionProvider

public TapConnectionProvider(CouchbaseConnectionFactory cf)
                      throws java.io.IOException,
                             javax.naming.ConfigurationException

Get a tap connection based on the REST response from a Couchbase server.

Parameters:

cf - A connection factory to create the tap stream with

Throws:

java.io.IOException

ConfigurationException

Method Detail

removeObserver

public boolean removeObserver(ConnectionObserver obs)

Remove a connection observer.

Overrides:

removeObserver in class TapConnectionProvider

Parameters:

obs - the ConnectionObserver you wish to add

Returns:

true if the observer existed, but no longer does

reconfigure

public void reconfigure(Bucket bucket)

Description copied from interface: Reconfigurable

Call on a configuration update.

Specified by:

reconfigure in interface Reconfigurable

Parameters:

bucket - updated vbucket configuration

shutdown

public void shutdown()

Description copied from class: TapConnectionProvider

Shut down immediately.

Overrides:

shutdown in class TapConnectionProvider