com.datastax.driver.core.Cluster.checkNotClosed()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(10.2k)|赞(0)|评价(0)|浏览(179)

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

Cluster.checkNotClosed介绍

暂无

代码示例

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

  1. /**
  2. * The cluster metrics.
  3. *
  4. * @return the cluster metrics, or {@code null} if this cluster has not yet been {@link #init()
  5. * initialized}, or if metrics collection has been disabled (that is if {@link
  6. * Configuration#getMetricsOptions} returns {@code null}).
  7. */
  8. public Metrics getMetrics() {
  9. checkNotClosed(manager);
  10. return manager.metrics;
  11. }

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

  1. /**
  2. * Creates a new session on this cluster but does not initialize it.
  3. *
  4. * <p>Because this method does not perform any initialization, it cannot fail. The initialization
  5. * of the session (the connection of the Session to the Cassandra nodes) will occur if either the
  6. * {@link Session#init} method is called explicitly, or whenever the returned session object is
  7. * used.
  8. *
  9. * <p>Once a session returned by this method gets initialized (see above), it will be set to no
  10. * keyspace. If you want to set such session to a keyspace, you will have to explicitly execute a
  11. * 'USE mykeyspace' query.
  12. *
  13. * <p>Note that if you do not particularly need to defer initialization, it is simpler to use one
  14. * of the {@code connect()} method of this class.
  15. *
  16. * @return a new, non-initialized session on this cluster.
  17. */
  18. public Session newSession() {
  19. checkNotClosed(manager);
  20. return manager.newSession();
  21. }

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

  1. /**
  2. * Unregisters the provided latency tracking from being updated with host read latencies.
  3. *
  4. * <p>This method is a no-op if {@code tracker} hasn't previously been registered against this
  5. * Cluster.
  6. *
  7. * @param tracker the {@link LatencyTracker} to unregister.
  8. * @return this {@code Cluster} object;
  9. */
  10. public Cluster unregister(LatencyTracker tracker) {
  11. checkNotClosed(manager);
  12. boolean removed = manager.latencyTrackers.remove(tracker);
  13. if (removed) tracker.onUnregister(this);
  14. return this;
  15. }

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

  1. /**
  2. * Unregisters the provided schema change listener from being updated with schema change events.
  3. *
  4. * <p>This method is a no-op if {@code listener} hasn't previously been registered against this
  5. * Cluster.
  6. *
  7. * @param listener the {@link SchemaChangeListener} to unregister.
  8. * @return this {@code Cluster} object;
  9. */
  10. public Cluster unregister(SchemaChangeListener listener) {
  11. checkNotClosed(manager);
  12. boolean removed = manager.schemaChangeListeners.remove(listener);
  13. if (removed) listener.onUnregister(this);
  14. return this;
  15. }

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

  1. /**
  2. * Unregisters the provided listener from being notified on hosts events.
  3. *
  4. * <p>This method is a no-op if {@code listener} hasn't previously been registered against this
  5. * Cluster.
  6. *
  7. * @param listener the {@link Host.StateListener} to unregister.
  8. * @return this {@code Cluster} object;
  9. */
  10. public Cluster unregister(Host.StateListener listener) {
  11. checkNotClosed(manager);
  12. boolean removed = manager.listeners.remove(listener);
  13. if (removed) listener.onUnregister(this);
  14. return this;
  15. }

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

  1. /**
  2. * Registers the provided listener to be updated with schema change events.
  3. *
  4. * <p>Registering the same listener multiple times is a no-op.
  5. *
  6. * @param listener the new {@link SchemaChangeListener} to register.
  7. * @return this {@code Cluster} object;
  8. */
  9. public Cluster register(SchemaChangeListener listener) {
  10. checkNotClosed(manager);
  11. boolean added = manager.schemaChangeListeners.add(listener);
  12. if (added) listener.onRegister(this);
  13. return this;
  14. }

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

  1. /**
  2. * Registers the provided listener to be notified on hosts up/down/added/removed events.
  3. *
  4. * <p>Registering the same listener multiple times is a no-op.
  5. *
  6. * <p>This method should be used to register additional listeners on an already-initialized
  7. * cluster. To add listeners to a cluster object prior to its initialization, use {@link
  8. * Builder#withInitialListeners(Collection)}. Calling this method on a non-initialized cluster
  9. * will result in the listener being {@link
  10. * com.datastax.driver.core.Host.StateListener#onRegister(Cluster) notified} twice of cluster
  11. * registration: once inside this method, and once at cluster initialization.
  12. *
  13. * @param listener the new {@link Host.StateListener} to register.
  14. * @return this {@code Cluster} object;
  15. */
  16. public Cluster register(Host.StateListener listener) {
  17. checkNotClosed(manager);
  18. boolean added = manager.listeners.add(listener);
  19. if (added) listener.onRegister(this);
  20. return this;
  21. }

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

  1. /**
  2. * Registers the provided tracker to be updated with hosts read latencies.
  3. *
  4. * <p>Registering the same tracker multiple times is a no-op.
  5. *
  6. * <p>Beware that the registered tracker's {@link LatencyTracker#update(Host, Statement,
  7. * Exception, long) update} method will be called very frequently (at the end of every query to a
  8. * Cassandra host) and should thus not be costly.
  9. *
  10. * <p>The main use case for a {@link LatencyTracker} is to allow load balancing policies to
  11. * implement latency awareness. For example, {@link LatencyAwarePolicy} registers it's own
  12. * internal {@code LatencyTracker} (automatically, you don't have to call this method directly).
  13. *
  14. * @param tracker the new {@link LatencyTracker} to register.
  15. * @return this {@code Cluster} object;
  16. */
  17. public Cluster register(LatencyTracker tracker) {
  18. checkNotClosed(manager);
  19. boolean added = manager.latencyTrackers.add(tracker);
  20. if (added) tracker.onRegister(this);
  21. return this;
  22. }

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

  1. /**
  2. * The cluster metrics.
  3. *
  4. * @return the cluster metrics, or {@code null} if this cluster has not yet been {@link #init() initialized}, or if
  5. * metrics collection has been disabled (that is if {@link Configuration#getMetricsOptions} returns {@code null}).
  6. */
  7. public Metrics getMetrics() {
  8. checkNotClosed(manager);
  9. return manager.metrics;
  10. }

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

  1. /**
  2. * The cluster metrics.
  3. *
  4. * @return the cluster metrics, or {@code null} if this cluster has not yet been {@link #init() initialized}, or if
  5. * metrics collection has been disabled (that is if {@link Configuration#getMetricsOptions} returns {@code null}).
  6. */
  7. public Metrics getMetrics() {
  8. checkNotClosed(manager);
  9. return manager.metrics;
  10. }

