akka.camel

UntypedProducer

trait UntypedProducer extends ProducerSupport

Java-friendly ProducerSupport.

Self Type
UntypedProducer with UntypedActor
See also

UntypedProducerActor

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

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

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 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
  9. def eq (arg0: AnyRef): Boolean

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

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

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

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

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

    Attributes
    final
    Definition Classes
    Any
  16. 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).

  17. def ne (arg0: AnyRef): Boolean

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

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

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

    Default implementation of UntypedActor.

    Default implementation of UntypedActor.onReceive

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

    Annotations
    @throws( classOf[Exception] )
  22. 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.

    Annotations
    @throws( classOf[Exception] )
  23. 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
  24. 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
  25. 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
  26. 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
  27. 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)

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

  29. 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
  30. 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
  31. def synchronized [T0] (arg0: ⇒ T0): T0

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

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

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from ProducerSupport

Inherited from AnyRef

Inherited from Any