vertx-lang-scala-docs_2.12 3.6.1 API < Back
 

# Packages

-  package root
  Definition Classes
    root
-  package io
  Definition Classes
    root
-  package vertx
  Definition Classes
    io
-  package scala
  Definition Classes
    vertx
-  package amqpbridge
  Definition Classes
    scala
- AmqpBridge
- AmqpBridgeOptions

c

io.vertx.scala.amqpbridge

# AmqpBridge 

###
Companion object AmqpBridge

#### class AmqpBridge extends AnyRef

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

Linear Supertypes
AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. AmqpBridge
2. AnyRef
3. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new AmqpBridge(_asJava: AnyRef)

### Value Members

1.  final def !=(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
2.  final def ##(): Int
   Definition Classes
     AnyRef → Any
3.  final def ==(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
4.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
5.  def asJava: AnyRef
6.  def clone(): AnyRef
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @native() @throws( ... )
7.  def close(resultHandler: Handler[AsyncResult[Unit]]): Unit

   Shuts the bridge down, closing the underlying connection.

   Shuts the bridge down, closing the underlying connection. * @param resultHandler the result handler

8.  def closeFuture(): Future[Unit]

   Like close but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

9.  def createConsumer[T](amqpAddress: String)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T]): MessageConsumer[T]

   Creates a consumer on the given AMQP address.

   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. * @param amqpAddress the address to consume from

   returns

     the consumer

10.  def createProducer[T](amqpAddress: String)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T]): MessageProducer[T]

    Creates a producer to the given AMQP address.

    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. * @param amqpAddress the address to produce to

    returns

      the producer

11.  def endHandler(endHandler: Handler[Unit]): Unit

    Set an end handler.

    Set an end handler. This will fire if the underlying connection is unexpectedly disconnected or remotely closed. * @param endHandler the handler

12.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
13.  def equals(arg0: Any): Boolean
    Definition Classes
      AnyRef → Any
14.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
15.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
16.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
17.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
18.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
19.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
20.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
21.  def start(hostname: String, port: Int, resultHandler: Handler[AsyncResult[AmqpBridge]]): Unit

    Starts the bridge, establishing the underlying connection.

    Starts the bridge, establishing the underlying connection. * @param hostname the host name to connect to

    port

      the port to connect to

    resultHandler

      the result handler

22.  def start(hostname: String, port: Int, username: String, password: String, resultHandler: Handler[AsyncResult[AmqpBridge]]): Unit

    Starts the bridge, establishing the underlying connection.

    Starts the bridge, establishing the underlying connection. * @param hostname the host name to connect to

    port

      the port to connect to

    username

      the username

    password

      the password

    resultHandler

      the result handler

23.  def startFuture(hostname: String, port: Int): Future[AmqpBridge]

    Like start but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

24.  def startFuture(hostname: String, port: Int, username: String, password: String): Future[AmqpBridge]

    Like start but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

25.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
26.  def toString(): String
    Definition Classes
      AnyRef → Any
27.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
28.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
29.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )

### Inherited from AnyRef

### Inherited from Any

### Ungrouped