akka.camel
Class ProducerSupport.ProducerChild
java.lang.Object
akka.camel.ProducerSupport.ProducerChild
- All Implemented Interfaces:
- Actor
- Enclosing interface:
- ProducerSupport
public private static class ProducerSupport.ProducerChild
- extends java.lang.Object
- implements Actor
Method Summary |
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()
This defines the initial actor behavior, it must return a partial function
with the actor logic. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ProducerSupport.ProducerChild
public ProducerSupport.ProducerChild(org.apache.camel.Endpoint endpoint,
org.apache.camel.processor.SendProcessor processor)
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
- Description copied from interface:
Actor
- This defines the initial actor behavior, it must return a partial function
with the actor logic.
- Specified by:
receive
in interface Actor
produce
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
. 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 and senderFuture are preserved.
- Parameters:
endpoint
- the endpointprocessor
- the processormsg
- message to producepattern
- exchange pattern- See Also:
CamelMessage#canonicalize(Any)