Class: VertxAmqpClient::AmqpSender
- Inherits:
-
Object
- Object
- VertxAmqpClient::AmqpSender
show all
- Includes:
- Vertx::WriteStream
- Defined in:
- /Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb
Overview
AMQP Sender interface used to send messages.
Constant Summary
- @@j_api_type =
Object.new
Class Method Summary
(collapse)
Instance Method Summary
(collapse)
Class Method Details
+ (Boolean) accept?(obj)
22
23
24
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 22
def @@j_api_type.accept?(obj)
obj.class == AmqpSender
end
|
+ (Object) j_api_type
31
32
33
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 31
def self.j_api_type
@@j_api_type
end
|
+ (Object) j_class
34
35
36
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 34
def self.j_class
Java::IoVertxAmqp::AmqpSender.java_class
end
|
+ (Object) unwrap(obj)
28
29
30
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 28
def @@j_api_type.unwrap(obj)
obj.j_del
end
|
+ (Object) wrap(obj)
25
26
27
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 25
def @@j_api_type.wrap(obj)
AmqpSender.new(obj)
end
|
Instance Method Details
- (String) address
Returns the configured address.
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_sender.rb', line 132
def address
if !block_given?
return @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 sender.
125
126
127
128
129
130
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 125
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 sender. Cannot be null
140
141
142
143
144
145
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 140
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) drain_handler { ... }
Set a drain handler on the stream. If the write queue is full, then the handler will be called when the write
queue is ready to accept buffers again. See for an example of this being used.
The stream implementation defines when the drain handler, for example it could be when the queue size has been
reduced to
maxSize / 2.
74
75
76
77
78
79
80
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 74
def drain_handler
if true
@j_del.java_method(:drainHandler, [Java::IoVertxCore::Handler.java_class]).call(Proc.new { yield unless !block_given? })
return self
end
raise ArgumentError, "Invalid arguments when calling drain_handler()"
end
|
- (void) end(data = nil) { ... }
This method returns an undefined value.
Same as but with an
handler called when the operation completes
51
52
53
54
55
56
57
58
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 51
def end(data=nil)
if true && data == nil
return @j_del.java_method(:end, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |ar| yield(ar.failed ? ar.cause : nil) } unless !block_given?))
elsif data.class.method_defined?(:j_del) && true
return @j_del.java_method(:end, [Java::IoVertxAmqp::AmqpMessage.java_class,Java::IoVertxCore::Handler.java_class]).call(data.j_del,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) } unless !block_given?))
end
raise ArgumentError, "Invalid arguments when calling end(#{data})"
end
|
- (self) exception_handler { ... }
83
84
85
86
87
88
89
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 83
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) send(message = nil)
Sends an AMQP message. The destination the configured sender address or the address configured in the message.
102
103
104
105
106
107
108
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 102
def send(message=nil)
if message.class.method_defined?(:j_del) && !block_given?
@j_del.java_method(:send, [Java::IoVertxAmqp::AmqpMessage.java_class]).call(message.j_del)
return self
end
raise ArgumentError, "Invalid arguments when calling send(#{message})"
end
|
- (self) send_with_ack(message = nil) { ... }
Sends an AMQP message and waits for an acknowledgement. The acknowledgement handler is called with an
marked as failed if the message has been rejected or re-routed. If the message has been accepted,
the handler is called with a success.
115
116
117
118
119
120
121
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 115
def send_with_ack(message=nil)
if message.class.method_defined?(:j_del) && true
@j_del.java_method(:sendWithAck, [Java::IoVertxAmqp::AmqpMessage.java_class,Java::IoVertxCore::Handler.java_class]).call(message.j_del,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) } unless !block_given?))
return self
end
raise ArgumentError, "Invalid arguments when calling send_with_ack(#{message})"
end
|
- (self) set_write_queue_max_size(maxSize = nil)
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_sender.rb', line 92
def set_write_queue_max_size(maxSize=nil)
if maxSize.class == Fixnum && !block_given?
@j_del.java_method(:setWriteQueueMaxSize, [Java::int.java_class]).call(maxSize)
return self
end
raise ArgumentError, "Invalid arguments when calling set_write_queue_max_size(#{maxSize})"
end
|
- (void) write(data = nil) { ... }
This method returns an undefined value.
Same as but with an
handler called when the operation completes
41
42
43
44
45
46
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 41
def write(data=nil)
if data.class.method_defined?(:j_del) && true
return @j_del.java_method(:write, [Java::IoVertxAmqp::AmqpMessage.java_class,Java::IoVertxCore::Handler.java_class]).call(data.j_del,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) } unless !block_given?))
end
raise ArgumentError, "Invalid arguments when calling write(#{data})"
end
|
- (true, false) write_queue_full?
61
62
63
64
65
66
|
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_sender.rb', line 61
def write_queue_full?
if !block_given?
return @j_del.java_method(:writeQueueFull, []).call()
end
raise ArgumentError, "Invalid arguments when calling write_queue_full?()"
end
|