Packages

p

streamz

camel

package camel

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class DefaultStreamContext extends StreamContext

    A default StreamContext with an internally managed DefaultCamelContext.

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

  2. class StreamContext extends AnyRef

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

  3. case class StreamMessage[A](body: A, headers: Map[String, Any] = Map.empty) extends Product with Serializable

    A message received from or sent to a Camel endpoint.

    A message received from or sent to a Camel endpoint.

    body

    Message body.

    headers

    Message headers.

Value Members

  1. object DefaultStreamContext
  2. object StreamContext
  3. object StreamMessage extends Serializable

Ungrouped