Class: VertxStomp::Destination
- Inherits:
-
Object
- Object
- VertxStomp::Destination
- Defined in:
- /Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb
Class Method Summary (collapse)
- + (Object) bridge(vertx = nil, options = nil)
- + (Object) queue(vertx = nil, destination = nil)
- + (Object) topic(vertx = nil, destination = nil)
Instance Method Summary (collapse)
- - (Boolean) ack?(connection = nil, frame = nil)
- - (Object) destination
- - (Object) dispatch(connection = nil, frame = nil)
- - (Object) get_subscriptions(connection = nil)
-
- (Destination) initialize(j_del)
constructor
A new instance of Destination.
- - (Object) j_del
- - (Boolean) matches?(address = nil)
- - (Boolean) nack?(connection = nil, frame = nil)
- - (Object) number_of_subscriptions
- - (Object) subscribe(connection = nil, frame = nil)
- - (Boolean) unsubscribe?(connection = nil, frame = nil)
- - (Object) unsubscribe_connection(connection = nil)
Constructor Details
- (Destination) initialize(j_del)
Returns a new instance of Destination
14 15 16 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 14 def initialize(j_del) @j_del = j_del end |
Class Method Details
+ (Object) bridge(vertx = nil, options = nil)
43 44 45 46 47 48 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 43 def self.bridge(vertx=nil,=nil) if vertx.class.method_defined?(:j_del) && .class == Hash && !block_given? return ::Vertx::Util::Utils.safe_create(Java::IoVertxExtStomp::Destination.java_method(:bridge, [Java::IoVertxCore::Vertx.java_class,Java::IoVertxExtStomp::BridgeOptions.java_class]).call(vertx.j_del,Java::IoVertxExtStomp::BridgeOptions.new(::Vertx::Util::Utils.to_json_object())),::VertxStomp::Destination) end raise ArgumentError, "Invalid arguments when calling bridge(vertx,options)" end |
+ (Object) queue(vertx = nil, destination = nil)
34 35 36 37 38 39 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 34 def self.queue(vertx=nil,destination=nil) if vertx.class.method_defined?(:j_del) && destination.class == String && !block_given? return ::Vertx::Util::Utils.safe_create(Java::IoVertxExtStomp::Destination.java_method(:queue, [Java::IoVertxCore::Vertx.java_class,Java::java.lang.String.java_class]).call(vertx.j_del,destination),::VertxStomp::Destination) end raise ArgumentError, "Invalid arguments when calling queue(vertx,destination)" end |
+ (Object) topic(vertx = nil, destination = nil)
25 26 27 28 29 30 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 25 def self.topic(vertx=nil,destination=nil) if vertx.class.method_defined?(:j_del) && destination.class == String && !block_given? return ::Vertx::Util::Utils.safe_create(Java::IoVertxExtStomp::Destination.java_method(:topic, [Java::IoVertxCore::Vertx.java_class,Java::java.lang.String.java_class]).call(vertx.j_del,destination),::VertxStomp::Destination) end raise ArgumentError, "Invalid arguments when calling topic(vertx,destination)" end |
Instance Method Details
- (Boolean) ack?(connection = nil, frame = nil)
102 103 104 105 106 107 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 102 def ack?(connection=nil,frame=nil) if connection.class.method_defined?(:j_del) && frame.class == Hash && !block_given? return @j_del.java_method(:ack, [Java::IoVertxExtStomp::StompServerConnection.java_class,Java::IoVertxExtStomp::Frame.java_class]).call(connection.j_del,Java::IoVertxExtStomp::Frame.new(::Vertx::Util::Utils.to_json_object(frame))) end raise ArgumentError, "Invalid arguments when calling ack?(connection,frame)" end |
- (Object) destination
50 51 52 53 54 55 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 50 def destination if !block_given? return @j_del.java_method(:destination, []).call() end raise ArgumentError, "Invalid arguments when calling destination()" end |
- (Object) dispatch(connection = nil, frame = nil)
60 61 62 63 64 65 66 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 60 def dispatch(connection=nil,frame=nil) if connection.class.method_defined?(:j_del) && frame.class == Hash && !block_given? @j_del.java_method(:dispatch, [Java::IoVertxExtStomp::StompServerConnection.java_class,Java::IoVertxExtStomp::Frame.java_class]).call(connection.j_del,Java::IoVertxExtStomp::Frame.new(::Vertx::Util::Utils.to_json_object(frame))) return self end raise ArgumentError, "Invalid arguments when calling dispatch(connection,frame)" end |
- (Object) get_subscriptions(connection = nil)
121 122 123 124 125 126 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 121 def get_subscriptions(connection=nil) if connection.class.method_defined?(:j_del) && !block_given? return @j_del.java_method(:getSubscriptions, [Java::IoVertxExtStomp::StompServerConnection.java_class]).call(connection.j_del).to_a.map { |elt| elt } end raise ArgumentError, "Invalid arguments when calling get_subscriptions(connection)" end |
- (Object) j_del
19 20 21 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 19 def j_del @j_del end |
- (Boolean) matches?(address = nil)
138 139 140 141 142 143 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 138 def matches?(address=nil) if address.class == String && !block_given? return @j_del.java_method(:matches, [Java::java.lang.String.java_class]).call(address) end raise ArgumentError, "Invalid arguments when calling matches?(address)" end |
- (Boolean) nack?(connection = nil, frame = nil)
112 113 114 115 116 117 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 112 def nack?(connection=nil,frame=nil) if connection.class.method_defined?(:j_del) && frame.class == Hash && !block_given? return @j_del.java_method(:nack, [Java::IoVertxExtStomp::StompServerConnection.java_class,Java::IoVertxExtStomp::Frame.java_class]).call(connection.j_del,Java::IoVertxExtStomp::Frame.new(::Vertx::Util::Utils.to_json_object(frame))) end raise ArgumentError, "Invalid arguments when calling nack?(connection,frame)" end |
- (Object) number_of_subscriptions
129 130 131 132 133 134 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 129 def number_of_subscriptions if !block_given? return @j_del.java_method(:numberOfSubscriptions, []).call() end raise ArgumentError, "Invalid arguments when calling number_of_subscriptions()" end |
- (Object) subscribe(connection = nil, frame = nil)
71 72 73 74 75 76 77 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 71 def subscribe(connection=nil,frame=nil) if connection.class.method_defined?(:j_del) && frame.class == Hash && !block_given? @j_del.java_method(:subscribe, [Java::IoVertxExtStomp::StompServerConnection.java_class,Java::IoVertxExtStomp::Frame.java_class]).call(connection.j_del,Java::IoVertxExtStomp::Frame.new(::Vertx::Util::Utils.to_json_object(frame))) return self end raise ArgumentError, "Invalid arguments when calling subscribe(connection,frame)" end |
- (Boolean) unsubscribe?(connection = nil, frame = nil)
82 83 84 85 86 87 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 82 def unsubscribe?(connection=nil,frame=nil) if connection.class.method_defined?(:j_del) && frame.class == Hash && !block_given? return @j_del.java_method(:unsubscribe, [Java::IoVertxExtStomp::StompServerConnection.java_class,Java::IoVertxExtStomp::Frame.java_class]).call(connection.j_del,Java::IoVertxExtStomp::Frame.new(::Vertx::Util::Utils.to_json_object(frame))) end raise ArgumentError, "Invalid arguments when calling unsubscribe?(connection,frame)" end |
- (Object) unsubscribe_connection(connection = nil)
91 92 93 94 95 96 97 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-stomp/destination.rb', line 91 def unsubscribe_connection(connection=nil) if connection.class.method_defined?(:j_del) && !block_given? @j_del.java_method(:unsubscribeConnection, [Java::IoVertxExtStomp::StompServerConnection.java_class]).call(connection.j_del) return self end raise ArgumentError, "Invalid arguments when calling unsubscribe_connection(connection)" end |