akka.camel

Producer

trait Producer extends ProducerSupport

Mixed in by Actor implementations to produce messages to Camel endpoints.

Self Type
Producer with Actor
Linear Supertypes
ProducerSupport, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. Producer
  2. ProducerSupport
  3. AnyRef
  4. Any
Visibility
  1. Public
  2. All

Abstract Value Members

  1. def endpointUri : String

    Returns the Camel endpoint URI to produce messages to.

    Returns the Camel endpoint URI to produce messages to.

    Attributes
    abstract
    Definition Classes
    ProducerSupport

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 clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  8. def eq (arg0: AnyRef): Boolean

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

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

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  12. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  13. 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
  14. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  15. def ne (arg0: AnyRef): Boolean

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

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

    Attributes
    final
    Definition Classes
    AnyRef
  18. 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).

    Definition Classes
    ProducerSupport
  19. 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
  20. 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
  21. 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
  22. 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)

  23. 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)

  24. def receive : Receive

    Default implementation of Actor.

    Default implementation of Actor.receive. Any messages received by this actors will be produced to the endpoint specified by endpointUri.

    Attributes
    protected
  25. def receiveAfterProduce : Receive

    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
    protected
    Definition Classes
    ProducerSupport
  26. 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
    protected
    Definition Classes
    ProducerSupport
  27. def synchronized [T0] (arg0: ⇒ T0): T0

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

    Definition Classes
    AnyRef → Any
  29. def wait (): Unit

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from ProducerSupport

Inherited from AnyRef

Inherited from Any