Class: VertxTcpEventbusBridge::TcpEventBusBridge
- Inherits:
-
Object
- Object
- VertxTcpEventbusBridge::TcpEventBusBridge
- Defined in:
- /Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-tcp-eventbus-bridge/tcp_event_bus_bridge.rb
Overview
TCP EventBus bridge for Vert.x
Constant Summary
- @@j_api_type =
Object.new
Class Method Summary (collapse)
- + (Boolean) accept?(obj)
- + (::VertxTcpEventbusBridge::TcpEventBusBridge) create(*args)
- + (Object) j_api_type
- + (Object) j_class
- + (Object) unwrap(obj)
- + (Object) wrap(obj)
Instance Method Summary (collapse)
-
- (void) close
Close the current socket.
-
- (self) listen(*args)
Listen on specific port and bind to specific address.
Class Method Details
+ (Boolean) accept?(obj)
20 21 22 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-tcp-eventbus-bridge/tcp_event_bus_bridge.rb', line 20 def @@j_api_type.accept?(obj) obj.class == TcpEventBusBridge end |
+ (::VertxTcpEventbusBridge::TcpEventBusBridge) create(vertx) + (::VertxTcpEventbusBridge::TcpEventBusBridge) create(vertx, options) + (::VertxTcpEventbusBridge::TcpEventBusBridge) create(vertx, options, netServerOptions) + (::VertxTcpEventbusBridge::TcpEventBusBridge) create(vertx, options, netServerOptions, eventHandler) { ... }
50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-tcp-eventbus-bridge/tcp_event_bus_bridge.rb', line 50 def self.create(*args) if args[0].class.method_defined?(:j_del) && !block_given? && args[1] == nil && args[2] == nil return ::Vertx::Util::Utils.safe_create(Java::IoVertxExtEventbusBridgeTcp::TcpEventBusBridge.java_method(:create, [Java::IoVertxCore::Vertx.java_class]).call(args[0].j_del),::VertxTcpEventbusBridge::TcpEventBusBridge) elsif args[0].class.method_defined?(:j_del) && args[1].class == Hash && !block_given? && args[2] == nil return ::Vertx::Util::Utils.safe_create(Java::IoVertxExtEventbusBridgeTcp::TcpEventBusBridge.java_method(:create, [Java::IoVertxCore::Vertx.java_class,Java::IoVertxExtBridge::BridgeOptions.java_class]).call(args[0].j_del,Java::IoVertxExtBridge::BridgeOptions.new(::Vertx::Util::Utils.to_json_object(args[1]))),::VertxTcpEventbusBridge::TcpEventBusBridge) elsif args[0].class.method_defined?(:j_del) && args[1].class == Hash && args[2].class == Hash && !block_given? return ::Vertx::Util::Utils.safe_create(Java::IoVertxExtEventbusBridgeTcp::TcpEventBusBridge.java_method(:create, [Java::IoVertxCore::Vertx.java_class,Java::IoVertxExtBridge::BridgeOptions.java_class,Java::IoVertxCoreNet::NetServerOptions.java_class]).call(args[0].j_del,Java::IoVertxExtBridge::BridgeOptions.new(::Vertx::Util::Utils.to_json_object(args[1])),Java::IoVertxCoreNet::NetServerOptions.new(::Vertx::Util::Utils.to_json_object(args[2]))),::VertxTcpEventbusBridge::TcpEventBusBridge) elsif args[0].class.method_defined?(:j_del) && args[1].class == Hash && args[2].class == Hash && true return ::Vertx::Util::Utils.safe_create(Java::IoVertxExtEventbusBridgeTcp::TcpEventBusBridge.java_method(:create, [Java::IoVertxCore::Vertx.java_class,Java::IoVertxExtBridge::BridgeOptions.java_class,Java::IoVertxCoreNet::NetServerOptions.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,Java::IoVertxExtBridge::BridgeOptions.new(::Vertx::Util::Utils.to_json_object(args[1])),Java::IoVertxCoreNet::NetServerOptions.new(::Vertx::Util::Utils.to_json_object(args[2])),(Proc.new { |event| yield(::Vertx::Util::Utils.safe_create(event,::VertxTcpEventbusBridge::BridgeEvent)) unless !block_given? })),::VertxTcpEventbusBridge::TcpEventBusBridge) end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling create(#{args[0]},#{args[1]},#{args[2]})" end end |
+ (Object) j_api_type
29 30 31 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-tcp-eventbus-bridge/tcp_event_bus_bridge.rb', line 29 def self.j_api_type @@j_api_type end |
+ (Object) j_class
32 33 34 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-tcp-eventbus-bridge/tcp_event_bus_bridge.rb', line 32 def self.j_class Java::IoVertxExtEventbusBridgeTcp::TcpEventBusBridge.java_class end |
+ (Object) unwrap(obj)
26 27 28 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-tcp-eventbus-bridge/tcp_event_bus_bridge.rb', line 26 def @@j_api_type.unwrap(obj) obj.j_del end |
+ (Object) wrap(obj)
23 24 25 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-tcp-eventbus-bridge/tcp_event_bus_bridge.rb', line 23 def @@j_api_type.wrap(obj) TcpEventBusBridge.new(obj) end |
Instance Method Details
- (void) close - (void) close(handler) { ... }
This method returns an undefined value.
Close the current socket.
71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-tcp-eventbus-bridge/tcp_event_bus_bridge.rb', line 71 def close if !block_given? return @j_del.java_method(:close, []).call() elsif true if (block_given?) return @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) 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 |
- (self) listen - (self) listen(handler) { ... } - (self) listen(port) - (self) listen(port, address) - (self) listen(port, handler) { ... } - (self) listen(port, address, handler) { ... }
Listen on specific port and bind to specific address
106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-tcp-eventbus-bridge/tcp_event_bus_bridge.rb', line 106 def listen(*args) if !block_given? && args[0] == nil && args[1] == nil @j_del.java_method(:listen, []).call() return self elsif true && args[0] == nil && args[1] == nil if (block_given?) @j_del.java_method(:listen, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxTcpEventbusBridge::TcpEventBusBridge) : nil) } : promise) return self else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:listen, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxTcpEventbusBridge::TcpEventBusBridge) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxTcpEventbusBridge::TcpEventBusBridge.j_api_type) end elsif args[0].class == Fixnum && !block_given? && args[1] == nil @j_del.java_method(:listen, [Java::int.java_class]).call(args[0]) return self elsif args[0].class == Fixnum && args[1].class == String && !block_given? @j_del.java_method(:listen, [Java::int.java_class,Java::java.lang.String.java_class]).call(args[0],args[1]) return self elsif args[0].class == Fixnum && true && args[1] == nil if (block_given?) @j_del.java_method(:listen, [Java::int.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,::VertxTcpEventbusBridge::TcpEventBusBridge) : nil) } : promise) return self else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:listen, [Java::int.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,::VertxTcpEventbusBridge::TcpEventBusBridge) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxTcpEventbusBridge::TcpEventBusBridge.j_api_type) end elsif args[0].class == Fixnum && args[1].class == String && true if (block_given?) @j_del.java_method(:listen, [Java::int.java_class,Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxTcpEventbusBridge::TcpEventBusBridge) : nil) } : promise) return self else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:listen, [Java::int.java_class,Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxTcpEventbusBridge::TcpEventBusBridge) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxTcpEventbusBridge::TcpEventBusBridge.j_api_type) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling listen(#{args[0]},#{args[1]})" end end |