Class: VertxTcpEventbusBridge::TcpEventBusBridge

Inherits:
Object
  • Object
show all
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)

Instance Method Summary (collapse)

Class Method Details

+ (Boolean) accept?(obj)

Returns:

  • (Boolean)


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) { ... }

Overloads:

Returns:



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.

Overloads:

  • - (void) close(handler) { ... }

    Yields:

    • the result handler


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

Overloads:

  • - (self) listen(handler) { ... }

    Yields:

    • the result handler
  • - (self) listen(port)

    Parameters:

    • port (Fixnum)
      tcp port
  • - (self) listen(port, address)

    Parameters:

    • port (Fixnum)
      tcp port
    • address (String)
      tcp address to the bind
  • - (self) listen(port, handler) { ... }

    Parameters:

    • port (Fixnum)
      tcp port

    Yields:

    • the result handler
  • - (self) listen(port, address, handler) { ... }

    Parameters:

    • port (Fixnum)
      tcp port
    • address (String)
      tcp address to the bind

    Yields:

    • the result handler

Returns:

  • (self)


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