object ProtocolMessage extends Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ProtocolMessage
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- trait ProtocolMessageContentCast[A <: ProtocolMessage] extends AnyRef
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 clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def filterDomainsEnvelopes[M <: ProtocolMessage](batch: Batch[OpenEnvelope[M]], domainId: DomainId, onWrongDomain: (List[OpenEnvelope[M]]) => Unit): List[OpenEnvelope[M]]
Returns the envelopes from the batch that match the given domain ID.
Returns the envelopes from the batch that match the given domain ID. If any other messages exist, it gives them to the provided callback
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def select[M <: ProtocolMessage](envelope: DefaultOpenEnvelope)(implicit cast: ProtocolMessageContentCast[M]): Option[OpenEnvelope[M]]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toKind[M <: ProtocolMessage](envelope: DefaultOpenEnvelope)(implicit cast: ProtocolMessageContentCast[M]): Option[M]
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- object ProtocolMessageContentCast