Package akka.camel.internal.component
Class ActorEndpoint
- java.lang.Object
-
- org.apache.camel.support.ServiceSupport
-
- org.apache.camel.impl.DefaultEndpoint
-
- akka.camel.internal.component.ActorEndpoint
-
- All Implemented Interfaces:
ActorEndpointConfig
,org.apache.camel.CamelContextAware
,org.apache.camel.Endpoint
,org.apache.camel.IsSingleton
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.HasId
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class ActorEndpoint extends org.apache.camel.impl.DefaultEndpoint implements ActorEndpointConfig
The ActorEndpoint only supports receiving messages from Camel. The createProducer method (not to be confused with a producer actor) is used to send messages into the endpoint. The ActorComponent is only there to send to actors registered through an actor endpoint URI. You can use an actor as an endpoint to send to in a camel route (as in, a Camel Consumer Actor). so from(someuri) to (actoruri), but not 'the other way around'. Supporting createConsumer would mean that messages are consumed from an Actor endpoint in a route, and an Actor is not necessarily a producer of messages.Producer
Actors can be used for sending messages to some other uri/ component type registered in Camel.
-
-
Constructor Summary
Constructors Constructor Description ActorEndpoint(java.lang.String uri, ActorComponent comp, ActorEndpointPath path, Camel camel)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
autoAck()
void
autoAck_$eq(boolean x$1)
Camel
camel()
org.apache.camel.Consumer
createConsumer(org.apache.camel.Processor processor)
ActorProducer
createProducer()
Creates a new producer which is used send messages into the endpoint.boolean
isSingleton()
Returns true.ActorEndpointPath
path()
scala.concurrent.duration.FiniteDuration
replyTimeout()
void
replyTimeout_$eq(scala.concurrent.duration.FiniteDuration x$1)
-
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
-
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface akka.camel.internal.component.ActorEndpointConfig
getAutoAck, getReplyTimeout, setAutoAck, setReplyTimeout
-
-
-
-
Constructor Detail
-
ActorEndpoint
public ActorEndpoint(java.lang.String uri, ActorComponent comp, ActorEndpointPath path, Camel camel)
-
-
Method Detail
-
autoAck
public boolean autoAck()
- Specified by:
autoAck
in interfaceActorEndpointConfig
-
autoAck_$eq
public void autoAck_$eq(boolean x$1)
- Specified by:
autoAck_$eq
in interfaceActorEndpointConfig
-
camel
public Camel camel()
- Specified by:
camel
in interfaceActorEndpointConfig
-
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
- Specified by:
createConsumer
in interfaceorg.apache.camel.Endpoint
-
createProducer
public ActorProducer createProducer()
Creates a new producer which is used send messages into the endpoint.- Specified by:
createProducer
in interfaceorg.apache.camel.Endpoint
- Returns:
- a newly created producer
-
isSingleton
public boolean isSingleton()
Returns true.- Specified by:
isSingleton
in interfaceorg.apache.camel.IsSingleton
- Returns:
- (undocumented)
-
path
public ActorEndpointPath path()
- Specified by:
path
in interfaceActorEndpointConfig
-
replyTimeout
public scala.concurrent.duration.FiniteDuration replyTimeout()
- Specified by:
replyTimeout
in interfaceActorEndpointConfig
-
replyTimeout_$eq
public void replyTimeout_$eq(scala.concurrent.duration.FiniteDuration x$1)
- Specified by:
replyTimeout_$eq
in interfaceActorEndpointConfig
-
-