Class: VertxCassandra::CassandraClient
- Inherits:
-
Object
- Object
- VertxCassandra::CassandraClient
- Defined in:
- /Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb
Overview
Eclipse Vert.x Cassandra client.
Constant Summary
- @@j_api_type =
Object.new
Class Method Summary (collapse)
- + (Boolean) accept?(obj)
-
+ (::VertxCassandra::CassandraClient) create_non_shared(*args)
Create a Cassandra client which maintains its own driver session.
-
+ (::VertxCassandra::CassandraClient) create_shared(*args)
Create a Cassandra client that shares its driver session with any other client having the same name.
-
+ (Object) DEFAULT_SHARED_CLIENT_NAME
The default shared client name.
- + (Object) j_api_type
- + (Object) j_class
- + (Object) unwrap(obj)
- + (Object) wrap(obj)
Instance Method Summary (collapse)
-
- (self) close(closeHandler) { ... }
Closes this client.
-
- (true, false) isConnected
Whether this Cassandra client instance is connected.
-
- (self) execute(query, resultHandler) { ... }
Execute the query and provide a handler for consuming results.
-
- (self) queryStream(sql, rowStreamHandler) { ... }
Executes the given SQL SELECT statement which returns the results of the query as a read stream.
Class Method Details
+ (Boolean) accept?(obj)
22 23 24 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 22 def @@j_api_type.accept?(obj) obj.class == CassandraClient end |
+ (::VertxCassandra::CassandraClient) createNonShared(vertx) + (::VertxCassandra::CassandraClient) createNonShared(vertx, options)
Create a Cassandra client which maintains its own driver session.
It is not recommended to create several non shared clients in an application.
88 89 90 91 92 93 94 95 96 97 98 99 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 88 def self.create_non_shared(*args) if args[0].class.method_defined?(:j_del) && !block_given? && args[1] == nil return ::Vertx::Util::Utils.safe_create(Java::IoVertxCassandra::CassandraClient.java_method(:createNonShared, [Java::IoVertxCore::Vertx.java_class]).call(args[0].j_del),::VertxCassandra::CassandraClient) elsif args[0].class.method_defined?(:j_del) && args[1].class == Hash && !block_given? return ::Vertx::Util::Utils.safe_create(Java::IoVertxCassandra::CassandraClient.java_method(:createNonShared, [Java::IoVertxCore::Vertx.java_class,Java::IoVertxCassandra::CassandraClientOptions.java_class]).call(args[0].j_del,Java::IoVertxCassandra::CassandraClientOptions.new(::Vertx::Util::Utils.to_json_object(args[1]))),::VertxCassandra::CassandraClient) end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling create_non_shared(#{args[0]},#{args[1]})" end end |
+ (::VertxCassandra::CassandraClient) createShared(vertx) + (::VertxCassandra::CassandraClient) createShared(vertx, clientName) + (::VertxCassandra::CassandraClient) createShared(vertx, options) + (::VertxCassandra::CassandraClient) createShared(vertx, clientName, options)
Create a Cassandra client that shares its driver session with any other client having the same name.
63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 63 def self.create_shared(*args) if args[0].class.method_defined?(:j_del) && !block_given? && args[1] == nil && args[2] == nil return ::Vertx::Util::Utils.safe_create(Java::IoVertxCassandra::CassandraClient.java_method(:createShared, [Java::IoVertxCore::Vertx.java_class]).call(args[0].j_del),::VertxCassandra::CassandraClient) elsif args[0].class.method_defined?(:j_del) && args[1].class == String && !block_given? && args[2] == nil return ::Vertx::Util::Utils.safe_create(Java::IoVertxCassandra::CassandraClient.java_method(:createShared, [Java::IoVertxCore::Vertx.java_class,Java::java.lang.String.java_class]).call(args[0].j_del,args[1]),::VertxCassandra::CassandraClient) elsif args[0].class.method_defined?(:j_del) && args[1].class == Hash && !block_given? && args[2] == nil return ::Vertx::Util::Utils.safe_create(Java::IoVertxCassandra::CassandraClient.java_method(:createShared, [Java::IoVertxCore::Vertx.java_class,Java::IoVertxCassandra::CassandraClientOptions.java_class]).call(args[0].j_del,Java::IoVertxCassandra::CassandraClientOptions.new(::Vertx::Util::Utils.to_json_object(args[1]))),::VertxCassandra::CassandraClient) elsif args[0].class.method_defined?(:j_del) && args[1].class == String && args[2].class == Hash && !block_given? return ::Vertx::Util::Utils.safe_create(Java::IoVertxCassandra::CassandraClient.java_method(:createShared, [Java::IoVertxCore::Vertx.java_class,Java::java.lang.String.java_class,Java::IoVertxCassandra::CassandraClientOptions.java_class]).call(args[0].j_del,args[1],Java::IoVertxCassandra::CassandraClientOptions.new(::Vertx::Util::Utils.to_json_object(args[2]))),::VertxCassandra::CassandraClient) end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling create_shared(#{args[0]},#{args[1]},#{args[2]})" end end |
+ (Object) DEFAULT_SHARED_CLIENT_NAME
The default shared client name.
166 167 168 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 166 def self.DEFAULT_SHARED_CLIENT_NAME Java::IoVertxCassandra::CassandraClient.DEFAULT_SHARED_CLIENT_NAME end |
+ (Object) j_api_type
31 32 33 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 31 def self.j_api_type @@j_api_type end |
+ (Object) j_class
34 35 36 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 34 def self.j_class Java::IoVertxCassandra::CassandraClient.java_class end |
+ (Object) unwrap(obj)
28 29 30 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 28 def @@j_api_type.unwrap(obj) obj.j_del end |
+ (Object) wrap(obj)
25 26 27 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 25 def @@j_api_type.wrap(obj) CassandraClient.new(obj) end |
Instance Method Details
- (self) close(closeHandler) { ... }
Closes this client.
104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 104 def close if true if (block_given?) @j_del.java_method(:close, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise) return self else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:close, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling close()" end end |
- (true, false) isConnected
Returns whether this Cassandra client instance is connected
39 40 41 42 43 44 45 46 47 48 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 39 def connected? if !block_given? return @j_del.java_method(:isConnected, []).call() end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling connected?()" end end |
- (self) execute(query, resultHandler) { ... }
Execute the query and provide a handler for consuming results.
148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 148 def execute(*args) if args[0].class == String && true if (block_given?) @j_del.java_method(:execute, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxCassandra::ResultSet) : nil) } : promise) return self else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:execute, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxCassandra::ResultSet) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxCassandra::ResultSet.j_api_type) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling execute(#{args[0]})" end end |
- (self) queryStream(sql, rowStreamHandler) { ... }
Executes the given SQL
SELECT
statement which returns the results of the query as a read stream.
126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/cassandra_client.rb', line 126 def query_stream(*args) if args[0].class == String && true if (block_given?) @j_del.java_method(:queryStream, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxCassandra::CassandraRowStream) : nil) } : promise) return self else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:queryStream, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxCassandra::CassandraRowStream) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxCassandra::CassandraRowStream.j_api_type) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling query_stream(#{args[0]})" end end |