Class: VertxAmqpClient::AmqpReceiver
- Inherits:
-
Object
- Object
- VertxAmqpClient::AmqpReceiver
show all
- Includes:
- Vertx::ReadStream
- Defined in:
- /Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb
Overview
Interface used to consume AMQP message as a stream of message.
Back pressure is implemented using AMQP credits.
Constant Summary
- @@j_api_type =
Object.new
Class Method Summary
(collapse)
Instance Method Summary
(collapse)
Class Method Details
+ (Boolean) accept?(obj)
26
27
28
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 26
def @@j_api_type.accept?(obj)
obj.class == AmqpReceiver
end
|
+ (Object) j_api_type
35
36
37
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 35
def self.j_api_type
@@j_api_type
end
|
+ (Object) j_class
38
39
40
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 38
def self.j_class
Java::IoVertxAmqp::AmqpReceiver.java_class
end
|
+ (Object) unwrap(obj)
32
33
34
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 32
def @@j_api_type.unwrap(obj)
obj.j_del
end
|
+ (Object) wrap(obj)
29
30
31
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 29
def @@j_api_type.wrap(obj)
AmqpReceiver.new(obj)
end
|
Instance Method Details
- (String) address
71
72
73
74
75
76
77
78
79
80
81
82
83
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 71
def address
if !block_given?
if @cached_address != nil
return @cached_address
end
return @cached_address = @j_del.java_method(:address, []).call()
end
if defined?(super)
super
else
raise ArgumentError, "Invalid arguments when calling address()"
end
end
|
- (void) close(handler) { ... }
This method returns an undefined value.
Closes the receiver.
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 170
def close
if 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
|
Gets the connection having created the receiver. Cannot be null
141
142
143
144
145
146
147
148
149
150
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 141
def connection
if !block_given?
return ::Vertx::Util::Utils.safe_create(@j_del.java_method(:connection, []).call(),::VertxAmqpClient::AmqpConnection)
end
if defined?(super)
super
else
raise ArgumentError, "Invalid arguments when calling connection()"
end
end
|
- (self) endHandler(endHandler) { ... }
113
114
115
116
117
118
119
120
121
122
123
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 113
def end_handler
if true
@j_del.java_method(:endHandler, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |event| yield(nil) unless !block_given? }))
return self
end
if defined?(super)
super
else
raise ArgumentError, "Invalid arguments when calling end_handler()"
end
end
|
- (self) exceptionHandler(handler) { ... }
189
190
191
192
193
194
195
196
197
198
199
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 189
def exception_handler
if true
@j_del.java_method(:exceptionHandler, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |event| yield(::Vertx::Util::Utils.from_throwable(event)) unless !block_given? }))
return self
end
if defined?(super)
super
else
raise ArgumentError, "Invalid arguments when calling exception_handler()"
end
end
|
- (self) fetch(amount)
127
128
129
130
131
132
133
134
135
136
137
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 127
def fetch(*args)
if args[0].class == Fixnum && !block_given?
@j_del.java_method(:fetch, [Java::long.java_class]).call(args[0])
return self
end
if defined?(super)
super
else
raise ArgumentError, "Invalid arguments when calling fetch(#{args[0]})"
end
end
|
- (self) handler(handler) { ... }
57
58
59
60
61
62
63
64
65
66
67
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 57
def handler
if true
@j_del.java_method(:handler, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |event| yield(::Vertx::Util::Utils.safe_create(event,::VertxAmqpClient::AmqpMessage)) unless !block_given? }))
return self
end
if defined?(super)
super
else
raise ArgumentError, "Invalid arguments when calling handler()"
end
end
|
- (self) pause
202
203
204
205
206
207
208
209
210
211
212
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 202
def pause
if !block_given?
@j_del.java_method(:pause, []).call()
return self
end
if defined?(super)
super
else
raise ArgumentError, "Invalid arguments when calling pause()"
end
end
|
Pause this stream and return a to transfer the elements of this stream to a destination .
The stream will be resumed when the pipe will be wired to a
WriteStream
.
156
157
158
159
160
161
162
163
164
165
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 156
def pipe
if !block_given?
return ::Vertx::Util::Utils.safe_create(@j_del.java_method(:pipe, []).call(),::Vertx::Pipe,::VertxAmqpClient::AmqpMessage.j_api_type)
end
if defined?(super)
super
else
raise ArgumentError, "Invalid arguments when calling pipe()"
end
end
|
- (void) pipeTo(dst, handler) { ... }
This method returns an undefined value.
Pipe this
ReadStream
to the
WriteStream
.
Elements emitted by this stream will be written to the write stream until this stream ends or fails.
Once this stream has ended or failed, the write stream will be ended and the handler
will be
called with the result.
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 94
def pipe_to(*args)
if args[0].class.method_defined?(:j_del) && true
if (block_given?)
return @j_del.java_method(:pipeTo, [Java::IoVertxCoreStreams::WriteStream.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,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(:pipeTo, [Java::IoVertxCoreStreams::WriteStream.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].j_del,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 pipe_to(#{args[0]})"
end
end
|
- (self) resume
43
44
45
46
47
48
49
50
51
52
53
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 43
def resume
if !block_given?
@j_del.java_method(:resume, []).call()
return self
end
if defined?(super)
super
else
raise ArgumentError, "Invalid arguments when calling resume()"
end
end
|