代码示例来源:origin: io.prestosql.cassandra/cassandra-driver

  1. /**
  2. * The cluster metrics.
  3. *
  4. * @return the cluster metrics, or {@code null} if this cluster has not yet been {@link #init() initialized}, or if
  5. * metrics collection has been disabled (that is if {@link Configuration#getMetricsOptions} returns {@code null}).
  6. */
  7. public Metrics getMetrics() {
  8. checkNotClosed(manager);
  9. return manager.metrics;
  10. }

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

  1. checkNotClosed(manager);
  2. init();
  3. final Session session = manager.newSession();

代码示例来源:origin: io.prestosql.cassandra/cassandra-driver

  1. /**
  2. * Registers the provided listener to be updated with schema change events.
  3. * <p/>
  4. * Registering the same listener multiple times is a no-op.
  5. *
  6. * @param listener the new {@link SchemaChangeListener} to register.
  7. * @return this {@code Cluster} object;
  8. */
  9. public Cluster register(SchemaChangeListener listener) {
  10. checkNotClosed(manager);
  11. boolean added = manager.schemaChangeListeners.add(listener);
  12. if (added)
  13. listener.onRegister(this);
  14. return this;
  15. }

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

  1. /**
  2. * Registers the provided listener to be updated with schema change events.
  3. * <p/>
  4. * Registering the same listener multiple times is a no-op.
  5. *
  6. * @param listener the new {@link SchemaChangeListener} to register.
  7. * @return this {@code Cluster} object;
  8. */
  9. public Cluster register(SchemaChangeListener listener) {
  10. checkNotClosed(manager);
  11. boolean added = manager.schemaChangeListeners.add(listener);
  12. if (added)
  13. listener.onRegister(this);
  14. return this;
  15. }

