本文整理了Java中com.datastax.driver.core.Cluster.unregister()方法的一些代码示例，展示了Cluster.unregister()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Cluster.unregister()方法的具体详情如下：
包路径：com.datastax.driver.core.Cluster
类名称：Cluster
方法名：unregister

Cluster.unregister介绍

[英]Unregisters the provided listener from being notified on hosts events.

This method is a no-op if listener hasn't previously been registered against this Cluster.
[中]取消注册提供的侦听器，使其不会收到主机事件的通知。
如果侦听器以前未针对此群集注册，则此方法为无操作。

代码示例

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Override
public Cluster unregister(Host.StateListener listener) {
 return delegate().unregister(listener);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Override
public Cluster unregister(LatencyTracker tracker) {
 return delegate().unregister(tracker);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Override
public Cluster unregister(SchemaChangeListener listener) {
 return delegate().unregister(listener);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@AfterMethod(
  groups = {"short", "unit"},
  alwaysRun = true)
public void unregisterQueryLogger() {
 if (cluster() != null && queryLogger != null) {
  cluster().unregister(queryLogger);
 }
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

public HostAssert goesDownWithin(long duration, TimeUnit unit) {
 final CountDownLatch downSignal = new CountDownLatch(1);
 StateListener upListener =
   new StateListenerBase() {
    @Override
    public void onDown(Host host) {
     downSignal.countDown();
    }
   };
 cluster.register(upListener);
 try {
  // If the host is already down or if we receive the DOWN signal within given time
  if (actual.state == State.DOWN || downSignal.await(duration, unit)) return this;
 } catch (InterruptedException e) {
  fail("Got interrupted while waiting for host to go down");
 } finally {
  cluster.unregister(upListener);
 }
 fail(actual + " did not go down within " + duration + " " + unit);
 return this;
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

public static Host findOrWaitForHost(
  final Cluster cluster, final String address, long duration, TimeUnit unit) {
 Host host = findHost(cluster, address);
 if (host == null) {
  final CountDownLatch addSignal = new CountDownLatch(1);
  Host.StateListener addListener =
    new StateListenerBase() {
     @Override
     public void onAdd(Host host) {
      if (host.getAddress().getHostAddress().equals(address)) {
       // for a new node, because of this we also listen for add events.
       addSignal.countDown();
      }
     }
    };
  cluster.register(addListener);
  try {
   // Wait until an add event occurs or we timeout.
   if (addSignal.await(duration, unit)) {
    host = findHost(cluster, address);
   }
  } catch (InterruptedException e) {
   return null;
  } finally {
   cluster.unregister(addListener);
  }
 }
 return host;
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

public HostAssert comesUpWithin(long duration, TimeUnit unit) {
 final CountDownLatch upSignal = new CountDownLatch(1);
 StateListener upListener =
   new StateListenerBase() {
    @Override
    public void onUp(Host host) {
     upSignal.countDown();
    }
    @Override
    public void onAdd(Host host) {
     // Special case, cassandra will sometimes not send an 'UP' topology change event
     // for a new node, because of this we also listen for add events.
     upSignal.countDown();
    }
   };
 cluster.register(upListener);
 try {
  // If the host is already up or if we receive the UP signal within given time
  if (actual.isUp() || upSignal.await(duration, unit)) {
   return this;
  }
 } catch (InterruptedException e) {
  fail("Got interrupted while waiting for host to come up");
 } finally {
  cluster.unregister(upListener);
 }
 fail(actual + " did not come up within " + duration + " " + unit);
 return this;
}

代码示例来源：origin: org.hawkular.metrics/hawkular-metrics-core-service

@Override public void shutdown() {
  session.getCluster().unregister(tableCreator);
  tableCreator = null;
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

@Override
public Cluster unregister(LatencyTracker tracker) {
  return delegate().unregister(tracker);
}

代码示例来源：origin: com.yugabyte/cassandra-driver-core

@Override
public Cluster unregister(Host.StateListener listener) {
  return delegate().unregister(listener);
}

代码示例来源：origin: com.yugabyte/cassandra-driver-core

@Override
public Cluster unregister(SchemaChangeListener listener) {
  return delegate().unregister(listener);
}

代码示例来源：origin: hawkular/hawkular-metrics

@Override public void shutdown() {
  session.getCluster().unregister(tableCreator);
  tableCreator = null;
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

@Override
public Cluster unregister(Host.StateListener listener) {
  return delegate().unregister(listener);
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

@Override
public Cluster unregister(SchemaChangeListener listener) {
  return delegate().unregister(listener);
}

代码示例来源：origin: com.englishtown.vertx/vertx-cassandra

@Override
public void close() {
  if (listener != null) {
    session.getCluster().unregister(listener);
    listener = null;
  }
  if (reporter != null) {
    reporter.stop();
    reporter = null;
  }
}

代码示例来源：origin: com.englishtown/vertx-mod-cassandra

@Override
public void close() {
  if (listener != null) {
    session.getCluster().unregister(listener);
    listener = null;
  }
  if (reporter != null) {
    reporter.stop();
    reporter = null;
  }
}

代码示例来源：origin: ef-labs/vertx-cassandra

@Override
public void close() {
  if (listener != null) {
    session.getCluster().unregister(listener);
    listener = null;
  }
  if (reporter != null) {
    reporter.stop();
    reporter = null;
  }
}

代码示例来源：origin: org.hawkular.metrics/hawkular-metrics-core-service

public void setTempTableCreator(TemporaryTableStatementCreator creator) {
    if(tableCreator != null) {
      session.getCluster().unregister(tableCreator);
    }
    tableCreator = creator;
    session.getCluster().register(tableCreator);
  }
}

代码示例来源：origin: hawkular/hawkular-metrics

public void setTempTableCreator(TemporaryTableStatementCreator creator) {
    if(tableCreator != null) {
      session.getCluster().unregister(tableCreator);
    }
    tableCreator = creator;
    session.getCluster().register(tableCreator);
  }
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

@AfterMethod(
  groups = {"short", "unit"},
  alwaysRun = true)
public void unregisterQueryLogger() {
 if (cluster() != null && queryLogger != null) {
  cluster().unregister(queryLogger);
 }
}