@UriEndpoint(scheme="mina2", title="Mina2", syntax="mina2:protocol:host:port", consumerClass=Mina2Consumer.class, label="networking,tcp,udp") public class Mina2Endpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.MultipleConsumersSupport
Constructor and Description |
---|
Mina2Endpoint() |
Mina2Endpoint(String endpointUri,
org.apache.camel.Component component,
Mina2Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange(org.apache.mina.core.session.IoSession session,
Object payload) |
org.apache.camel.Producer |
createProducer() |
Mina2Configuration |
getConfiguration() |
boolean |
isMultipleConsumersSupported() |
boolean |
isSingleton() |
void |
setConfiguration(Mina2Configuration configuration) |
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 Mina2Endpoint()
public Mina2Endpoint(String endpointUri, org.apache.camel.Component component, Mina2Configuration configuration)
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Exchange createExchange(org.apache.mina.core.session.IoSession session, Object payload)
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public boolean isMultipleConsumersSupported()
isMultipleConsumersSupported
in interface org.apache.camel.MultipleConsumersSupport
public Mina2Configuration getConfiguration()
public void setConfiguration(Mina2Configuration configuration)
Apache Camel