68 lines
2.5 KiB
Scala
68 lines
2.5 KiB
Scala
package akka.camel.internal
|
|
|
|
import akka.actor.ActorSystem
|
|
import akka.camel.internal.component.{ DurationTypeConverter, ActorComponent }
|
|
import org.apache.camel.impl.DefaultCamelContext
|
|
import scala.Predef._
|
|
import akka.event.Logging
|
|
import akka.camel.{ CamelSettings, Camel }
|
|
import scala.util.control.NonFatal
|
|
import scala.concurrent.util.Duration
|
|
|
|
import org.apache.camel.{ ProducerTemplate, CamelContext }
|
|
|
|
/**
|
|
* For internal use only.
|
|
* Creates an instance of the Camel subsystem.
|
|
*
|
|
* @param system is used to create internal actors needed by camel instance.
|
|
* Camel doesn't maintain the lifecycle of this actor system. The actor system has to be shut down by the user.
|
|
* In the typical scenario, when camel is used with akka extension, it is natural that camel reuses the actor system it extends.
|
|
* Also by not creating extra internal actor system we are conserving resources.
|
|
*/
|
|
private[camel] class DefaultCamel(val system: ActorSystem) extends Camel {
|
|
/**
|
|
* For internal use only.
|
|
*/
|
|
private[camel] implicit val log = Logging(system, "Camel")
|
|
|
|
lazy val context: CamelContext = {
|
|
val ctx = new DefaultCamelContext
|
|
if (!settings.jmxStatistics) ctx.disableJMX()
|
|
ctx.setName(system.name)
|
|
ctx.setStreamCaching(true)
|
|
ctx.addComponent("akka", new ActorComponent(this, system))
|
|
ctx.getTypeConverterRegistry.addTypeConverter(classOf[Duration], classOf[String], DurationTypeConverter)
|
|
ctx
|
|
}
|
|
|
|
val settings = new CamelSettings(system.settings.config)
|
|
|
|
lazy val template: ProducerTemplate = context.createProducerTemplate()
|
|
|
|
/**
|
|
* Starts camel and underlying camel context and template.
|
|
* Only the creator of Camel should start and stop it.
|
|
* @see akka.camel.DefaultCamel#stop()
|
|
*/
|
|
def start(): this.type = {
|
|
context.start()
|
|
try template.start() catch { case NonFatal(e) ⇒ context.stop(); throw e }
|
|
log.debug("Started CamelContext[{}] for ActorSystem[{}]", context.getName, system.name)
|
|
this
|
|
}
|
|
|
|
/**
|
|
* Stops camel and underlying camel context and template.
|
|
* Only the creator of Camel should shut it down.
|
|
* There is no need to stop Camel instance, which you get from the CamelExtension, as its lifecycle is bound to the actor system.
|
|
*
|
|
* @see akka.camel.DefaultCamel#start()
|
|
*/
|
|
def shutdown(): Unit = {
|
|
try context.stop() finally {
|
|
try template.stop() catch { case NonFatal(e) ⇒ log.debug("Swallowing non-fatal exception [{}] on stopping Camel producer template", e) }
|
|
}
|
|
log.debug("Stopped CamelContext[{}] for ActorSystem[{}]", context.getName, system.name)
|
|
}
|
|
}
|