|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.actor.UntypedActor akka.camel.javaapi.UntypedProducerActor
public abstract class UntypedProducerActor
Subclass this abstract class to create an untyped producer actor. This class is meant to be used from Java.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface akka.actor.Actor |
---|
Actor.emptyBehavior$ |
Constructor Summary | |
---|---|
UntypedProducerActor()
|
Method Summary | |
---|---|
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. |
Methods inherited from class akka.actor.UntypedActor |
---|
getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, supervisorStrategy, unhandled |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.camel.ProducerSupport |
---|
headersToCopy, headersToCopyDefault, preStart, produce, register |
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 |
Constructor Detail |
---|
public UntypedProducerActor()
Method Detail |
---|
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 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.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |