Class: VertxRabbitmq::RabbitMQClient
- Inherits:
-
Object
- Object
- VertxRabbitmq::RabbitMQClient
- Defined in:
- /Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb
Constant Summary
- @@j_api_type =
Object.new
Class Method Summary (collapse)
- + (Boolean) accept?(obj)
- + (::VertxRabbitmq::RabbitMQClient) create(vertx = nil, config = nil)
- + (Object) j_api_type
- + (Object) j_class
- + (Object) unwrap(obj)
- + (Object) wrap(obj)
Instance Method Summary (collapse)
-
- (void) basic_ack(deliveryTag = nil, multiple = nil) { ... }
Acknowledge one or several received messages.
-
- (void) basic_consume(queue = nil, address = nil, autoAck = nil, resultHandler = nil) { ... }
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and error handler.
-
- (void) basic_get(queue = nil, autoAck = nil) { ... }
Retrieve a message from a queue using AMQP.Basic.Get.
-
- (void) basic_nack(deliveryTag = nil, multiple = nil, requeue = nil) { ... }
Reject one or several received messages.
-
- (void) basic_publish(exchange = nil, routingKey = nil, message = nil) { ... }
Publish a message.
-
- (void) basic_qos(prefetchCount = nil) { ... }
Request specific "quality of service" settings, Limiting the number of unacknowledged messages on a channel (or connection).
-
- (void) confirm_select { ... }
Enables publisher acknowledgements on this channel.
-
- (true, false) connected?
Check if a connection is open.
-
- (void) exchange_bind(destination = nil, source = nil, routingKey = nil) { ... }
Bind an exchange to an exchange.
-
- (void) exchange_declare(exchange = nil, type = nil, durable = nil, autoDelete = nil, config = nil) { ... }
Declare an exchange with additional parameters such as dead lettering or an alternate exchnage.
-
- (void) exchange_delete(exchange = nil) { ... }
Delete an exchange, without regard for whether it is in use or not.
-
- (void) exchange_unbind(destination = nil, source = nil, routingKey = nil) { ... }
Unbind an exchange from an exchange.
-
- (void) message_count(queue = nil) { ... }
Returns the number of messages in a queue ready to be delivered.
-
- (true, false) open_channel?
Check if a channel is open.
-
- (void) queue_bind(queue = nil, exchange = nil, routingKey = nil) { ... }
Bind a queue to an exchange.
-
- (void) queue_declare(queue = nil, durable = nil, exclusive = nil, autoDelete = nil, config = nil) { ... }
Declare a queue with config options.
-
- (void) queue_declare_auto { ... }
Actively declare a server-named exclusive, autodelete, non-durable queue.
-
- (void) queue_delete(queue = nil) { ... }
Delete a queue, without regard for whether it is in use or has messages on it.
-
- (void) queue_delete_if(queue = nil, ifUnused = nil, ifEmpty = nil) { ... }
Delete a queue.
-
- (void) start { ... }
Start the rabbitMQ client.
-
- (void) stop { ... }
Stop the rabbitMQ client.
-
- (void) wait_for_confirms(timeout = nil) { ... }
Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses.
Class Method Details
+ (Boolean) accept?(obj)
17 18 19 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 17 def @@j_api_type.accept?(obj) obj.class == RabbitMQClient end |
+ (::VertxRabbitmq::RabbitMQClient) create(vertx = nil, config = nil)
35 36 37 38 39 40 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 35 def self.create(vertx=nil,config=nil) if vertx.class.method_defined?(:j_del) && config.class == Hash && !block_given? return ::Vertx::Util::Utils.safe_create(Java::IoVertxRabbitmq::RabbitMQClient.java_method(:create, [Java::IoVertxCore::Vertx.java_class,Java::IoVertxCoreJson::JsonObject.java_class]).call(vertx.j_del,::Vertx::Util::Utils.to_json_object(config)),::VertxRabbitmq::RabbitMQClient) end raise ArgumentError, "Invalid arguments when calling create(#{vertx},#{config})" end |
+ (Object) j_api_type
26 27 28 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 26 def self.j_api_type @@j_api_type end |
+ (Object) j_class
29 30 31 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 29 def self.j_class Java::IoVertxRabbitmq::RabbitMQClient.java_class end |
+ (Object) unwrap(obj)
23 24 25 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 23 def @@j_api_type.unwrap(obj) obj.j_del end |
+ (Object) wrap(obj)
20 21 22 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 20 def @@j_api_type.wrap(obj) RabbitMQClient.new(obj) end |
Instance Method Details
- (void) basic_ack(deliveryTag = nil, multiple = nil) { ... }
This method returns an undefined value.
Acknowledge one or several received messages. Supply the deliveryTag from the AMQP.Basic.GetOk or AMQP.Basic.Deliver method containing the received message being acknowledged.
47 48 49 50 51 52 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 47 def basic_ack(deliveryTag=nil,multiple=nil) if deliveryTag.class == Fixnum && (multiple.class == TrueClass || multiple.class == FalseClass) && block_given? return @j_del.java_method(:basicAck, [Java::long.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(deliveryTag,multiple,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) })) end raise ArgumentError, "Invalid arguments when calling basic_ack(#{deliveryTag},#{multiple})" end |
- (void) basic_consume(queue = nil, address = nil, autoAck = nil, resultHandler = nil) { ... }
This method returns an undefined value.
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and error handler
83 84 85 86 87 88 89 90 91 92 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 83 def basic_consume(queue=nil,address=nil,autoAck=nil,resultHandler=nil) if queue.class == String && address.class == String && block_given? && autoAck == nil && resultHandler == nil return @j_del.java_method(:basicConsume, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,address,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) elsif queue.class == String && address.class == String && (autoAck.class == TrueClass || autoAck.class == FalseClass) && block_given? && resultHandler == nil return @j_del.java_method(:basicConsume, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,address,autoAck,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) elsif queue.class == String && address.class == String && (autoAck.class == TrueClass || autoAck.class == FalseClass) && resultHandler.class == Proc && block_given? return @j_del.java_method(:basicConsume, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,address,autoAck,(Proc.new { |ar| resultHandler.call(ar.failed ? ar.cause : nil) }),(Proc.new { |event| yield(::Vertx::Util::Utils.from_throwable(event)) })) end raise ArgumentError, "Invalid arguments when calling basic_consume(#{queue},#{address},#{autoAck},#{resultHandler})" end |
- (void) basic_get(queue = nil, autoAck = nil) { ... }
This method returns an undefined value.
Retrieve a message from a queue using AMQP.Basic.Get
70 71 72 73 74 75 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 70 def basic_get(queue=nil,autoAck=nil) if queue.class == String && (autoAck.class == TrueClass || autoAck.class == FalseClass) && block_given? return @j_del.java_method(:basicGet, [Java::java.lang.String.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,autoAck,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) })) end raise ArgumentError, "Invalid arguments when calling basic_get(#{queue},#{autoAck})" end |
- (void) basic_nack(deliveryTag = nil, multiple = nil, requeue = nil) { ... }
This method returns an undefined value.
Reject one or several received messages.
59 60 61 62 63 64 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 59 def basic_nack(deliveryTag=nil,multiple=nil,requeue=nil) if deliveryTag.class == Fixnum && (multiple.class == TrueClass || multiple.class == FalseClass) && (requeue.class == TrueClass || requeue.class == FalseClass) && block_given? return @j_del.java_method(:basicNack, [Java::long.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(deliveryTag,multiple,requeue,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) })) end raise ArgumentError, "Invalid arguments when calling basic_nack(#{deliveryTag},#{multiple},#{requeue})" end |
- (void) basic_publish(exchange = nil, routingKey = nil, message = nil) { ... }
This method returns an undefined value.
Publish a message. Publishing to a non-existent exchange will result in a channel-level protocol exception, which closes the channel. Invocations of Channel#basicPublish will eventually block if a resource-driven alarm is in effect.
100 101 102 103 104 105 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 100 def basic_publish(exchange=nil,routingKey=nil,=nil) if exchange.class == String && routingKey.class == String && .class == Hash && block_given? return @j_del.java_method(:basicPublish, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCore::Handler.java_class]).call(exchange,routingKey,::Vertx::Util::Utils.to_json_object(),(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling basic_publish(#{exchange},#{routingKey},#{})" end |
- (void) basic_qos(prefetchCount = nil) { ... }
This method returns an undefined value.
Request specific "quality of service" settings, Limiting the number of unacknowledged messages on a channel (or connection). This limit is applied separately to each new consumer on the channel.
133 134 135 136 137 138 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 133 def basic_qos(prefetchCount=nil) if prefetchCount.class == Fixnum && block_given? return @j_del.java_method(:basicQos, [Java::int.java_class,Java::IoVertxCore::Handler.java_class]).call(prefetchCount,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling basic_qos(#{prefetchCount})" end |
- (void) confirm_select { ... }
This method returns an undefined value.
Enables publisher acknowledgements on this channel. Can be called once during client initialisation. Calls to basicPublish() will have to be confirmed.
110 111 112 113 114 115 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 110 def confirm_select if block_given? return @j_del.java_method(:confirmSelect, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling confirm_select()" end |
- (true, false) connected?
278 279 280 281 282 283 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 278 def connected? if !block_given? return @j_del.java_method(:isConnected, []).call() end raise ArgumentError, "Invalid arguments when calling connected?()" end |
- (void) exchange_bind(destination = nil, source = nil, routingKey = nil) { ... }
This method returns an undefined value.
Bind an exchange to an exchange.
171 172 173 174 175 176 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 171 def exchange_bind(destination=nil,source=nil,routingKey=nil) if destination.class == String && source.class == String && routingKey.class == String && block_given? return @j_del.java_method(:exchangeBind, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(destination,source,routingKey,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling exchange_bind(#{destination},#{source},#{routingKey})" end |
- (void) exchange_declare(exchange = nil, type = nil, durable = nil, autoDelete = nil, config = nil) { ... }
This method returns an undefined value.
Declare an exchange with additional parameters such as dead lettering or an alternate exchnage.
147 148 149 150 151 152 153 154 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 147 def exchange_declare(exchange=nil,type=nil,durable=nil,autoDelete=nil,config=nil) if exchange.class == String && type.class == String && (durable.class == TrueClass || durable.class == FalseClass) && (autoDelete.class == TrueClass || autoDelete.class == FalseClass) && block_given? && config == nil return @j_del.java_method(:exchangeDeclare, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(exchange,type,durable,autoDelete,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) elsif exchange.class == String && type.class == String && (durable.class == TrueClass || durable.class == FalseClass) && (autoDelete.class == TrueClass || autoDelete.class == FalseClass) && config.class == Hash && block_given? return @j_del.java_method(:exchangeDeclare, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::JavaUtil::Map.java_class,Java::IoVertxCore::Handler.java_class]).call(exchange,type,durable,autoDelete,Hash[config.map { |k,v| [k,v] }],(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling exchange_declare(#{exchange},#{type},#{durable},#{autoDelete},#{config})" end |
- (void) exchange_delete(exchange = nil) { ... }
This method returns an undefined value.
Delete an exchange, without regard for whether it is in use or not.
159 160 161 162 163 164 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 159 def exchange_delete(exchange=nil) if exchange.class == String && block_given? return @j_del.java_method(:exchangeDelete, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(exchange,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling exchange_delete(#{exchange})" end |
- (void) exchange_unbind(destination = nil, source = nil, routingKey = nil) { ... }
This method returns an undefined value.
Unbind an exchange from an exchange.
183 184 185 186 187 188 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 183 def exchange_unbind(destination=nil,source=nil,routingKey=nil) if destination.class == String && source.class == String && routingKey.class == String && block_given? return @j_del.java_method(:exchangeUnbind, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(destination,source,routingKey,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling exchange_unbind(#{destination},#{source},#{routingKey})" end |
- (void) message_count(queue = nil) { ... }
This method returns an undefined value.
Returns the number of messages in a queue ready to be delivered.
252 253 254 255 256 257 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 252 def (queue=nil) if queue.class == String && block_given? return @j_del.java_method(:messageCount, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) })) end raise ArgumentError, "Invalid arguments when calling message_count(#{queue})" end |
- (true, false) open_channel?
286 287 288 289 290 291 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 286 def open_channel? if !block_given? return @j_del.java_method(:isOpenChannel, []).call() end raise ArgumentError, "Invalid arguments when calling open_channel?()" end |
- (void) queue_bind(queue = nil, exchange = nil, routingKey = nil) { ... }
This method returns an undefined value.
Bind a queue to an exchange
242 243 244 245 246 247 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 242 def queue_bind(queue=nil,exchange=nil,routingKey=nil) if queue.class == String && exchange.class == String && routingKey.class == String && block_given? return @j_del.java_method(:queueBind, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,exchange,routingKey,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling queue_bind(#{queue},#{exchange},#{routingKey})" end |
- (void) queue_declare(queue = nil, durable = nil, exclusive = nil, autoDelete = nil, config = nil) { ... }
This method returns an undefined value.
Declare a queue with config options
206 207 208 209 210 211 212 213 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 206 def queue_declare(queue=nil,durable=nil,exclusive=nil,autoDelete=nil,config=nil) if queue.class == String && (durable.class == TrueClass || durable.class == FalseClass) && (exclusive.class == TrueClass || exclusive.class == FalseClass) && (autoDelete.class == TrueClass || autoDelete.class == FalseClass) && block_given? && config == nil return @j_del.java_method(:queueDeclare, [Java::java.lang.String.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,durable,exclusive,autoDelete,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) })) elsif queue.class == String && (durable.class == TrueClass || durable.class == FalseClass) && (exclusive.class == TrueClass || exclusive.class == FalseClass) && (autoDelete.class == TrueClass || autoDelete.class == FalseClass) && config.class == Hash && block_given? return @j_del.java_method(:queueDeclare, [Java::java.lang.String.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::JavaUtil::Map.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,durable,exclusive,autoDelete,Hash[config.map { |k,v| [k,v] }],(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) })) end raise ArgumentError, "Invalid arguments when calling queue_declare(#{queue},#{durable},#{exclusive},#{autoDelete},#{config})" end |
- (void) queue_declare_auto { ... }
This method returns an undefined value.
Actively declare a server-named exclusive, autodelete, non-durable queue.
192 193 194 195 196 197 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 192 def queue_declare_auto if block_given? return @j_del.java_method(:queueDeclareAuto, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) })) end raise ArgumentError, "Invalid arguments when calling queue_declare_auto()" end |
- (void) queue_delete(queue = nil) { ... }
This method returns an undefined value.
Delete a queue, without regard for whether it is in use or has messages on it
218 219 220 221 222 223 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 218 def queue_delete(queue=nil) if queue.class == String && block_given? return @j_del.java_method(:queueDelete, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) })) end raise ArgumentError, "Invalid arguments when calling queue_delete(#{queue})" end |
- (void) queue_delete_if(queue = nil, ifUnused = nil, ifEmpty = nil) { ... }
This method returns an undefined value.
Delete a queue
230 231 232 233 234 235 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 230 def queue_delete_if(queue=nil,ifUnused=nil,ifEmpty=nil) if queue.class == String && (ifUnused.class == TrueClass || ifUnused.class == FalseClass) && (ifEmpty.class == TrueClass || ifEmpty.class == FalseClass) && block_given? return @j_del.java_method(:queueDeleteIf, [Java::java.lang.String.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(queue,ifUnused,ifEmpty,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) })) end raise ArgumentError, "Invalid arguments when calling queue_delete_if(#{queue},#{ifUnused},#{ifEmpty})" end |
- (void) start { ... }
This method returns an undefined value.
Start the rabbitMQ client. Create the connection and the chanel.
261 262 263 264 265 266 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 261 def start if block_given? return @j_del.java_method(:start, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling start()" end |
- (void) stop { ... }
This method returns an undefined value.
Stop the rabbitMQ client. Close the connection and its chanel.
270 271 272 273 274 275 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 270 def stop if block_given? return @j_del.java_method(:stop, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling stop()" end |
- (void) wait_for_confirms(timeout = nil) { ... }
This method returns an undefined value.
Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses. If the timeout expires a TimeoutException is thrown.
120 121 122 123 124 125 126 127 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 120 def wait_for_confirms(timeout=nil) if block_given? && timeout == nil return @j_del.java_method(:waitForConfirms, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) elsif timeout.class == Fixnum && block_given? return @j_del.java_method(:waitForConfirms, [Java::long.java_class,Java::IoVertxCore::Handler.java_class]).call(timeout,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling wait_for_confirms(#{timeout})" end |