public interface ProducerSupport extends Actor, CamelSupport
Modifier and Type | Interface and Description |
---|---|
private static class |
ProducerSupport.ProducerChild |
Actor.emptyBehavior$, Actor.ignoringBehavior$
Modifier and Type | Method and Description |
---|---|
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.
|
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.
|
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled
camel, camelContext
void preStart()
Actor
void register()
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 transformOutgoingMessage
. If oneway
is true
, an in-only message exchange is initiated, otherwise an in-out message exchange.
produce()
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)