public class ActorEndpoint extends org.apache.camel.impl.DefaultEndpoint implements ActorEndpointConfig
ActorEndpoint
is a Camel Endpoint
that is used to
receive messages from Camel. Sending messages from the ActorComponent
is not supported, a Producer
actor should be used instead.
The ActorEndpoint
s are created by the ActorComponent
.
Actors are referenced using actor endpoint URIs of the following format:
[actorPath]?[options]%s
,
where [actorPath]
refers to the actor path to the actor.
Constructor and Description |
---|
ActorEndpoint(java.lang.String uri,
ActorComponent comp,
ActorEndpointPath path,
Camel camel) |
Modifier and Type | Method and Description |
---|---|
boolean |
autoAck() |
Camel |
camel() |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor)
The ActorEndpoint only supports receiving messages from Camel.
|
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() |
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
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getAutoAck, getReplyTimeout, setAutoAck, setReplyTimeout
public ActorEndpoint(java.lang.String uri, ActorComponent comp, ActorEndpointPath path, Camel camel)
public scala.concurrent.duration.FiniteDuration replyTimeout()
replyTimeout
in interface ActorEndpointConfig
public boolean autoAck()
autoAck
in interface ActorEndpointConfig
public ActorEndpointPath path()
path
in interface ActorEndpointConfig
public Camel camel()
camel
in interface ActorEndpointConfig
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
Producer
Actors can be used for sending messages to some other uri/ component type registered in Camel.createConsumer
in interface org.apache.camel.Endpoint
processor
- (undocumented)java.lang.UnsupportedOperationException
- this method is not supportedpublic ActorProducer createProducer()
createProducer
in interface org.apache.camel.Endpoint
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton