Akka/Scala example source code file (UntypedConsumerActor.scala)

This example Akka source code file (UntypedConsumerActor.scala) is included in my "Source Code Warehouse" project. The intent of this project is to help you more easily find Akka and Scala source code examples by using tags.

All credit for the original source code belongs to akka.io; I'm just trying to make examples easier to find. (For my Scala work, see my Scala examples and tutorials.)

Akka tags/keywords

activation, actor, akka, camel, consumer, defaultcamelcontext, producertemplate, string, untypedactor, untypedconsumeractor

The UntypedConsumerActor.scala Akka example source code

/**
 * Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com>
 */

package akka.camel.javaapi

import akka.actor.UntypedActor
import akka.camel._
import org.apache.camel.ProducerTemplate
import org.apache.camel.impl.DefaultCamelContext

/**
 * Subclass this abstract class to create an MDB-style untyped consumer actor. This
 * class is meant to be used from Java.
 */
abstract class UntypedConsumerActor extends UntypedActor with Consumer {
  final def endpointUri: String = getEndpointUri

  /**
   * Java API: Returns the Camel endpoint URI to consume messages from.
   */
  def getEndpointUri(): String

  /**
   * Java API: Returns the [[org.apache.camel.impl.DefaultCamelContext]]
   * @return the CamelContext
   */
  protected def getCamelContext(): DefaultCamelContext = camelContext

  /**
   * Java API: Returns the [[org.apache.camel.ProducerTemplate]]
   * @return the ProducerTemplate
   */
  protected def getProducerTemplate(): ProducerTemplate = camel.template

  /**
   * Java API: Returns the [[akka.camel.Activation]] interface
   * that can be used to wait on activation or de-activation of Camel endpoints.
   * @return the Activation interface
   */
  protected def getActivation(): Activation = camel
}