public abstract class UntypedProducerActor extends akka.actor.UntypedActor implements ProducerSupport
Constructor and Description |
---|
UntypedProducerActor() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
endpointUri()
Returns the Camel endpoint URI to produce messages to.
|
Activation |
getActivation()
''Java API'': Returns the
Activation interface
that can be used to wait on activation or de-activation of Camel endpoints. |
org.apache.camel.impl.DefaultCamelContext |
getCamelContext()
Returns the
CamelContext . |
abstract java.lang.String |
getEndpointUri()
Returns the Camel endpoint URI to produce messages to.
|
org.apache.camel.ProducerTemplate |
getProducerTemplate()
Returns the
ProducerTemplate . |
boolean |
isOneway()
If set to false (default), this producer expects a response message from the Camel endpoint.
|
boolean |
oneway()
If set to false (default), this producer expects a response message from the Camel endpoint.
|
void |
onReceive(java.lang.Object message)
Default implementation of UntypedActor.onReceive
|
void |
onRouteResponse(java.lang.Object message)
Called after a response was received from the endpoint specified by
endpointUri . |
java.lang.Object |
onTransformOutgoingMessage(java.lang.Object message)
Called before the message is sent to the endpoint specified by
getEndpointUri . |
java.lang.Object |
onTransformResponse(java.lang.Object message)
Called before the response message is sent to original sender.
|
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.
|
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
headersToCopy, headersToCopyDefault, preStart, produce, register
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled
camel, camelContext
public java.lang.Object onTransformOutgoingMessage(java.lang.Object message)
getEndpointUri
. The original
message is passed as argument. By default, this method simply returns the argument but may be overridden
by subclasses.message
- (undocumented)public java.lang.Object onTransformResponse(java.lang.Object message)
message
- (undocumented)public void onRouteResponse(java.lang.Object message)
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 subclasses (e.g. to forward responses to another actor).message
- (undocumented)public final java.lang.Object transformOutgoingMessage(java.lang.Object msg)
ProducerSupport
endpointUri
. The original
message is passed as argument. By default, this method simply returns the argument but may be overridden
by subtraits or subclasses.transformOutgoingMessage
in interface ProducerSupport
msg
- (undocumented)public final java.lang.Object transformResponse(java.lang.Object msg)
ProducerSupport
transformResponse
in interface ProducerSupport
msg
- (undocumented)public final void routeResponse(java.lang.Object msg)
ProducerSupport
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).routeResponse
in interface ProducerSupport
msg
- (undocumented)public final java.lang.String endpointUri()
ProducerSupport
endpointUri
in interface ProducerSupport
public final boolean oneway()
ProducerSupport
oneway
in interface ProducerSupport
public final void onReceive(java.lang.Object message)
onReceive
in class akka.actor.UntypedActor
message
- (undocumented)public abstract java.lang.String getEndpointUri()
public boolean isOneway()
public org.apache.camel.impl.DefaultCamelContext getCamelContext()
CamelContext
.public org.apache.camel.ProducerTemplate getProducerTemplate()
ProducerTemplate
.public Activation getActivation()
Activation
interface
that can be used to wait on activation or de-activation of Camel endpoints.