akka.camel

UntypedProducerActor

class UntypedProducerActor extends UntypedActor with UntypedProducer

Subclass this abstract class to create an untyped producer actor. This class is meant to be used from Java.

Attributes
abstract
Linear Supertypes
UntypedProducer, ProducerSupport, UntypedActor, Actor, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. UntypedProducerActor
  2. UntypedProducer
  3. ProducerSupport
  4. UntypedActor
  5. Actor
  6. AnyRef
  7. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new UntypedProducerActor ()

Type Members

  1. type Receive = PartialFunction[Any, Unit]

    Definition Classes
    Actor

Abstract Value Members

  1. def getEndpointUri (): String

    Returns the Camel endpoint URI to produce messages to.

    Returns the Camel endpoint URI to produce messages to.

    Attributes
    abstract
    Definition Classes
    UntypedProducer

Concrete Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  7. def become (behavior: Procedure[Any], discardOld: Boolean): Unit

    Definition Classes
    UntypedActor
  8. def become (behavior: Procedure[Any]): Unit

    Definition Classes
    UntypedActor
  9. def become (behavior: Receive, discardOld: Boolean): Unit

    Definition Classes
    Actor
  10. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. def context (): ActorRef

    Definition Classes
    UntypedActor
  12. def endpointUri : String

    Returns the Camel endpoint URI to produce messages to.

    Returns the Camel endpoint URI to produce messages to.

    Attributes
    final
    Definition Classes
    UntypedProducerProducerSupport
  13. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  14. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  15. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  16. def freshInstance (): Option[Actor]

    Definition Classes
    Actor
    Annotations
    @experimental()
  17. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  18. def getContext (): ActorRef

    Definition Classes
    UntypedActor
  19. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  20. def headersToCopy : Set[String]

    Returns the names of message headers to copy from a request message to a response message.

    Returns the names of message headers to copy from a request message to a response message. By default only the Message.MessageExchangeId is copied. Applications may override this to define an application-specific set of message headers to copy.

    Definition Classes
    ProducerSupport
  21. def isDefinedAt (message: Any): Boolean

    Definition Classes
    Actor
  22. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  23. def isOneway (): Boolean

    If set to false (default), this producer expects a response message from the Camel endpoint.

    If set to false (default), this producer expects a response message from the Camel endpoint. If set to true, this producer communicates with the Camel endpoint with an in-only message exchange pattern (fire and forget).

    Definition Classes
    UntypedProducer
  24. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  25. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  26. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  27. def onReceive (message: Any): Unit

    Default implementation of UntypedActor.

    Default implementation of UntypedActor.onReceive

    Definition Classes
    UntypedProducer
  28. def onReceiveAfterProduce (message: Any): Unit

    Called after a response was received from the endpoint specified by endpointUri.

    Called after a response was received from the endpoint specified by 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).

    Definition Classes
    UntypedProducer
    Annotations
    @throws( classOf[Exception] )
  29. def onReceiveBeforeProduce (message: Any): Any

    Called before the message is sent to the endpoint specified by getEndpointUri.

    Called before the message is sent to the endpoint specified by getEndpointUri. The original message is passed as argument. By default, this method simply returns the argument but may be overridden by subclasses.

    Definition Classes
    UntypedProducer
    Annotations
    @throws( classOf[Exception] )
  30. def oneway : Boolean

    If set to false (default), this producer expects a response message from the Camel endpoint.

    If set to false (default), this producer expects a response message from the Camel endpoint. If set to true, this producer initiates an in-only message exchange with the Camel endpoint (fire and forget).

    Attributes
    final
    Definition Classes
    UntypedProducerProducerSupport
  31. def optionSelf : Option[ActorRef]

    Definition Classes
    Actor
  32. def postRestart (reason: Throwable): Unit

    Definition Classes
    UntypedActor → Actor
  33. def postStop : Unit

    Default implementation of Actor.postStop for freeing resources needed to actually send messages to endpointUri.

    Default implementation of Actor.postStop for freeing resources needed to actually send messages to endpointUri.

    Definition Classes
    ProducerSupport
  34. def preRestart (reason: Throwable): Unit

    Default implementation of Actor.preRestart for freeing resources needed to actually send messages to endpointUri.

    Default implementation of Actor.preRestart for freeing resources needed to actually send messages to endpointUri.

    Definition Classes
    ProducerSupport
  35. def preRestart (reason: Throwable, message: Option[Any]): Unit

    Definition Classes
    Actor
  36. def preRestartProducer (reason: Throwable): Unit

    Does nothing by default.

    Does nothing by default. Can be overridden by concrete producers for implementing a pre-restart callback handler.

    Definition Classes
    ProducerSupport
  37. def preStart (): Unit

    Definition Classes
    UntypedActor → Actor
  38. def produce : Receive

    Produces msg to the endpoint specified by endpointUri.

    Produces msg to the endpoint specified by endpointUri. Before the message is actually sent it is pre-processed by calling receiveBeforeProduce. If oneway is true, an in-only message exchange is initiated, otherwise an in-out message exchange.

    Attributes
    protected
    Definition Classes
    ProducerSupport
    See also

    Producer#produce(Any, ExchangePattern)

  39. def produce (msg: Any, pattern: ExchangePattern): Unit

    Initiates a message exchange of given pattern with the endpoint specified by endpointUri.

    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. This is done by wrapping the response, adding it to this producers mailbox, unwrapping it and calling receiveAfterProduce. The original sender and senderFuture are thereby preserved.

    msg

    message to produce

    pattern

    exchange pattern

    Attributes
    protected
    Definition Classes
    ProducerSupport
    See also

    Message#canonicalize(Any)

  40. def receive : PartialFunction[Any, Unit]

    Attributes
    protected final
    Definition Classes
    UntypedActor → Actor
  41. def receiveAfterProduce : PartialFunction[Any, Unit]

    Called after a response was received from the endpoint specified by endpointUri.

    Called after a response was received from the endpoint specified by 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).

    Attributes
    final
    Definition Classes
    UntypedProducerProducerSupport
  42. def receiveBeforeProduce : PartialFunction[Any, Any]

    Called before the message is sent to the endpoint specified by endpointUri.

    Called before the message is sent to the endpoint specified by endpointUri. The original message is passed as argument. By default, this method simply returns the argument but may be overridden by subtraits or subclasses.

    Attributes
    final
    Definition Classes
    UntypedProducerProducerSupport
  43. implicit val self : ScalaActorRef

    Attributes
    implicit
    Definition Classes
    Actor
  44. val someSelf : Some[ActorRef]

    Definition Classes
    Actor
  45. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  46. def toString (): String

    Definition Classes
    AnyRef → Any
  47. def unbecome (): Unit

    Definition Classes
    Actor
  48. def unhandled (msg: Any): Unit

    Definition Classes
    UntypedActor → Actor
  49. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  50. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  51. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from UntypedProducer

Inherited from ProducerSupport

Inherited from UntypedActor

Inherited from Actor

Inherited from AnyRef

Inherited from Any