Class: Vertx::NetClient
- Inherits:
-
Object
- Object
- Vertx::NetClient
- Includes:
- Measured
- Defined in:
- /Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx/net_client.rb
Overview
A TCP client.
Multiple connections to different servers can be made using the same instance.
This client supports a configurable number of connection attempts and a configurable delay between attempts.
Constant Summary
- @@j_api_type =
Object.new
Class Method Summary (collapse)
- + (Boolean) accept?(obj)
- + (Object) j_api_type
- + (Object) j_class
- + (Object) unwrap(obj)
- + (Object) wrap(obj)
Instance Method Summary (collapse)
-
- (void) close
Close the client.
-
- (self) connect(param_1 = nil, param_2 = nil, param_3 = nil)
Open a connection to a server at the specific port and host.
-
- (true, false) metrics_enabled?
Whether the metrics are enabled for this measured object.
Class Method Details
+ (Boolean) accept?(obj)
27 28 29 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx/net_client.rb', line 27 def @@j_api_type.accept?(obj) obj.class == NetClient end |
+ (Object) j_api_type
36 37 38 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx/net_client.rb', line 36 def self.j_api_type @@j_api_type end |
+ (Object) j_class
39 40 41 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx/net_client.rb', line 39 def self.j_class Java::IoVertxCoreNet::NetClient.java_class end |
+ (Object) unwrap(obj)
33 34 35 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx/net_client.rb', line 33 def @@j_api_type.unwrap(obj) obj.j_del end |
+ (Object) wrap(obj)
30 31 32 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx/net_client.rb', line 30 def @@j_api_type.wrap(obj) NetClient.new(obj) end |
Instance Method Details
- (void) close
This method returns an undefined value.
Close the client.Any sockets which have not been closed manually will be closed here. The close is asynchronous and may not complete until some time after the method has returned.
92 93 94 95 96 97 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx/net_client.rb', line 92 def close if !block_given? return @j_del.java_method(:close, []).call() end raise ArgumentError, "Invalid arguments when calling close()" end |
- (self) connect(remoteAddress, connectHandler) { ... } - (self) connect(port, host, connectHandler) { ... } - (self) connect(remoteAddress, serverName, connectHandler) { ... } - (self) connect(port, host, serverName, connectHandler) { ... }
Open a connection to a server at the specific
port and host.
host can be a valid host name or IP address. The connect is done asynchronously and on success, a
Vertx::NetSocket instance is supplied via the connectHandler instance
71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx/net_client.rb', line 71 def connect(param_1=nil,param_2=nil,param_3=nil) if param_1.class.method_defined?(:j_del) && true && param_2 == nil && param_3 == nil @j_del.java_method(:connect, [Java::IoVertxCoreNet::SocketAddress.java_class,Java::IoVertxCore::Handler.java_class]).call(param_1.j_del,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::Vertx::NetSocket) : nil) } unless !block_given?)) return self elsif param_1.class == Fixnum && param_2.class == String && true && param_3 == nil @j_del.java_method(:connect, [Java::int.java_class,Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(param_1,param_2,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::Vertx::NetSocket) : nil) } unless !block_given?)) return self elsif param_1.class.method_defined?(:j_del) && param_2.class == String && true && param_3 == nil @j_del.java_method(:connect, [Java::IoVertxCoreNet::SocketAddress.java_class,Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(param_1.j_del,param_2,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::Vertx::NetSocket) : nil) } unless !block_given?)) return self elsif param_1.class == Fixnum && param_2.class == String && param_3.class == String && true @j_del.java_method(:connect, [Java::int.java_class,Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(param_1,param_2,param_3,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::Vertx::NetSocket) : nil) } unless !block_given?)) return self end raise ArgumentError, "Invalid arguments when calling connect(#{param_1},#{param_2},#{param_3})" end |
- (true, false) metrics_enabled?
Whether the metrics are enabled for this measured object
44 45 46 47 48 49 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx/net_client.rb', line 44 def metrics_enabled? if !block_given? return @j_del.java_method(:isMetricsEnabled, []).call() end raise ArgumentError, "Invalid arguments when calling metrics_enabled?()" end |