|
|||||||||
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 | |
---|---|
Camel |
camel()
INTERNAL API Returns a Camel trait which provides access to the CamelExtension. |
org.apache.camel.impl.DefaultCamelContext |
camelContext()
Returns the CamelContext. |
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 |
---|
context, noSender, postRestart, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled |
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.
public java.lang.Object onTransformResponse(java.lang.Object message)
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).
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
public final java.lang.Object transformResponse(java.lang.Object msg)
ProducerSupport
transformResponse
in interface ProducerSupport
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
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
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.
public Camel camel()
Camel
trait which provides access to the CamelExtension.
public org.apache.camel.impl.DefaultCamelContext camelContext()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |