Packages

class DefaultStreamContext extends StreamContext

A default StreamContext with an internally managed DefaultCamelContext. The lifecycle of the DefaultCamelContext is bound to the lifecycle of this DefaultStreamContext.

Linear Supertypes
StreamContext, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DefaultStreamContext
  2. StreamContext
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DefaultStreamContext(executorServiceFactory: ExecutorServiceFactory)

    executorServiceFactory

    factory for creating this stream context's executorService.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. val camelContext: CamelContext
    Definition Classes
    StreamContext
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  7. val config: Config
    Definition Classes
    StreamContext
  8. def consumer(uri: String, processor: AsyncProcessor): Consumer

    A Camel consumer for given uri.

    A Camel consumer for given uri. If the corresponding endpoint doesn't exist yet, it is created and started. The returned consumer must be started (and stopped) by the caller.

    Definition Classes
    StreamContext
  9. lazy val consumerTemplate: ConsumerTemplate

    A Camel consumer template created from camelContext.

    A Camel consumer template created from camelContext.

    Definition Classes
    StreamContext
  10. def convertObject[A](obj: Any, clazz: Class[A]): A

    Java API.

    Java API.

    Converts obj to clazz using a Camel type converter.

    Definition Classes
    StreamContext
    Exceptions thrown

    TypeConversionException if type conversion fails.

  11. def convertObject[A](obj: Any)(implicit classTag: ClassTag[A]): A

    Converts obj to type A using a Camel type converter.

    Converts obj to type A using a Camel type converter.

    Definition Classes
    StreamContext
    Exceptions thrown

    TypeConversionException if type conversion fails.

  12. def createExchange[A](message: StreamMessage[A], pattern: ExchangePattern): Exchange

    Creates a Camel Exchange of given pattern and input message.

    Creates a Camel Exchange of given pattern and input message.

    Definition Classes
    StreamContext
  13. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  15. lazy val executorService: ExecutorService

    Executor service used for running blocking endpoint operations.

    Executor service used for running blocking endpoint operations. It is created with executorServiceFactory.

    Definition Classes
    StreamContext
  16. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  22. lazy val producerTemplate: ProducerTemplate

    A Camel producer template created from camelContext.

    A Camel producer template created from camelContext.

    Definition Classes
    StreamContext
  23. def start(): DefaultStreamContext

    Starts this StreamContext including the internally managed DefaultCamelContext and returns this.

    Starts this StreamContext including the internally managed DefaultCamelContext and returns this.

    Definition Classes
    DefaultStreamContext → StreamContext
  24. def stop(): Unit

    Stops this StreamContext including the internally managed DefaultCamelContext.

    Stops this StreamContext including the internally managed DefaultCamelContext.

    Definition Classes
    DefaultStreamContext → StreamContext
  25. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  26. def toString(): String
    Definition Classes
    AnyRef → Any
  27. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  29. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from StreamContext

Inherited from AnyRef

Inherited from Any

Ungrouped