Examples of com.couchbase.client.vbucket.ConfigurationProviderHTTP.subscribe()

Class com.couchbase.client.vbucket.ConfigurationProviderHTTP

Examples of com.couchbase.client.vbucket.ConfigurationProviderHTTP.subscribe()

com.couchbase.client.vbucket.ConfigurationProviderHTTP.subscribe()
Subscribes for configuration updates. @param bucketName bucket name to receive configuration for @param rec reconfigurable that will receive updates

          ConfigurationProvider oldConfigProvider = getConfigurationProvider();
          Reconfigurable oldRec = oldConfigProvider.getReconfigurable();


          ConfigurationProvider newConfigProvider =
            new ConfigurationProviderHTTP(storedBaseList, bucket, pass);
          newConfigProvider.subscribe(bucket, oldRec);


          setConfigurationProvider(newConfigProvider);
          oldConfigProvider.shutdown();


          if (!doingResubscribe.compareAndSet(true, false)) {

View Full Code Here

          ConfigurationProvider oldConfigProvider = getConfigurationProvider();
          Reconfigurable oldRec = oldConfigProvider.getReconfigurable();


          ConfigurationProvider newConfigProvider =
            new ConfigurationProviderHTTP(storedBaseList, bucket, pass);
          newConfigProvider.subscribe(bucket, oldRec);


          setConfigurationProvider(newConfigProvider);
          oldConfigProvider.shutdown();


          if (!doingResubscribe.compareAndSet(true, false)) {

View Full Code Here


          ConfigurationProvider newConfigProvider =
            new ConfigurationProviderHTTP(storedBaseList, bucket, pass);
          setConfigurationProvider(newConfigProvider);


          newConfigProvider.subscribe(bucket,
            oldConfigProvider.getReconfigurable());


          if (!doingResubscribe.compareAndSet(true, false)) {
            LOGGER.log(Level.WARNING,
              "Could not reset from doing a resubscribe.");

View Full Code Here

            Thread.sleep(waitTime);


            ConfigurationProviderHTTP oldProvider = httpProvider.get();
            ConfigurationProviderHTTP newProvider =
              new ConfigurationProviderHTTP(seedNodes, bucket, password);
            newProvider.subscribe(bucket, provider);
            httpProvider.set(newProvider);
            oldProvider.shutdown();
            return;
          } catch(Exception ex) {
            continue;

View Full Code Here

          ConfigurationProvider oldConfigProvider = getConfigurationProvider();
          Reconfigurable oldRec = oldConfigProvider.getReconfigurable();


          ConfigurationProvider newConfigProvider =
            new ConfigurationProviderHTTP(storedBaseList, bucket, pass);
          newConfigProvider.subscribe(bucket, oldRec);


          setConfigurationProvider(newConfigProvider);
          oldConfigProvider.shutdown();


          if (!doingResubscribe.compareAndSet(true, false)) {

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.