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( ... )