public private static class ProducerSupport.ProducerChild
extends java.lang.Object
implements akka.actor.Actor
Constructor and Description |
---|
ProducerChild(org.apache.camel.Endpoint endpoint,
org.apache.camel.processor.SendProcessor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
produce(org.apache.camel.Endpoint endpoint,
org.apache.camel.processor.SendProcessor processor,
java.lang.Object msg,
org.apache.camel.ExchangePattern pattern)
Initiates a message exchange of given
pattern with the endpoint specified by
endpointUri . |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
public ProducerChild(org.apache.camel.Endpoint endpoint, org.apache.camel.processor.SendProcessor processor)
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
protected void produce(org.apache.camel.Endpoint endpoint, org.apache.camel.processor.SendProcessor processor, java.lang.Object msg, org.apache.camel.ExchangePattern pattern)
pattern
with the endpoint specified by
endpointUri
. The in-message of the initiated exchange is the canonical form
of msg
. After sending the in-message, the processing result (response) is passed
as argument to receiveAfterProduce
. If the response is received synchronously from
the endpoint then receiveAfterProduce
is called synchronously as well. If the
response is received asynchronously, the receiveAfterProduce
is called
asynchronously. The original sender is preserved.
endpoint
- the endpointprocessor
- the processormsg
- message to producepattern
- exchange patternCamelMessage.canonicalize(java.lang.Object)