|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.camel.CamelMessage
public class CamelMessage
An immutable representation of a Camel message.
Constructor Summary | |
---|---|
CamelMessage(java.lang.Object body,
scala.collection.immutable.Map<java.lang.String,java.lang.Object> headers)
|
|
CamelMessage(java.lang.Object body,
java.util.Map<java.lang.String,java.lang.Object> headers)
|
Method Summary | ||
---|---|---|
java.lang.Object |
body()
|
|
|
bodyAs(scala.reflect.ClassTag<T> t,
org.apache.camel.CamelContext camelContext)
Returns the body of the message converted to the type T . |
|
|
getBodyAs(java.lang.Class<T> clazz,
org.apache.camel.CamelContext camelContext)
Java API: Returns the body of the message converted to the type as given by the clazz
parameter. |
|
|
getHeaderAs(java.lang.String name,
java.lang.Class<T> clazz,
org.apache.camel.CamelContext camelContext)
Java API: Returns the header by given name parameter. |
|
java.util.Map<java.lang.String,java.lang.Object> |
getHeaders()
Java API: Returns all headers from this message. |
|
java.util.Map<java.lang.String,java.lang.Object> |
getHeaders(java.util.Set<java.lang.String> names)
Java API: Returns those headers from this message whose name is contained in names . |
|
|
headerAs(java.lang.String name,
scala.reflect.ClassTag<T> t,
org.apache.camel.CamelContext camelContext)
Returns the header by given name parameter in a Try . |
|
scala.collection.immutable.Map<java.lang.String,java.lang.Object> |
headers()
|
|
scala.collection.immutable.Map<java.lang.String,java.lang.Object> |
headers(scala.collection.immutable.Set<java.lang.String> names)
Returns those headers from this message whose name is contained in names . |
|
|
mapBody(scala.Function1<A,B> transformer)
Returns a new CamelMessage with a transformed body using a transformer function. |
|
|
mapBody(Mapper<A,B> transformer)
Java API: Returns a new CamelMessage with a transformed body using a transformer function. |
|
static java.lang.String |
MessageExchangeId()
CamelMessage header to correlate request with response messages. |
|
void |
resetStreamCache()
Reset StreamCache body. |
|
java.lang.String |
toString()
|
|
|
withBody(T body)
Java API: Returns a new CamelMessage with a new body, while keeping the same headers. |
|
|
withBodyAs(java.lang.Class<T> clazz,
org.apache.camel.CamelContext camelContext)
Java API: Creates a CamelMessage with current body converted to type clazz . |
|
|
withBodyAs(scala.reflect.ClassTag<T> t,
org.apache.camel.CamelContext camelContext)
Creates a CamelMessage with current body converted to type T . |
|
|
withHeaders(java.util.Map<java.lang.String,A> headers)
Java API: Creates a new CamelMessage with given headers . |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface scala.Product |
---|
productArity, productElement, productIterator, productPrefix |
Methods inherited from interface scala.Equals |
---|
canEqual, equals |
Constructor Detail |
---|
public CamelMessage(java.lang.Object body, scala.collection.immutable.Map<java.lang.String,java.lang.Object> headers)
public CamelMessage(java.lang.Object body, java.util.Map<java.lang.String,java.lang.Object> headers)
Method Detail |
---|
public static java.lang.String MessageExchangeId()
public java.lang.Object body()
public scala.collection.immutable.Map<java.lang.String,java.lang.Object> headers()
public java.lang.String toString()
toString
in class java.lang.Object
public scala.collection.immutable.Map<java.lang.String,java.lang.Object> headers(scala.collection.immutable.Set<java.lang.String> names)
names
.
public java.util.Map<java.lang.String,java.lang.Object> getHeaders(java.util.Set<java.lang.String> names)
names
.
The returned headers map is backed up by an immutable headers map. Any attempt to modify
the returned map will throw an exception.
public java.util.Map<java.lang.String,java.lang.Object> getHeaders()
public <A> CamelMessage withHeaders(java.util.Map<java.lang.String,A> headers)
headers
. A copy of the headers map is made.
public <T> scala.util.Try<T> headerAs(java.lang.String name, scala.reflect.ClassTag<T> t, org.apache.camel.CamelContext camelContext)
name
parameter in a Try
. The header is converted to type T
, which is returned
in a 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 Failure
.
The CamelContext is accessible in a UntypedConsumerActor
and UntypedProducerActor
using the getCamelContext
method, and is available on the CamelExtension
.
public <T> T getHeaderAs(java.lang.String name, java.lang.Class<T> clazz, org.apache.camel.CamelContext camelContext)
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 UntypedConsumerActor
and UntypedProducerActor
using the getCamelContext
method, and is available on the CamelExtension
.
public <A,B> CamelMessage mapBody(scala.Function1<A,B> transformer)
transformer
function.
This method will throw a ClassCastException
if the body cannot be mapped to type A.
public <A,B> CamelMessage mapBody(Mapper<A,B> transformer)
transformer
function.
This method will throw a ClassCastException
if the body cannot be mapped to type A.
public <T> T bodyAs(scala.reflect.ClassTag<T> t, org.apache.camel.CamelContext camelContext)
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 UntypedConsumerActor
and UntypedProducerActor
using the getCamelContext
method, and is available on the CamelExtension
.
public <T> T getBodyAs(java.lang.Class<T> clazz, org.apache.camel.CamelContext camelContext)
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 UntypedConsumerActor
and UntypedProducerActor
using the getCamelContext
method, and is available on the CamelExtension
.
public void resetStreamCache()
public <T> CamelMessage withBody(T body)
public <T> CamelMessage withBodyAs(scala.reflect.ClassTag<T> t, org.apache.camel.CamelContext camelContext)
body
converted to type T
.
The CamelContext is accessible in a UntypedConsumerActor
and UntypedProducerActor
using the getCamelContext
method, and is available on the CamelExtension
.
public <T> CamelMessage withBodyAs(java.lang.Class<T> clazz, org.apache.camel.CamelContext camelContext)
body
converted to type clazz
.
The CamelContext is accessible in a UntypedConsumerActor
and UntypedProducerActor
using the getCamelContext
method, and is available on the CamelExtension
.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |