Class: VertxRabbitmq::RabbitMQClient
- Inherits:
-
Object
- Object
- VertxRabbitmq::RabbitMQClient
- Defined in:
- /Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb
Constant Summary
- @@j_api_type =
Object.new
Class Method Summary (collapse)
- + (Boolean) accept?(obj)
-
+ (::VertxRabbitmq::RabbitMQClient) create(*args)
Create and return a client.
- + (Object) j_api_type
- + (Object) j_class
- + (Object) unwrap(obj)
- + (Object) wrap(obj)
Instance Method Summary (collapse)
-
- (void) basicAck(deliveryTag, multiple, resultHandler) { ... }
Acknowledge one or several received messages.
-
- (void) basic_consumer(*args)
Create a consumer with the given options.
-
- (void) basicGet(queue, autoAck, resultHandler) { ... }
Retrieve a message from a queue using AMQP.Basic.Get.
-
- (void) basicNack(deliveryTag, multiple, requeue, resultHandler) { ... }
Reject one or several received messages.
-
- (void) basicPublish(exchange, routingKey, body, resultHandler) { ... }
Publish a message.
-
- (void) basic_qos(*args)
Request specific "quality of service" settings.
-
- (void) confirmSelect(resultHandler) { ... }
Enables publisher acknowledgements on this channel.
-
- (true, false) isConnected
Check if a connection is open.
-
- (void) exchangeBind(destination, source, routingKey, resultHandler) { ... }
Bind an exchange to an exchange.
-
- (void) exchange_declare(*args)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
-
- (void) exchangeDelete(exchange, resultHandler) { ... }
Delete an exchange, without regard for whether it is in use or not.
-
- (void) exchangeUnbind(destination, source, routingKey, resultHandler) { ... }
Unbind an exchange from an exchange.
-
- (void) messageCount(queue, resultHandler) { ... }
Returns the number of messages in a queue ready to be delivered.
-
- (true, false) isOpenChannel
Check if a channel is open.
-
- (void) queueBind(queue, exchange, routingKey, resultHandler) { ... }
Bind a queue to an exchange.
-
- (::Vertx::Future) queueDeclare(queue, durable, exclusive, autoDelete)
Like #queue_declare but returns a Future of the asynchronous result.
-
- (void) queueDeclareAuto(resultHandler) { ... }
Actively declare a server-named exclusive, autodelete, non-durable queue.
-
- (::Vertx::Future) queueDelete(queue)
Like #queue_delete but returns a Future of the asynchronous result.
-
- (::Vertx::Future) queueDeleteIf(queue, ifUnused, ifEmpty)
Like #queue_delete_if but returns a Future of the asynchronous result.
-
- (void) start(resultHandler) { ... }
Start the rabbitMQ client.
-
- (void) stop(resultHandler) { ... }
Stop the rabbitMQ client.
-
- (void) wait_for_confirms(*args)
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)
22 23 24 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 22 def @@j_api_type.accept?(obj) obj.class == RabbitMQClient end |
+ (::VertxRabbitmq::RabbitMQClient) create(vertx) + (::VertxRabbitmq::RabbitMQClient) create(vertx, config)
Create and return a client.
452 453 454 455 456 457 458 459 460 461 462 463 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 452 def self.create(*args) if args[0].class.method_defined?(:j_del) && !block_given? && args[1] == nil return ::Vertx::Util::Utils.safe_create(Java::IoVertxRabbitmq::RabbitMQClient.java_method(:create, [Java::IoVertxCore::Vertx.java_class]).call(args[0].j_del),::VertxRabbitmq::RabbitMQClient) elsif args[0].class.method_defined?(:j_del) && args[1].class == Hash && !block_given? return ::Vertx::Util::Utils.safe_create(Java::IoVertxRabbitmq::RabbitMQClient.java_method(:create, [Java::IoVertxCore::Vertx.java_class,Java::IoVertxRabbitmq::RabbitMQOptions.java_class]).call(args[0].j_del,Java::IoVertxRabbitmq::RabbitMQOptions.new(::Vertx::Util::Utils.to_json_object(args[1]))),::VertxRabbitmq::RabbitMQClient) end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling create(#{args[0]},#{args[1]})" end end |
+ (Object) j_api_type
31 32 33 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.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-rabbitmq/rabbit_mq_client.rb', line 34 def self.j_class Java::IoVertxRabbitmq::RabbitMQClient.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-rabbitmq/rabbit_mq_client.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-rabbitmq/rabbit_mq_client.rb', line 25 def @@j_api_type.wrap(obj) RabbitMQClient.new(obj) end |
Instance Method Details
- (void) basicAck(deliveryTag, multiple, resultHandler) { ... }
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.
429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 429 def basic_ack(*args) if args[0].class == Fixnum && (args[1].class == TrueClass || args[1].class == FalseClass) && true if (block_given?) return @j_del.java_method(:basicAck, [Java::long.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],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(:basicAck, [Java::long.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],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 basic_ack(#{args[0]},#{args[1]})" end end |
- (void) basicConsumer(queue, resultHandler) { ... } - (void) basicConsumer(queue, options, resultHandler) { ... }
This method returns an undefined value.
Create a consumer with the givenoptions
.
248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 248 def basic_consumer(*args) if args[0].class == String && true && args[1] == nil if (block_given?) return @j_del.java_method(:basicConsumer, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRabbitmq::RabbitMQConsumer) : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:basicConsumer, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRabbitmq::RabbitMQConsumer) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxRabbitmq::RabbitMQConsumer.j_api_type) end elsif args[0].class == String && args[1].class == Hash && true if (block_given?) return @j_del.java_method(:basicConsumer, [Java::java.lang.String.java_class,Java::IoVertxRabbitmq::QueueOptions.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],Java::IoVertxRabbitmq::QueueOptions.new(::Vertx::Util::Utils.to_json_object(args[1])),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRabbitmq::RabbitMQConsumer) : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:basicConsumer, [Java::java.lang.String.java_class,Java::IoVertxRabbitmq::QueueOptions.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],Java::IoVertxRabbitmq::QueueOptions.new(::Vertx::Util::Utils.to_json_object(args[1])),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRabbitmq::RabbitMQConsumer) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxRabbitmq::RabbitMQConsumer.j_api_type) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling basic_consumer(#{args[0]},#{args[1]})" end end |
- (void) basicGet(queue, autoAck, resultHandler) { ... }
This method returns an undefined value.
Retrieve a message from a queue using AMQP.Basic.Get
278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 278 def basic_get(*args) if args[0].class == String && (args[1].class == TrueClass || args[1].class == FalseClass) && true if (block_given?) return @j_del.java_method(:basicGet, [Java::java.lang.String.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRabbitmq::RabbitMQMessage) : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:basicGet, [Java::java.lang.String.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::VertxRabbitmq::RabbitMQMessage) : nil) } : promise) return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future,::VertxRabbitmq::RabbitMQMessage.j_api_type) end end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling basic_get(#{args[0]},#{args[1]})" end end |
- (void) basicNack(deliveryTag, multiple, requeue, resultHandler) { ... }
This method returns an undefined value.
Reject one or several received messages.
495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 495 def basic_nack(*args) if args[0].class == Fixnum && (args[1].class == TrueClass || args[1].class == FalseClass) && (args[2].class == TrueClass || args[2].class == FalseClass) && true if (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(args[0],args[1],args[2],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(:basicNack, [Java::long.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],args[2],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 basic_nack(#{args[0]},#{args[1]},#{args[2]})" end end |
- (void) basicPublish(exchange, routingKey, body, resultHandler) { ... }
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.
472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 472 def basic_publish(*args) if args[0].class == String && args[1].class == String && args[2].class.method_defined?(:j_del) && true if (block_given?) return @j_del.java_method(:basicPublish, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::IoVertxCoreBuffer::Buffer.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],args[2].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(:basicPublish, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::IoVertxCoreBuffer::Buffer.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],args[2].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 basic_publish(#{args[0]},#{args[1]},#{args[2]})" end end |
- (void) basicQos(prefetchCount, resultHandler) { ... } - (void) basicQos(prefetchCount, global, resultHandler) { ... } - (void) basicQos(prefetchSize, prefetchCount, global, resultHandler) { ... }
This method returns an undefined value.
Request specific "quality of service" settings. These settings impose limits on the amount of data the server will deliver to consumers before requiring acknowledgements. Thus they provide a means of consumer-initiated flow control.
151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 151 def basic_qos(*args) if args[0].class == Fixnum && true && args[1] == nil && args[2] == nil if (block_given?) return @j_del.java_method(:basicQos, [Java::int.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],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(:basicQos, [Java::int.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],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 elsif args[0].class == Fixnum && (args[1].class == TrueClass || args[1].class == FalseClass) && true && args[2] == nil if (block_given?) return @j_del.java_method(:basicQos, [Java::int.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],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(:basicQos, [Java::int.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],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 elsif args[0].class == Fixnum && args[1].class == Fixnum && (args[2].class == TrueClass || args[2].class == FalseClass) && true if (block_given?) return @j_del.java_method(:basicQos, [Java::int.java_class,Java::int.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],args[2],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(:basicQos, [Java::int.java_class,Java::int.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],args[2],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 basic_qos(#{args[0]},#{args[1]},#{args[2]})" end end |
- (void) confirmSelect(resultHandler) { ... }
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.
65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 65 def confirm_select if true if (block_given?) return @j_del.java_method(:confirmSelect, [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(:confirmSelect, [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 confirm_select()" end end |
- (true, false) isConnected
Check if a connection is open
209 210 211 212 213 214 215 216 217 218 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 209 def connected? if !block_given? return @j_del.java_method(:isConnected, []).call() end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling connected?()" end end |
- (void) exchangeBind(destination, source, routingKey, resultHandler) { ... }
This method returns an undefined value.
Bind an exchange to an exchange.
334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 334 def exchange_bind(*args) if args[0].class == String && args[1].class == String && args[2].class == String && true if (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(args[0],args[1],args[2],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(: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(args[0],args[1],args[2],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 exchange_bind(#{args[0]},#{args[1]},#{args[2]})" end end |
- (void) exchangeDeclare(exchange, type, durable, autoDelete, resultHandler) { ... } - (void) exchangeDeclare(exchange, type, durable, autoDelete, config, resultHandler) { ... }
This method returns an undefined value.
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 526 def exchange_declare(*args) if args[0].class == String && args[1].class == String && (args[2].class == TrueClass || args[2].class == FalseClass) && (args[3].class == TrueClass || args[3].class == FalseClass) && true && args[4] == nil if (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::IoVertxCore::Handler.java_class]).call(args[0],args[1],args[2],args[3],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(: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(args[0],args[1],args[2],args[3],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 elsif args[0].class == String && args[1].class == String && (args[2].class == TrueClass || args[2].class == FalseClass) && (args[3].class == TrueClass || args[3].class == FalseClass) && args[4].class == Hash && true if (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::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],args[2],args[3],::Vertx::Util::Utils.to_json_object(args[4]),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(:exchangeDeclare, [Java::java.lang.String.java_class,Java::java.lang.String.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::IoVertxCoreJson::JsonObject.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],args[1],args[2],args[3],::Vertx::Util::Utils.to_json_object(args[4]),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 exchange_declare(#{args[0]},#{args[1]},#{args[2]},#{args[3]},#{args[4]})" end end |
- (void) exchangeDelete(exchange, resultHandler) { ... }
This method returns an undefined value.
Delete an exchange, without regard for whether it is in use or not.
369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 369 def exchange_delete(*args) if args[0].class == String && true if (block_given?) return @j_del.java_method(:exchangeDelete, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],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(:exchangeDelete, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],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 exchange_delete(#{args[0]})" end end |
- (void) exchangeUnbind(destination, source, routingKey, resultHandler) { ... }
This method returns an undefined value.
Unbind an exchange from an exchange.
44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 44 def exchange_unbind(*args) if args[0].class == String && args[1].class == String && args[2].class == String && true if (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(args[0],args[1],args[2],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(: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(args[0],args[1],args[2],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 exchange_unbind(#{args[0]},#{args[1]},#{args[2]})" end end |
- (void) messageCount(queue, resultHandler) { ... }
This method returns an undefined value.
Returns the number of messages in a queue ready to be delivered.
117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 117 def (*args) if args[0].class == String && true if (block_given?) return @j_del.java_method(:messageCount, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:messageCount, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result : 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 message_count(#{args[0]})" end end |
- (true, false) isOpenChannel
Check if a channel is open
297 298 299 300 301 302 303 304 305 306 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 297 def open_channel? if !block_given? return @j_del.java_method(:isOpenChannel, []).call() end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling open_channel?()" end end |
- (void) queueBind(queue, exchange, routingKey, resultHandler) { ... }
This method returns an undefined value.
Bind a queue to an exchange
190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 190 def queue_bind(*args) if args[0].class == String && args[1].class == String && args[2].class == String && true if (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(args[0],args[1],args[2],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(: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(args[0],args[1],args[2],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 queue_bind(#{args[0]},#{args[1]},#{args[2]})" end end |
- (::Vertx::Future) queueDeclare(queue, durable, exclusive, autoDelete)
Like #queue_declare but returns a
Future
of the asynchronous result
412 413 414 415 416 417 418 419 420 421 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 412 def queue_declare(*args) if args[0].class == String && (args[1].class == TrueClass || args[1].class == FalseClass) && (args[2].class == TrueClass || args[2].class == FalseClass) && (args[3].class == TrueClass || args[3].class == FalseClass) && !block_given? return ::Vertx::Util::Utils.safe_create(@j_del.java_method(:queueDeclare, [Java::java.lang.String.java_class,Java::boolean.java_class,Java::boolean.java_class,Java::boolean.java_class]).call(args[0],args[1],args[2],args[3]),::Vertx::Future, nil) end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling queue_declare(#{args[0]},#{args[1]},#{args[2]},#{args[3]})" end end |
- (void) queueDeclareAuto(resultHandler) { ... }
This method returns an undefined value.
Actively declare a server-named exclusive, autodelete, non-durable queue.
311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 311 def queue_declare_auto if true if (block_given?) return @j_del.java_method(:queueDeclareAuto, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : nil : nil) } : promise) else promise = ::Vertx::Util::Utils.promise @j_del.java_method(:queueDeclareAuto, [Java::IoVertxCore::Handler.java_class]).call(block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ar.result != nil ? JSON.parse(ar.result.encode) : 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 queue_declare_auto()" end end |
- (::Vertx::Future) queueDelete(queue)
Like #queue_delete but returns a
Future
of the asynchronous result
354 355 356 357 358 359 360 361 362 363 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 354 def queue_delete(*args) if args[0].class == String && !block_given? return ::Vertx::Util::Utils.safe_create(@j_del.java_method(:queueDelete, [Java::java.lang.String.java_class]).call(args[0]),::Vertx::Future, nil) end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling queue_delete(#{args[0]})" end end |
- (::Vertx::Future) queueDeleteIf(queue, ifUnused, ifEmpty)
Like #queue_delete_if but returns a
Future
of the asynchronous result
556 557 558 559 560 561 562 563 564 565 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 556 def queue_delete_if(*args) if args[0].class == String && (args[1].class == TrueClass || args[1].class == FalseClass) && (args[2].class == TrueClass || args[2].class == FalseClass) && !block_given? return ::Vertx::Util::Utils.safe_create(@j_del.java_method(:queueDeleteIf, [Java::java.lang.String.java_class,Java::boolean.java_class,Java::boolean.java_class]).call(args[0],args[1],args[2]),::Vertx::Future, nil) end if defined?(super) super else raise ArgumentError, "Invalid arguments when calling queue_delete_if(#{args[0]},#{args[1]},#{args[2]})" end end |
- (void) start(resultHandler) { ... }
This method returns an undefined value.
Start the rabbitMQ client. Create the connection and the chanel.
223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 223 def start if true if (block_given?) return @j_del.java_method(:start, [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(:start, [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 start()" end end |
- (void) stop(resultHandler) { ... }
This method returns an undefined value.
Stop the rabbitMQ client. Close the connection and its chanel.
389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 389 def stop if true if (block_given?) return @j_del.java_method(:stop, [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(:stop, [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 stop()" end end |
- (void) waitForConfirms(resultHandler) { ... } - (void) waitForConfirms(timeout, resultHandler) { ... }
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.
88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 |
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-rabbitmq/rabbit_mq_client.rb', line 88 def wait_for_confirms(*args) if true && args[0] == nil if (block_given?) return @j_del.java_method(:waitForConfirms, [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(:waitForConfirms, [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 elsif args[0].class == Fixnum && true if (block_given?) return @j_del.java_method(:waitForConfirms, [Java::long.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],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(:waitForConfirms, [Java::long.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0],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 wait_for_confirms(#{args[0]})" end end |