class CamelMessage extends Serializable with Product

An immutable representation of a Camel message.

Annotations
@deprecated
Deprecated

(Since version 2.5.0) Akka Camel is deprecated in favour of 'Alpakka', the Akka Streams based collection of integrations to various endpoints (including Camel).

Source
CamelMessage.scala
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CamelMessage
  2. Product
  3. Equals
  4. Serializable
  5. Serializable
  6. AnyRef
  7. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new CamelMessage(body: Any, headers: Map[String, Any])
  2. new CamelMessage(body: Any, headers: Map[String, Any], attachments: Map[String, DataHandler])
  3. new CamelMessage(body: Any, headers: Map[String, Any])
  4. new CamelMessage(body: Any, headers: Map[String, Any], attachments: Map[String, DataHandler])

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. def +(other: String): String
    Implicit
    This member is added by an implicit conversion from CamelMessage to any2stringadd[CamelMessage] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (CamelMessage, B)
    Implicit
    This member is added by an implicit conversion from CamelMessage to ArrowAssoc[CamelMessage] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def attachments(names: Set[String]): Map[String, DataHandler]

    Returns those attachments from this message whose name is contained in names.

  8. val attachments: Map[String, DataHandler]
  9. val body: Any
  10. def bodyAs[T](implicit t: ClassTag[T], camelContext: CamelContext): T

    Returns the body of the message converted to the type T.

    Returns the body of the message converted to the type T. Conversion is done using Camel's type converter. The type converter is obtained from the CamelContext that is passed in. The CamelContext is accessible in a akka.camel.javaapi.UntypedConsumerActor and akka.camel.javaapi.UntypedProducerActor using the getCamelContext method, and is available on the akka.camel.CamelExtension.

  11. def canEqual(that: Any): Boolean

    Indicates if some other object can be compared (based on type).

    Indicates if some other object can be compared (based on type). This method should be called from every well-designed equals method that is open to be overridden in a subclass.

    Definition Classes
    CamelMessage → Equals
  12. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate() @throws( ... )
  13. def copy(body: Any = this.body, headers: Map[String, Any] = this.headers): CamelMessage
  14. def ensuring(cond: (CamelMessage) ⇒ Boolean, msg: ⇒ Any): CamelMessage
    Implicit
    This member is added by an implicit conversion from CamelMessage to Ensuring[CamelMessage] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  15. def ensuring(cond: (CamelMessage) ⇒ Boolean): CamelMessage
    Implicit
    This member is added by an implicit conversion from CamelMessage to Ensuring[CamelMessage] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  16. def ensuring(cond: Boolean, msg: ⇒ Any): CamelMessage
    Implicit
    This member is added by an implicit conversion from CamelMessage to Ensuring[CamelMessage] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  17. def ensuring(cond: Boolean): CamelMessage
    Implicit
    This member is added by an implicit conversion from CamelMessage to Ensuring[CamelMessage] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(that: Any): Boolean

    Indicates whether some other object is "equal to" this one.

    Indicates whether some other object is "equal to" this one.

    Definition Classes
    CamelMessage → Equals → AnyRef → Any
  20. def formatted(fmtstr: String): String
    Implicit
    This member is added by an implicit conversion from CamelMessage to StringFormat[CamelMessage] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  21. def getAttachments: Map[String, DataHandler]

    Java API: Returns all attachments from this message.

    Java API: Returns all attachments from this message. The returned attachments map is backed up by this message's immutable headers map. Any attempt to modify the returned map will throw an exception.

  22. def getAttachments(names: Set[String]): Map[String, DataHandler]

    Java API: Returns those attachments from this message whose name is contained in names.

    Java API: Returns those attachments from this message whose name is contained in names. The returned headers map is backed up by an immutable headers map. Any attempt to modify the returned map will throw an exception.

  23. def getBodyAs[T](clazz: Class[T], camelContext: CamelContext): T

    Java API: Returns the body of the message converted to the type as given by the clazz parameter.

    Java API: Returns the body of the message converted to the type as given by the clazz parameter. Conversion is done using Camel's type converter. The type converter is obtained from the CamelContext that is passed in.

    The CamelContext is accessible in a akka.camel.javaapi.UntypedConsumerActor and akka.camel.javaapi.UntypedProducerActor using the getCamelContext method, and is available on the akka.camel.CamelExtension.

  24. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  25. def getHeaderAs[T](name: String, clazz: Class[T], camelContext: CamelContext): T

    Java API: Returns the header by given name parameter.

    Java API: Returns the header by given name parameter. The header is converted to type T as defined by the clazz parameter. An exception is thrown when the conversion to the type T fails or when the header cannot be found.

    The CamelContext is accessible in a akka.camel.javaapi.UntypedConsumerActor and akka.camel.javaapi.UntypedProducerActor using the getCamelContext method, and is available on the akka.camel.CamelExtension.

  26. def getHeaders: Map[String, Any]

    Java API: Returns all headers from this message.

    Java API: Returns all headers from this message. The returned headers map is backed up by this message's immutable headers map. Any attempt to modify the returned map will throw an exception.

  27. def getHeaders(names: Set[String]): Map[String, Any]

    Java API: Returns those headers from this message whose name is contained in names.

    Java API: Returns those headers from this message whose name is contained in names. The returned headers map is backed up by an immutable headers map. Any attempt to modify the returned map will throw an exception.

  28. def hashCode(): Int

    Returns a hash code value for the object.

    Returns a hash code value for the object.

    Definition Classes
    CamelMessage → AnyRef → Any
  29. def headerAs[T](name: String)(implicit t: ClassTag[T], camelContext: CamelContext): Try[T]

    Returns the header by given name parameter in a scala.util.Try.

    Returns the header by given name parameter in a scala.util.Try. The header is converted to type T, which is returned in a scala.util.Success. If an exception occurs during the conversion to the type T or when the header cannot be found, the exception is returned in a scala.util.Failure.

    The CamelContext is accessible in a akka.camel.javaapi.UntypedConsumerActor and akka.camel.javaapi.UntypedProducerActor using the getCamelContext method, and is available on the akka.camel.CamelExtension.

  30. def headers(names: Set[String]): Map[String, Any]

    Returns those headers from this message whose name is contained in names.

  31. val headers: Map[String, Any]
  32. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  33. def mapBody[A, B](transformer: Mapper[A, B]): CamelMessage

    Java API: Returns a new CamelMessage with a transformed body using a transformer function.

    Java API: Returns a new CamelMessage with a transformed body using a transformer function. This method will throw a java.lang.ClassCastException if the body cannot be mapped to type A.

  34. def mapBody[A, B](transformer: (A) ⇒ B): CamelMessage

    Returns a new CamelMessage with a transformed body using a transformer function.

    Returns a new CamelMessage with a transformed body using a transformer function. This method will throw a java.lang.ClassCastException if the body cannot be mapped to type A.

  35. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  36. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  37. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  38. def productArity: Int

    Returns the size of this product.

    Returns the size of this product.

    Definition Classes
    CamelMessage → Product
  39. def productElement(n: Int): Any

    Returns the n-th element of this product, 0-based.

    Returns the n-th element of this product, 0-based.

    Definition Classes
    CamelMessage → Product
  40. def productIterator: Iterator[Any]
    Definition Classes
    Product
  41. def productPrefix: String
    Definition Classes
    Product
  42. def resetStreamCache(): Unit

    Reset StreamCache body.

    Reset StreamCache body. Nothing is done if the body is not a StreamCache. See http://camel.apache.org/stream-caching.html

  43. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  44. def toString(): String
    Definition Classes
    CamelMessage → AnyRef → Any
  45. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  46. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  47. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  48. def withAttachments(attachments: Map[String, DataHandler]): CamelMessage

    SCALA API: Creates a new CamelMessage with given attachments.

  49. def withAttachments(attachments: Map[String, DataHandler]): CamelMessage

    Java API: Creates a new CamelMessage with given attachments.

    Java API: Creates a new CamelMessage with given attachments. A copy of the attachments map is made.

  50. def withBody[T](body: T): CamelMessage

    Java API: Returns a new CamelMessage with a new body, while keeping the same headers.

  51. def withBodyAs[T](clazz: Class[T])(implicit camelContext: CamelContext): CamelMessage

    Java API: Creates a CamelMessage with current body converted to type clazz.

    Java API: Creates a CamelMessage with current body converted to type clazz.

    The CamelContext is accessible in a akka.camel.javaapi.UntypedConsumerActor and akka.camel.javaapi.UntypedProducerActor using the getCamelContext method, and is available on the akka.camel.CamelExtension.

  52. def withBodyAs[T](implicit t: ClassTag[T], camelContext: CamelContext): CamelMessage

    Creates a CamelMessage with current body converted to type T.

    Creates a CamelMessage with current body converted to type T. The CamelContext is accessible in a akka.camel.javaapi.UntypedConsumerActor and akka.camel.javaapi.UntypedProducerActor using the getCamelContext method, and is available on the akka.camel.CamelExtension.

  53. def withHeaders[A](headers: Map[String, A]): CamelMessage

    Java API: Creates a new CamelMessage with given headers.

    Java API: Creates a new CamelMessage with given headers. A copy of the headers map is made.

  54. def [B](y: B): (CamelMessage, B)
    Implicit
    This member is added by an implicit conversion from CamelMessage to ArrowAssoc[CamelMessage] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from Product

Inherited from Equals

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from CamelMessage to any2stringadd[CamelMessage]

Inherited by implicit conversion StringFormat from CamelMessage to StringFormat[CamelMessage]

Inherited by implicit conversion Ensuring from CamelMessage to Ensuring[CamelMessage]

Inherited by implicit conversion ArrowAssoc from CamelMessage to ArrowAssoc[CamelMessage]

Ungrouped