case class StreamMessage[A](body: A, headers: Map[String, Any] = Map.empty) extends Product with Serializable
A message received from or sent to a Camel endpoint.
- body
Message body.
- headers
Message headers.
- Alphabetic
- By Inheritance
- StreamMessage
- Serializable
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
StreamMessage(body: A, headers: Map[String, Any] = Map.empty)
- body
Message body.
- headers
Message headers.
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
- val body: A
-
def
bodyAs[B](implicit streamContext: StreamContext, tag: ClassTag[B]): B
Returns the
body
converted to typeB
using a Camel type converter.Returns the
body
converted to typeB
using a Camel type converter.- Exceptions thrown
org.apache.camel.TypeConversionException
if type conversion fails.
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
getBody: A
Java API.
Java API.
Returns the message body.
-
def
getBodyAs[B](streamContext: StreamContext, clazz: Class[B]): B
Java API.
Java API.
Returns the
body
converted to typeB
using a Camel type converter.- Exceptions thrown
org.apache.camel.TypeConversionException
if type conversion fails.
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
getHeaderAs[B](name: String, streamContext: StreamContext, clazz: Class[B]): B
Java API.
Java API.
Returns the
name
header value converted to typeB
using a Camel type converter.- Exceptions thrown
NoSuchElementException
if thename
header does not exist.org.apache.camel.TypeConversionException
if type conversion fails.
-
def
getHeaderOptionAs[B](name: String, streamContext: StreamContext, clazz: Class[B]): Optional[B]
Java API.
Java API.
Returns the
name
header value converted to typeB
using a Camel type converter if thename
header is defined.- Exceptions thrown
org.apache.camel.TypeConversionException
if type conversion fails.
-
def
getHeaders: Map[String, Any]
Java API.
Java API.
Returns the message headers.
-
def
headerAs[B](name: String)(implicit streamContext: StreamContext, tag: ClassTag[B]): B
Returns the
name
header value converted to typeB
using a Camel type converter.Returns the
name
header value converted to typeB
using a Camel type converter.- Exceptions thrown
NoSuchElementException
if thename
header does not exist.org.apache.camel.TypeConversionException
if type conversion fails.
-
def
headerOptionAs[B](name: String)(implicit streamContext: StreamContext, tag: ClassTag[B]): Option[B]
Returns the
name
header value converted to typeB
using a Camel type converter if thename
header is defined.Returns the
name
header value converted to typeB
using a Camel type converter if thename
header is defined.- Exceptions thrown
org.apache.camel.TypeConversionException
if type conversion fails.
- val headers: Map[String, Any]
-
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()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.