akka.camel

CamelService

trait CamelService extends Bootable

Publishes consumer actors at their Camel endpoints. Consumer actors are published asynchronously when they are started and un-published asynchronously when they are stopped. The CamelService is notified about actor life cycle by registering listeners at Actor.registry.

If the akka-camel-typed jar is on the classpath, it is automatically detected by the CamelService. The optional akka-camel-typed jar provides support for typed consumer actors.

Linear Supertypes
Bootable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. CamelService
  2. Bootable
  3. AnyRef
  4. Any
Visibility
  1. Public
  2. All

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 awaitEndpointActivation (count: Int, timeout: Long, timeUnit: TimeUnit, p: SideEffect): Boolean

    Waits for an expected number (count) of consumer actor endpoints to be activated during execution of p.

    Waits for an expected number (count) of consumer actor endpoints to be activated during execution of p. Timeout values can be set via the timeout and timeUnit parameters.

    Java API

  8. def awaitEndpointActivation (count: Int, p: SideEffect): Boolean

    Waits for an expected number (count) of consumer actor endpoints to be activated during execution of p.

    Waits for an expected number (count) of consumer actor endpoints to be activated during execution of p. The wait timeout is 10 seconds.

    Java API

  9. def awaitEndpointActivation (count: Int, timeout: Long = 10, timeUnit: TimeUnit = TimeUnit.SECONDS)(f: ⇒ Unit): Boolean

    Waits for an expected number (count) of consumer actor endpoints to be activated during execution of f.

    Waits for an expected number (count) of consumer actor endpoints to be activated during execution of f. The wait-timeout is by default 10 seconds. Other timeout values can be set via the timeout and timeUnit parameters.

  10. def awaitEndpointDeactivation (count: Int, timeout: Long, timeUnit: TimeUnit, p: SideEffect): Boolean

    Waits for an expected number (count) of consumer actor endpoints to be de-activated during execution of p.

    Waits for an expected number (count) of consumer actor endpoints to be de-activated during execution of p. Timeout values can be set via the timeout and timeUnit parameters.

    Java API

  11. def awaitEndpointDeactivation (count: Int, p: SideEffect): Boolean

    Waits for an expected number (count) of consumer actor endpoints to be de-activated during execution of p.

    Waits for an expected number (count) of consumer actor endpoints to be de-activated during execution of p. The wait timeout is 10 seconds.

    Java API

  12. def awaitEndpointDeactivation (count: Int, timeout: Long = 10, timeUnit: TimeUnit = TimeUnit.SECONDS)(f: ⇒ Unit): Boolean

    Waits for an expected number (count) of consumer actor endpoints to be de-activated during execution of f.

    Waits for an expected number (count) of consumer actor endpoints to be de-activated during execution of f. The wait-timeout is by default 10 seconds. Other timeout values can be set via the timeout and timeUnit parameters.

  13. def clone (): AnyRef

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

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

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

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

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

    Definition Classes
    AnyRef → Any
  19. def isInstanceOf [T0] : Boolean

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

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

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

    Attributes
    final
    Definition Classes
    AnyRef
  23. def onLoad (): Unit

    Starts this CamelService if the akka.enabled-modules list contains "camel".

    Starts this CamelService if the akka.enabled-modules list contains "camel".

    Definition Classes
    CamelService → Bootable
  24. def onUnload (): Unit

    Stops this CamelService if the akka.enabled-modules list contains "camel".

    Stops this CamelService if the akka.enabled-modules list contains "camel".

    Definition Classes
    CamelService → Bootable
  25. def start : CamelService

    Starts this CamelService.

  26. def stop : Unit

    Stops this CamelService.

  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()

Deprecated Value Members

  1. def load : CamelService

    Annotations
    @deprecated
    Deprecated

    use start() instead

  2. def unload : Unit

    Annotations
    @deprecated
    Deprecated

    use stop() instead

Inherited from Bootable

Inherited from AnyRef

Inherited from Any