io.vertx.rxjava.amqpbridge

## Class AmqpBridge

- java.lang.Object
- - io.vertx.rxjava.amqpbridge.AmqpBridge

-     public class AmqpBridge
      extends Object

  Vert.x AMQP Bridge. Facilitates sending and receiving AMQP 1.0 messages.

  NOTE: This class has been automatically generated from the `original` non RX-ified interface using Vert.x codegen.

- - ### Constructor Summary

    Constructors
    Constructor and Description
    `AmqpBridge(AmqpBridge delegate)`

  - ### Method Summary

    All Methods Static Methods Instance Methods Concrete Methods
    Modifier and Type | Method and Description
    --- | ---
    `void` | `close(Handler<AsyncResult<Void>> resultHandler)` Shuts the bridge down, closing the underlying connection.
    `Observable<Void>` | `closeObservable()` Shuts the bridge down, closing the underlying connection.
    `static AmqpBridge` | `create(Vertx vertx)` Creates a Bridge.
    `static AmqpBridge` | `create(Vertx vertx, AmqpBridgeOptions options)` Creates a Bridge with the given options.
    `<T> MessageConsumer<T>` | `createConsumer(String amqpAddress)` Creates a consumer on the given AMQP address.
    `<T> MessageProducer<T>` | `createProducer(String amqpAddress)` Creates a producer to the given AMQP address.
    `Object` | `getDelegate()`
    `static AmqpBridge` | `newInstance(AmqpBridge arg)`
    `void` | `start(String hostname, int port, Handler<AsyncResult<AmqpBridge>> resultHandler)` Starts the bridge, establishing the underlying connection.
    `void` | `start(String hostname, int port, String username, String password, Handler<AsyncResult<AmqpBridge>> resultHandler)` Starts the bridge, establishing the underlying connection.
    `Observable<AmqpBridge>` | `startObservable(String hostname, int port)` Starts the bridge, establishing the underlying connection.
    `Observable<AmqpBridge>` | `startObservable(String hostname, int port, String username, String password)` Starts the bridge, establishing the underlying connection.

    - ### Methods inherited from class java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- - ### Constructor Detail

    - #### AmqpBridge

          public AmqpBridge(AmqpBridge delegate)

  - ### Method Detail

    - #### getDelegate

          public Object getDelegate()

    - #### create

          public static AmqpBridge create(Vertx vertx)

      Creates a Bridge.
      Parameters:
        `vertx` - the vertx instance to use
      Returns:
        the (not-yet-started) bridge.

    - #### create

          public static AmqpBridge create(Vertx vertx,
                                          AmqpBridgeOptions options)

      Creates a Bridge with the given options.
      Parameters:
        `vertx` - the vertx instance to use
        `options` - the options
      Returns:
        the (not-yet-started) bridge.

    - #### start

          public void start(String hostname,
                            int port,
                            String username,
                            String password,
                            Handler<AsyncResult<AmqpBridge>> resultHandler)

      Starts the bridge, establishing the underlying connection.
      Parameters:
        `hostname` - the host name to connect to
        `port` - the port to connect to
        `username` - the username
        `password` - the password
        `resultHandler` - the result handler

    - #### startObservable

          public Observable<AmqpBridge> startObservable(String hostname,
                                                        int port,
                                                        String username,
                                                        String password)

      Starts the bridge, establishing the underlying connection.
      Parameters:
        `hostname` - the host name to connect to
        `port` - the port to connect to
        `username` - the username
        `password` - the password
      Returns:

    - #### start

          public void start(String hostname,
                            int port,
                            Handler<AsyncResult<AmqpBridge>> resultHandler)

      Starts the bridge, establishing the underlying connection.
      Parameters:
        `hostname` - the host name to connect to
        `port` - the port to connect to
        `resultHandler` - the result handler

    - #### startObservable

          public Observable<AmqpBridge> startObservable(String hostname,
                                                        int port)

      Starts the bridge, establishing the underlying connection.
      Parameters:
        `hostname` - the host name to connect to
        `port` - the port to connect to
      Returns:

    - #### createConsumer

          public <T> MessageConsumer<T> createConsumer(String amqpAddress)

      Creates a consumer on the given AMQP address. This method MUST be called from the bridge Context thread, as used in the result handler callback from the start methods. The bridge MUST be successfully started before the method is called.
      Parameters:
        `amqpAddress` - the address to consume from
      Returns:
        the consumer

    - #### createProducer

          public <T> MessageProducer<T> createProducer(String amqpAddress)

      Creates a producer to the given AMQP address. This method MUST be called from the bridge Context thread, as used in the result handler callback from the start methods. The bridge MUST be successfully started before the method is called.
      Parameters:
        `amqpAddress` - the address to produce to
      Returns:
        the producer

    - #### close

          public void close(Handler<AsyncResult<Void>> resultHandler)

      Shuts the bridge down, closing the underlying connection.
      Parameters:
        `resultHandler` - the result handler

    - #### closeObservable

          public Observable<Void> closeObservable()

      Shuts the bridge down, closing the underlying connection.
      Returns:

    - #### newInstance

          public static AmqpBridge newInstance(AmqpBridge arg)

Copyright © 2016. All rights reserved.