akka.camel.javaapi

Class UntypedConsumerActor

java.lang.Object

akka.actor.UntypedActor

akka.camel.javaapi.UntypedConsumerActor

All Implemented Interfaces:

Actor, CamelSupport, Consumer

public abstract class UntypedConsumerActor
extends UntypedActor
implements Consumer

Subclass this abstract class to create an MDB-style untyped consumer actor. This class is meant to be used from Java.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
UntypedConsumerActor()

Method Summary

Modifier and Type	Method and Description
protected Camel	camel() INTERNAL API Returns a Camel trait which provides access to the CamelExtension.
java.lang.String	endpointUri() Must return the Camel endpoint URI that the consumer wants to consume messages from.
protected Activation	getActivation() Java API: Returns the Activation interface that can be used to wait on activation or de-activation of Camel endpoints.
protected org.apache.camel.impl.DefaultCamelContext	getCamelContext() Java API: Returns the DefaultCamelContext
abstract java.lang.String	getEndpointUri() Java API: Returns the Camel endpoint URI to consume messages from.
protected org.apache.camel.ProducerTemplate	getProducerTemplate() Java API: Returns the ProducerTemplate

Methods inherited from class akka.actor.UntypedActor

context, getContext, getSelf, getSender, onReceive, postRestart, postStop, preRestart, preStart, receive, self, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.camel.Consumer

activationTimeout, autoAck, getRouteDefinitionHandler, onRouteDefinition, preStart, register, replyTimeout

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.camel.CamelSupport

camelContext

Constructor Detail

UntypedConsumerActor

public UntypedConsumerActor()

Method Detail

camel

protected Camel camel()

Description copied from interface: CamelSupport

INTERNAL API Returns a Camel trait which provides access to the CamelExtension.

Specified by:

camel in interface CamelSupport

Returns:

(undocumented)

endpointUri

public final java.lang.String endpointUri()

Description copied from interface: Consumer

Must return the Camel endpoint URI that the consumer wants to consume messages from.

Specified by:

endpointUri in interface Consumer

Returns:

(undocumented)

getEndpointUri

public abstract java.lang.String getEndpointUri()

Java API: Returns the Camel endpoint URI to consume messages from.

Returns:

(undocumented)

getCamelContext

protected org.apache.camel.impl.DefaultCamelContext getCamelContext()

Java API: Returns the DefaultCamelContext

Returns:

the CamelContext

getProducerTemplate

protected org.apache.camel.ProducerTemplate getProducerTemplate()

Java API: Returns the ProducerTemplate

Returns:

the ProducerTemplate

getActivation

protected Activation getActivation()

Java API: Returns the Activation interface that can be used to wait on activation or de-activation of Camel endpoints.

Returns:

the Activation interface