|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ProducerSupport
Support trait for producing messages to Camel endpoints.
Nested Class Summary | |
---|---|
private static class |
ProducerSupport.ProducerChild
|
Nested classes/interfaces inherited from interface akka.actor.Actor |
---|
Actor.emptyBehavior$ |
Method Summary | |
---|---|
java.lang.String |
endpointUri()
Returns the Camel endpoint URI to produce messages to. |
scala.collection.immutable.Set<java.lang.String> |
headersToCopy()
Returns the names of message headers to copy from a request message to a response message. |
scala.collection.immutable.Set<java.lang.String> |
headersToCopyDefault()
CamelMessage headers to copy by default from request message to response-message. |
boolean |
oneway()
If set to false (default), this producer expects a response message from the Camel endpoint. |
void |
preStart()
User overridable callback. |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
produce()
Produces msg to the endpoint specified by endpointUri . |
void |
register()
|
void |
routeResponse(java.lang.Object msg)
Called after a response was received from the endpoint specified by endpointUri . |
java.lang.Object |
transformOutgoingMessage(java.lang.Object msg)
Called before the message is sent to the endpoint specified by endpointUri . |
java.lang.Object |
transformResponse(java.lang.Object msg)
Called before the response message is sent to the original sender. |
Methods inherited from interface akka.actor.Actor |
---|
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled |
Methods inherited from interface akka.camel.CamelSupport |
---|
camel, camelContext |
Method Detail |
---|
void preStart()
Actor
preStart
in interface Actor
void register()
scala.collection.immutable.Set<java.lang.String> headersToCopyDefault()
boolean oneway()
java.lang.String endpointUri()
scala.collection.immutable.Set<java.lang.String> headersToCopy()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> produce()
msg
to the endpoint specified by endpointUri
. Before the message is
actually sent it is pre-processed by calling receiveBeforeProduce
. If oneway
is true
, an in-only message exchange is initiated, otherwise an in-out message exchange.
Producer#produce(Any, ExchangePattern)
java.lang.Object transformOutgoingMessage(java.lang.Object msg)
endpointUri
. The original
message is passed as argument. By default, this method simply returns the argument but may be overridden
by subtraits or subclasses.
msg
- (undocumented)
java.lang.Object transformResponse(java.lang.Object msg)
msg
- (undocumented)
void routeResponse(java.lang.Object msg)
endpointUri
. The
response is passed as argument. By default, this method sends the response back to the original sender
if oneway
is false
. If oneway
is true
, nothing is
done. This method may be overridden by subtraits or subclasses (e.g. to forward responses to another
actor).
msg
- (undocumented)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |