Packages

class StreamContext extends AnyRef

A stream context required by the Camel DSL elements for FS2 and Akka Streams.

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

Instance Constructors

  1. new StreamContext(camelContext: CamelContext, executorServiceFactory: ExecutorServiceFactory = ..., config: Config = ConfigFactory.load())

    camelContext

    externally managed CamelContext. Applications are responsible for starting the CamelContext before starting this StreamContext and stopping the CamelContext after stopping this StreamContext.

    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
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  7. val config: Config
  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.

  9. lazy val consumerTemplate: ConsumerTemplate

    A Camel consumer template created from camelContext.

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

    Java API.

    Java API.

    Converts obj to clazz using a Camel type converter.

    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.

    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.

  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.

  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.

  23. def start(): StreamContext

    Starts this StreamContext and returns this.

  24. def stop(): Unit

    Stops this 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 AnyRef

Inherited from Any

Ungrouped