class CamelMessage extends Serializable with Product

An immutable representation of a Camel message.

Source
CamelMessage.scala
Linear Supertypes
Product, Equals, Serializable, Serializable, AnyRef, Any
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. def attachments(names: Set[String]): Map[String, DataHandler]

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

  2. val attachments: Map[String, DataHandler]
  3. val body: Any
  4. 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.

  5. 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
  6. def copy(body: Any = this.body, headers: Map[String, Any] = this.headers): CamelMessage
  7. 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
  8. 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.

  9. 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.

  10. 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.

  11. 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.

  12. 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.

  13. 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.

  14. def hashCode(): Int

    Returns a hash code value for the object.

    Returns a hash code value for the object.

    Definition Classes
    CamelMessage → AnyRef → Any
  15. 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.

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

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

  17. val headers: Map[String, Any]
  18. 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.

  19. 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.

  20. def productArity: Int

    Returns the size of this product.

    Returns the size of this product.

    Definition Classes
    CamelMessage → Product
  21. 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
  22. def productIterator: Iterator[Any]
    Definition Classes
    Product
  23. def productPrefix: String
    Definition Classes
    Product
  24. 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

  25. def toString(): String
    Definition Classes
    CamelMessage → AnyRef → Any
  26. def withAttachments(attachments: Map[String, DataHandler]): CamelMessage

    SCALA API: Creates a new CamelMessage with given attachments.

  27. 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.

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

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

  29. 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.

  30. 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.

  31. 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.