代码示例来源:origin: io.prestosql.cassandra/cassandra-driver

  1. /**
  2. * Unregisters the provided latency tracking from being updated
  3. * with host read latencies.
  4. * <p/>
  5. * This method is a no-op if {@code tracker} hasn't previously been
  6. * registered against this Cluster.
  7. *
  8. * @param tracker the {@link LatencyTracker} to unregister.
  9. * @return this {@code Cluster} object;
  10. */
  11. public Cluster unregister(LatencyTracker tracker) {
  12. checkNotClosed(manager);
  13. boolean removed = manager.latencyTrackers.remove(tracker);
  14. if (removed)
  15. tracker.onUnregister(this);
  16. return this;
  17. }

代码示例来源:origin: io.prestosql.cassandra/cassandra-driver

  1. /**
  2. * Unregisters the provided listener from being notified on hosts events.
  3. * <p/>
  4. * This method is a no-op if {@code listener} hasn't previously been
  5. * registered against this Cluster.
  6. *
  7. * @param listener the {@link Host.StateListener} to unregister.
  8. * @return this {@code Cluster} object;
  9. */
  10. public Cluster unregister(Host.StateListener listener) {
  11. checkNotClosed(manager);
  12. boolean removed = manager.listeners.remove(listener);
  13. if (removed)
  14. listener.onUnregister(this);
  15. return this;
  16. }

代码示例来源:origin: io.prestosql.cassandra/cassandra-driver

  1. /**
  2. * Unregisters the provided schema change listener from being updated
  3. * with schema change events.
  4. * <p/>
  5. * This method is a no-op if {@code listener} hasn't previously been
  6. * registered against this Cluster.
  7. *
  8. * @param listener the {@link SchemaChangeListener} to unregister.
  9. * @return this {@code Cluster} object;
  10. */
  11. public Cluster unregister(SchemaChangeListener listener) {
  12. checkNotClosed(manager);
  13. boolean removed = manager.schemaChangeListeners.remove(listener);
  14. if (removed)
  15. listener.onUnregister(this);
  16. return this;
  17. }

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

  1. /**
  2. * Unregisters the provided listener from being notified on hosts events.
  3. * <p/>
  4. * This method is a no-op if {@code listener} hasn't previously been
  5. * registered against this Cluster.
  6. *
  7. * @param listener the {@link Host.StateListener} to unregister.
  8. * @return this {@code Cluster} object;
  9. */
  10. public Cluster unregister(Host.StateListener listener) {
  11. checkNotClosed(manager);
  12. boolean removed = manager.listeners.remove(listener);
  13. if (removed)
  14. listener.onUnregister(this);
  15. return this;
  16. }

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

  1. /**
  2. * Registers the provided listener to be updated with schema change events.
  3. * <p/>
  4. * Registering the same listener multiple times is a no-op.
  5. *
  6. * @param listener the new {@link SchemaChangeListener} to register.
  7. * @return this {@code Cluster} object;
  8. */
  9. public Cluster register(SchemaChangeListener listener) {
  10. checkNotClosed(manager);
  11. boolean added = manager.schemaChangeListeners.add(listener);
  12. if (added)
  13. listener.onRegister(this);
  14. return this;
  15. }

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

  1. /**
  2. * Unregisters the provided schema change listener from being updated
  3. * with schema change events.
  4. * <p/>
  5. * This method is a no-op if {@code listener} hasn't previously been
  6. * registered against this Cluster.
  7. *
  8. * @param listener the {@link SchemaChangeListener} to unregister.
  9. * @return this {@code Cluster} object;
  10. */
  11. public Cluster unregister(SchemaChangeListener listener) {
  12. checkNotClosed(manager);
  13. boolean removed = manager.schemaChangeListeners.remove(listener);
  14. if (removed)
  15. listener.onUnregister(this);
  16. return this;
  17. }

相关文章