akka.camel.component

ActorEndpoint

class ActorEndpoint extends DefaultEndpoint

Camel endpoint for sending messages to and receiving replies from (untyped) actors. Actors are referenced using actor endpoint URIs of the following format: actor:, actor:id:[] and actor:uuid:[], where refers to ActorRef.id and refers to the String-representation od ActorRef.uuid. In URIs that contain id: or uuid:, an actor identifier (id or uuid) is optional. In this case, the in-message of an exchange produced to this endpoint must contain a message header with name CamelActorIdentifier and a value that is the target actor's identifier. If the URI contains an actor identifier, a message with a CamelActorIdentifier header overrides the identifier in the endpoint URI.

See also

akka.camel.component.ActorProducer

,

akka.camel.component.ActorComponent

Linear Supertypes
DefaultEndpoint, CamelContextAware, HasId, Endpoint, IsSingleton, ServiceSupport, ShutdownableService, Service, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. ActorEndpoint
  2. DefaultEndpoint
  3. CamelContextAware
  4. HasId
  5. Endpoint
  6. IsSingleton
  7. ServiceSupport
  8. ShutdownableService
  9. Service
  10. AnyRef
  11. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ActorEndpoint (uri: String, comp: ActorComponent, idType: String, idValue: Option[String])

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 addChildService (arg0: Any): Unit

    Attributes
    protected[impl]
    Definition Classes
    ServiceSupport
  7. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  8. var autoack : Boolean

    Whether to auto-acknowledge one-way message exchanges with (untyped) actors.

    Whether to auto-acknowledge one-way message exchanges with (untyped) actors. This is set via the blocking=true|false endpoint URI parameter. Default value is true. When set to true consumer actors need to additionally call Consumer.ack within Actor.receive.

  9. var blocking : Boolean

    Whether to block caller thread during two-way message exchanges with (untyped) actors.

    Whether to block caller thread during two-way message exchanges with (untyped) actors. This is set via the blocking=true|false endpoint URI parameter. Default value is false.

  10. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. def configureProperties (arg0: Map[String, AnyRef]): Unit

    Definition Classes
    DefaultEndpoint → Endpoint
  12. def createConsumer (processor: Processor): Consumer

    Definition Classes
    ActorEndpoint → Endpoint
  13. def createEndpointUri (): String

    Attributes
    protected[impl]
    Definition Classes
    DefaultEndpoint
  14. def createExchange (arg0: ExchangePattern): Exchange

    Definition Classes
    DefaultEndpoint → Endpoint
  15. def createExchange (): Exchange

    Definition Classes
    DefaultEndpoint → Endpoint
  16. def createExchange (arg0: Exchange): Exchange

    Definition Classes
    DefaultEndpoint → Endpoint
  17. def createPollingConsumer (): PollingConsumer

    Definition Classes
    DefaultEndpoint → Endpoint
    Annotations
    @throws()
  18. def createProducer (): ActorProducer

    Creates a new ActorProducer instance initialized with this endpoint.

    Creates a new ActorProducer instance initialized with this endpoint.

    Definition Classes
    ActorEndpoint → Endpoint
  19. def doResume (): Unit

    Attributes
    protected[impl]
    Definition Classes
    ServiceSupport
    Annotations
    @throws()
  20. def doShutdown (): Unit

    Attributes
    protected[impl]
    Definition Classes
    ServiceSupport
    Annotations
    @throws()
  21. def doStart (): Unit

    Attributes
    protected[impl]
    Definition Classes
    DefaultEndpoint → ServiceSupport
    Annotations
    @throws()
  22. def doStop (): Unit

    Attributes
    protected[impl]
    Definition Classes
    DefaultEndpoint → ServiceSupport
    Annotations
    @throws()
  23. def doSuspend (): Unit

    Attributes
    protected[impl]
    Definition Classes
    ServiceSupport
    Annotations
    @throws()
  24. def eq (arg0: AnyRef): Boolean

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

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

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  27. def getAutoack (): Boolean

  28. def getBlocking (): Boolean

  29. def getCamelContext (): CamelContext

    Definition Classes
    DefaultEndpoint → CamelContextAware → Endpoint
  30. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  31. def getComponent (): Component

    Definition Classes
    DefaultEndpoint
  32. def getEndpointKey (): String

    Definition Classes
    DefaultEndpoint → Endpoint
  33. def getEndpointUri (): String

    Definition Classes
    DefaultEndpoint → Endpoint
  34. def getExchangePattern (): ExchangePattern

    Definition Classes
    DefaultEndpoint
  35. def getExchangeType (): Class[Exchange]

    Definition Classes
    DefaultEndpoint
  36. def getId (): String

    Definition Classes
    DefaultEndpoint → HasId
  37. def getStatus (): ServiceStatus

    Definition Classes
    ServiceSupport
  38. def getVersion (): String

    Definition Classes
    ServiceSupport
  39. def hashCode (): Int

    Definition Classes
    DefaultEndpoint → AnyRef → Any
  40. val idType : String

  41. val idValue : Option[String]

  42. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  43. def isLenientProperties (): Boolean

    Definition Classes
    DefaultEndpoint → Endpoint
  44. def isRunAllowed (): Boolean

    Definition Classes
    ServiceSupport
  45. def isSingleton (): Boolean

    Returns true.

    Returns true.

    Definition Classes
    ActorEndpoint → IsSingleton
  46. def isStarted (): Boolean

    Definition Classes
    ServiceSupport
  47. def isStarting (): Boolean

    Definition Classes
    ServiceSupport
  48. def isStopped (): Boolean

    Definition Classes
    ServiceSupport
  49. def isStopping (): Boolean

    Definition Classes
    ServiceSupport
  50. def isSuspended (): Boolean

    Definition Classes
    ServiceSupport
  51. def isSuspending (): Boolean

    Definition Classes
    ServiceSupport
  52. def isSynchronous (): Boolean

    Definition Classes
    DefaultEndpoint
  53. def ne (arg0: AnyRef): Boolean

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

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

    Attributes
    final
    Definition Classes
    AnyRef
  56. def removeChildService (arg0: Any): Boolean

    Attributes
    protected[impl]
    Definition Classes
    ServiceSupport
  57. def resume (): Unit

    Definition Classes
    ServiceSupport
    Annotations
    @throws()
  58. def setAutoack (arg0: Boolean): Unit

    Whether to auto-acknowledge one-way message exchanges with (untyped) actors.

    Whether to auto-acknowledge one-way message exchanges with (untyped) actors. This is set via the blocking=true|false endpoint URI parameter. Default value is true. When set to true consumer actors need to additionally call Consumer.ack within Actor.receive.

  59. def setBlocking (arg0: Boolean): Unit

    Whether to block caller thread during two-way message exchanges with (untyped) actors.

    Whether to block caller thread during two-way message exchanges with (untyped) actors. This is set via the blocking=true|false endpoint URI parameter. Default value is false.

  60. def setCamelContext (arg0: CamelContext): Unit

    Definition Classes
    DefaultEndpoint → CamelContextAware → Endpoint
  61. def setEndpointUri (arg0: String): Unit

    Attributes
    protected[impl]
    Definition Classes
    DefaultEndpoint
  62. def setEndpointUriIfNotSpecified (arg0: String): Unit

    Definition Classes
    DefaultEndpoint
  63. def setExchangePattern (arg0: ExchangePattern): Unit

    Definition Classes
    DefaultEndpoint
  64. def setSynchronous (arg0: Boolean): Unit

    Definition Classes
    DefaultEndpoint
  65. def shutdown (): Unit

    Definition Classes
    ServiceSupport → ShutdownableService
    Annotations
    @throws()
  66. def start (arg0: Boolean): Unit

    Definition Classes
    ServiceSupport
    Annotations
    @throws()
  67. def start (): Unit

    Definition Classes
    ServiceSupport → Service
    Annotations
    @throws()
  68. def stop (): Unit

    Definition Classes
    ServiceSupport → Service
    Annotations
    @throws()
  69. def suspend (): Unit

    Definition Classes
    ServiceSupport
    Annotations
    @throws()
  70. def synchronized [T0] (arg0: ⇒ T0): T0

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

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

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from DefaultEndpoint

Inherited from CamelContextAware

Inherited from HasId

Inherited from Endpoint

Inherited from IsSingleton

Inherited from ServiceSupport

Inherited from ShutdownableService

Inherited from Service

Inherited from AnyRef

Inherited from Any