final case class Message[T](header: Header, content: T, parent_header: Option[Header] = None, idents: List[Seq[Byte]] = Nil, metadata: RawJson = RawJson.emptyObj) extends Product with Serializable
Fully-decoded message, with content of type T
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- Message
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new Message(header: Header, content: T, parent_header: Option[Header] = None, idents: List[Seq[Byte]] = Nil, metadata: RawJson = RawJson.emptyObj)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asRawMessage(implicit encoder: JsonValueCodec[T]): channels.Message
Encodes this Message as a RawMessage.
- def clearMetadata: Message[T]
- def clearParentHeader: Message[T]
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- val content: T
- def decodeAs[U](implicit ev: =:=[T, RawJson], decoder: JsonValueCodec[U]): Either[Throwable, Message[U]]
- def enqueueOn(channel: Channel, queue: Queue[IO, (Channel, channels.Message)])(implicit encoder: JsonValueCodec[T]): IO[Unit]
- def enqueueOn0(channel: Channel, queue: Queue[IO, Either[Throwable, (Channel, channels.Message)]])(implicit encoder: JsonValueCodec[T]): IO[Unit]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- val header: Header
- val idents: List[Seq[Byte]]
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def messageType: MessageType[T]
- val metadata: RawJson
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def on(channel: Channel)(implicit encoder: JsonValueCodec[T]): (Channel, channels.Message)
- val parent_header: Option[Header]
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def publish[U](messageType: MessageType[U], content: U, metadata: RawJson = RawJson.emptyObj, ident: Option[String] = None): Message[U]
Creates a response Message to this Message, to be sent on the Channel.Publish channel.
- def reply[U](messageType: MessageType[U], content: U, metadata: RawJson = RawJson.emptyObj): Message[U]
Creates a response Message to this Message, to be sent on the Channel.Requests channel.
- def streamOn[F[_]](channel: Channel)(implicit encoder: JsonValueCodec[T]): Stream[F, (Channel, channels.Message)]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def update[U](msgType: MessageType[U], newContent: U): Message[U]
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()