@UriEndpoint(scheme="mina", title="Mina", syntax="mina:protocol:host:port", consumerClass=MinaConsumer.class, label="networking,tcp,udp") public class MinaEndpoint extends org.apache.camel.impl.DefaultEndpoint implements org.apache.camel.MultipleConsumersSupport
Modifier and Type | Field and Description |
---|---|
static String |
HEADER_LOCAL_ADDRESS
Deprecated.
|
static String |
HEADER_MINA_IOSESSION
Deprecated.
|
static String |
HEADER_REMOTE_ADDRESS
Deprecated.
|
Constructor and Description |
---|
MinaEndpoint() |
MinaEndpoint(String endpointUri,
MinaComponent component) |
Modifier and Type | Method and Description |
---|---|
protected void |
addThreadPool(ExecutorService executorService)
Add thread pool which are in-use, we need to un-register when shutting down.
|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange(org.apache.mina.common.IoSession session,
Object payload) |
org.apache.camel.Producer |
createProducer() |
protected void |
doShutdown() |
org.apache.mina.common.IoAcceptor |
getAcceptor() |
org.apache.mina.common.IoAcceptorConfig |
getAcceptorConfig() |
SocketAddress |
getAddress() |
MinaConfiguration |
getConfiguration() |
org.apache.mina.common.IoConnector |
getConnector() |
org.apache.mina.common.IoConnectorConfig |
getConnectorConfig() |
boolean |
isMultipleConsumersSupported() |
boolean |
isSingleton() |
void |
setAcceptor(org.apache.mina.common.IoAcceptor acceptor) |
void |
setAcceptorConfig(org.apache.mina.common.IoAcceptorConfig acceptorConfig) |
void |
setAddress(SocketAddress address) |
void |
setConfiguration(MinaConfiguration configuration) |
void |
setConnector(org.apache.mina.common.IoConnector connector) |
void |
setConnectorConfig(org.apache.mina.common.IoConnectorConfig connectorConfig) |
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, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
@Deprecated public static final String HEADER_MINA_IOSESSION
@Deprecated public static final String HEADER_LOCAL_ADDRESS
@Deprecated public static final String HEADER_REMOTE_ADDRESS
public MinaEndpoint()
public MinaEndpoint(String endpointUri, MinaComponent component)
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.common.IoSession session, Object payload)
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public boolean isMultipleConsumersSupported()
isMultipleConsumersSupported
in interface org.apache.camel.MultipleConsumersSupport
protected void doShutdown() throws Exception
doShutdown
in class org.apache.camel.support.ServiceSupport
Exception
protected void addThreadPool(ExecutorService executorService)
public MinaConfiguration getConfiguration()
public void setConfiguration(MinaConfiguration configuration)
public SocketAddress getAddress()
public void setAddress(SocketAddress address)
public org.apache.mina.common.IoAcceptor getAcceptor()
public void setAcceptor(org.apache.mina.common.IoAcceptor acceptor)
public org.apache.mina.common.IoConnector getConnector()
public void setConnector(org.apache.mina.common.IoConnector connector)
public org.apache.mina.common.IoAcceptorConfig getAcceptorConfig()
public void setAcceptorConfig(org.apache.mina.common.IoAcceptorConfig acceptorConfig)
public org.apache.mina.common.IoConnectorConfig getConnectorConfig()
public void setConnectorConfig(org.apache.mina.common.IoConnectorConfig connectorConfig)
Apache Camel