Class List Method List File List

# Class: VertxRabbitmq::RabbitMQClient

Inherits:
  Object
  - Object
  - VertxRabbitmq::RabbitMQClient
  show all
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) { ... }
  Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
- - (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).
- - (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) { ... }
  Declare a queue.
- - (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.

## Class Method Details

### + (`Boolean`) accept?(obj)

Returns:

- (`Boolean`)

    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)

Parameters:

- vertx (`::Vertx::Vertx`) (defaults to: `nil`)
- config (`Hash{String => Object}`) (defaults to: `nil`)

Returns:

- (`::VertxRabbitmq::RabbitMQClient`)

Raises:

- (`ArgumentError`)

    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.

Parameters:

- deliveryTag (`Fixnum`) (defaults to: `nil`)
- multiple (`true`, `false`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    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) { ... }

This method returns an undefined value.

Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.

Parameters:

- queue (`String`) (defaults to: `nil`)
- address (`String`) (defaults to: `nil`)
- autoAck (`true`, `false`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    82
    83
    84
    85
    86
    87
    88
    89
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 82

    def basic_consume(queue=nil,address=nil,autoAck=nil)
      if queue.class == String && address.class == String && block_given? && autoAck == 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?
        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) }))
      end
      raise ArgumentError, "Invalid arguments when calling basic_consume(#{queue},#{address},#{autoAck})"
    end

### - (`void`) basic_get(queue = nil, autoAck = nil) { ... }

This method returns an undefined value.

Retrieve a message from a queue using AMQP.Basic.Get

Parameters:

- queue (`String`) (defaults to: `nil`)
- autoAck (`true`, `false`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    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.

Parameters:

- deliveryTag (`Fixnum`) (defaults to: `nil`)
- multiple (`true`, `false`) (defaults to: `nil`)
- requeue (`true`, `false`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    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.

Parameters:

- exchange (`String`) (defaults to: `nil`)
- routingKey (`String`) (defaults to: `nil`)
- message (`Hash{String => Object}`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    97
    98
    99
    100
    101
    102
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 97

    def basic_publish(exchange=nil,routingKey=nil,message=nil)
      if exchange.class == String && routingKey.class == String && message.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(message),(Proc.new { |ar| yield(ar.failed ? ar.cause : nil) }))
      end
      raise ArgumentError, "Invalid arguments when calling basic_publish(#{exchange},#{routingKey},#{message})"
    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.

Parameters:

- prefetchCount (`Fixnum`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    108
    109
    110
    111
    112
    113
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 108

    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

### - (`true`, `false`) connected?

Check if a connection is open

Returns:

- (`true`, `false`) —
  true when the connection is open, false otherwise

Raises:

- (`ArgumentError`)

    250
    251
    252
    253
    254
    255
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 250

    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.

Parameters:

- destination (`String`) (defaults to: `nil`)
- source (`String`) (defaults to: `nil`)
- routingKey (`String`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    146
    147
    148
    149
    150
    151
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 146

    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.

Parameters:

- exchange (`String`) (defaults to: `nil`)
- type (`String`) (defaults to: `nil`)
- durable (`true`, `false`) (defaults to: `nil`)
- autoDelete (`true`, `false`) (defaults to: `nil`)
- config (`Hash{String => String}`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    122
    123
    124
    125
    126
    127
    128
    129
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 122

    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.

Parameters:

- exchange (`String`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    134
    135
    136
    137
    138
    139
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 134

    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.

Parameters:

- destination (`String`) (defaults to: `nil`)
- source (`String`) (defaults to: `nil`)
- routingKey (`String`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    158
    159
    160
    161
    162
    163
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 158

    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.

Parameters:

- queue (`String`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    224
    225
    226
    227
    228
    229
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 224

    def message_count(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?

Check if a channel is open

Returns:

- (`true`, `false`) —
  true when the connection is open, false otherwise

Raises:

- (`ArgumentError`)

    258
    259
    260
    261
    262
    263
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 258

    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

Parameters:

- queue (`String`) (defaults to: `nil`)
- exchange (`String`) (defaults to: `nil`)
- routingKey (`String`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    214
    215
    216
    217
    218
    219
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 214

    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) { ... }

This method returns an undefined value.

Declare a queue

Parameters:

- queue (`String`) (defaults to: `nil`)
- durable (`true`, `false`) (defaults to: `nil`)
- exclusive (`true`, `false`) (defaults to: `nil`)
- autoDelete (`true`, `false`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    180
    181
    182
    183
    184
    185
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 180

    def queue_declare(queue=nil,durable=nil,exclusive=nil,autoDelete=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?
        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) }))
      end
      raise ArgumentError, "Invalid arguments when calling queue_declare(#{queue},#{durable},#{exclusive},#{autoDelete})"
    end

### - (`void`) queue_declare_auto { ... }

This method returns an undefined value.

Actively declare a server-named exclusive, autodelete, non-durable queue.

Yields:

Raises:

- (`ArgumentError`)

    167
    168
    169
    170
    171
    172
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 167

    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

Parameters:

- queue (`String`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    190
    191
    192
    193
    194
    195
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 190

    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

Parameters:

- queue (`String`) (defaults to: `nil`)
- ifUnused (`true`, `false`) (defaults to: `nil`)
- ifEmpty (`true`, `false`) (defaults to: `nil`)

Yields:

Raises:

- (`ArgumentError`)

    202
    203
    204
    205
    206
    207
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 202

    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.

Yields:

Raises:

- (`ArgumentError`)

    233
    234
    235
    236
    237
    238
    # File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx-rabbitmq/rabbit_mq_client.rb', line 233

    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.

Yields:

Raises:

- (`ArgumentError`)

    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 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