org.vertx.scala.core.eventbus

Message

final class Message[T] extends AnyRef

Represents a message on the event bus.

Instances of this class are not thread-safe

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Message
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. def address(): String

    The address the message was sent to

  7. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  8. val asJava: java.core.eventbus.Message[T]

  9. def body(): T

    The body of the message.

  10. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  11. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  13. def fail(failureCode: Int, message: String): Unit

    Signal that processing of this message failed.

    Signal that processing of this message failed. If the message was sent specifying a result handler the handler will be called with a failure corresponding to the failure code and message specified here

    failureCode

    A failure code to pass back to the sender

    message

    A message to pass back to the sender

  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
  16. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  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
  20. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  21. def reply[B](handler: (Message[B]) ⇒ Unit)(implicit arg0: (B) ⇒ MessageData): Unit

    The same as reply() but you can specify handler for the reply - i.

    The same as reply() but you can specify handler for the reply - i.e. to receive the reply to the reply.

    handler

    Handling the reply.

  22. def reply[B](value: MessageData, handler: (Message[B]) ⇒ Unit)(implicit arg0: (B) ⇒ MessageData): Unit

    The same as org.vertx.scala.core.eventbus.Message.reply(MessageData) but you can specify handler for the reply - i.

    The same as org.vertx.scala.core.eventbus.Message.reply(MessageData) but you can specify handler for the reply - i.e. to receive the reply to the reply.

    value

    The value to send.

    handler

    Handling the reply.

  23. def reply(value: MessageData): Unit

    Reply to this message.

    Reply to this message. If the message was sent specifying a reply handler, that handler will be called when it has received a reply. If the message wasn't sent specifying a receipt handler this method does nothing.

    value

    The data to send with the reply.

  24. def reply(): Unit

    Reply to this message.

    Reply to this message. If the message was sent specifying a reply handler, that handler will be called when it has received a reply. If the message wasn't sent specifying a receipt handler this method does nothing.

  25. def replyAddress(): Option[String]

    The reply address (if any).

    The reply address (if any).

    returns

    An optional String containing the reply address.

  26. def replyWithTimeout[T](value: MessageData, timeout: Long, replyHandler: (AsyncResult[Message[T]]) ⇒ Unit)(implicit arg0: (T) ⇒ MessageData): Unit

    Reply to this message with data.

    Reply to this message with data. Specifying a timeout and a reply handler.

    value

    The value to send.

    timeout

    The timeout in ms to wait for an answer.

    replyHandler

    Handling the reply (success) or the timeout (failed).

  27. def replyWithTimeout[T](timeout: Long, replyHandler: (AsyncResult[Message[T]]) ⇒ Unit)(implicit arg0: (T) ⇒ MessageData): Unit

    Reply to this message.

    Reply to this message. Specifying a timeout and a reply handler.

    timeout

    The timeout in ms to wait for an answer.

    replyHandler

    Handling the reply (success) or the timeout (failed).

  28. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  29. def toString(): String

    Definition Classes
    AnyRef → Any
  30. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  31. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped