@UriEndpoint(scheme="javaspace", title="JavaSpace", syntax="javaspace:url", consumerClass=JavaSpaceConsumer.class, label="messaging") public class JavaSpaceEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
JavaSpaceEndpoint(String endpointUri,
String remaining,
JavaSpaceComponent component) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
int |
getConcurrentConsumers() |
String |
getSpaceName() |
String |
getTemplateId() |
long |
getTransactionTimeout() |
String |
getUrl()
The URL to the JavaSpace server
|
String |
getVerb() |
boolean |
isSingleton() |
boolean |
isTransactional() |
void |
setConcurrentConsumers(int concurrentConsumers)
Specifies the number of concurrent consumers getting entries from the JavaSpace.
|
void |
setSpaceName(String spaceName)
Specifies the JavaSpace name.
|
void |
setTemplateId(String templateId)
If present, this option specifies the Spring bean ID of the template to use for reading/taking entries.
|
void |
setTransactional(boolean transactional)
If true, sending and receiving entries is performed within a transaction.
|
void |
setTransactionTimeout(long transactionTimeout)
Specifies the transaction timeout in millis.
|
void |
setVerb(String verb)
Specifies the verb for getting JavaSpace entries.
|
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
public JavaSpaceEndpoint(String endpointUri, String remaining, JavaSpaceComponent component)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public String getVerb()
public void setVerb(String verb)
public boolean isTransactional()
public void setTransactional(boolean transactional)
public String getUrl()
public void setConcurrentConsumers(int concurrentConsumers)
public int getConcurrentConsumers()
public String getSpaceName()
public void setSpaceName(String spaceName)
public String getTemplateId()
public void setTemplateId(String templateId)
public long getTransactionTimeout()
public void setTransactionTimeout(long transactionTimeout)
Apache Camel