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)
25
26
27
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 25
def @@j_api_type.accept?(obj)
obj.class == AmqpReceiver
end
|
+ (Object) j_api_type
34
35
36
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 34
def self.j_api_type
@@j_api_type
end
|
+ (Object) j_class
37
38
39
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 37
def self.j_class
Java::IoVertxAmqp::AmqpReceiver.java_class
end
|
+ (Object) unwrap(obj)
31
32
33
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 31
def @@j_api_type.unwrap(obj)
obj.j_del
end
|
+ (Object) wrap(obj)
28
29
30
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 28
def @@j_api_type.wrap(obj)
AmqpReceiver.new(obj)
end
|
Instance Method Details
- (String) address
119
120
121
122
123
124
125
126
127
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 119
def address
if !block_given?
if @cached_address != nil
return @cached_address
end
return @cached_address = @j_del.java_method(:address, []).call()
end
raise ArgumentError, "Invalid arguments when calling address()"
end
|
- (void) close { ... }
This method returns an undefined value.
Closes the receiver.
131
132
133
134
135
136
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 131
def close
if true
return @j_del.java_method(:close, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |ar| yield(ar.failed ? ar.cause : nil) } unless !block_given?))
end
raise ArgumentError, "Invalid arguments when calling close()"
end
|
Gets the connection having created the receiver. Cannot be null
139
140
141
142
143
144
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 139
def connection
if !block_given?
return ::Vertx::Util::Utils.safe_create(@j_del.java_method(:connection, []).call(),::VertxAmqpClient::AmqpConnection)
end
raise ArgumentError, "Invalid arguments when calling connection()"
end
|
- (self) end_handler { ... }
110
111
112
113
114
115
116
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 110
def end_handler
if true
@j_del.java_method(:endHandler, [Java::IoVertxCore::Handler.java_class]).call(Proc.new { yield unless !block_given? })
return self
end
raise ArgumentError, "Invalid arguments when calling end_handler()"
end
|
- (self) exception_handler { ... }
67
68
69
70
71
72
73
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 67
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
raise ArgumentError, "Invalid arguments when calling exception_handler()"
end
|
- (self) fetch(amount = nil)
101
102
103
104
105
106
107
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 101
def fetch(amount=nil)
if amount.class == Fixnum && !block_given?
@j_del.java_method(:fetch, [Java::long.java_class]).call(amount)
return self
end
raise ArgumentError, "Invalid arguments when calling fetch(#{amount})"
end
|
- (self) handler { ... }
76
77
78
79
80
81
82
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 76
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
raise ArgumentError, "Invalid arguments when calling handler()"
end
|
- (self) pause
84
85
86
87
88
89
90
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 84
def pause
if !block_given?
@j_del.java_method(:pause, []).call()
return self
end
raise ArgumentError, "Invalid arguments when calling pause()"
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.
44
45
46
47
48
49
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 44
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
raise ArgumentError, "Invalid arguments when calling pipe()"
end
|
- (void) pipe_to(dst = nil) { ... }
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.
59
60
61
62
63
64
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 59
def pipe_to(dst=nil)
if dst.class.method_defined?(:j_del) && true
return @j_del.java_method(:pipeTo, [Java::IoVertxCoreStreams::WriteStream.java_class,Java::IoVertxCore::Handler.java_class]).call(dst.j_del,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) } unless !block_given?))
end
raise ArgumentError, "Invalid arguments when calling pipe_to(#{dst})"
end
|
- (self) resume
92
93
94
95
96
97
98
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_receiver.rb', line 92
def resume
if !block_given?
@j_del.java_method(:resume, []).call()
return self
end
raise ArgumentError, "Invalid arguments when calling resume()"
end
|