org.apache.camel.component.mina2
Class Mina2Consumer
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultConsumer
org.apache.camel.component.mina2.Mina2Consumer
- All Implemented Interfaces:
- org.apache.camel.Consumer, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class Mina2Consumer
- extends org.apache.camel.impl.DefaultConsumer
A Consumer
implementation for Apache MINA.
- Version:
Fields inherited from class org.apache.camel.impl.DefaultConsumer |
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.DefaultConsumer |
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
Mina2Consumer
public Mina2Consumer(Mina2Endpoint endpoint,
org.apache.camel.Processor processor)
throws Exception
- Throws:
Exception
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class org.apache.camel.impl.DefaultConsumer
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Overrides:
doStop
in class org.apache.camel.impl.DefaultConsumer
- Throws:
Exception
doShutdown
protected void doShutdown()
throws Exception
- Overrides:
doShutdown
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
setupVmProtocol
protected void setupVmProtocol(String uri,
Mina2Configuration configuration)
setupSocketProtocol
protected void setupSocketProtocol(String uri,
Mina2Configuration configuration)
throws Exception
- Throws:
Exception
configureCodecFactory
protected void configureCodecFactory(String type,
org.apache.mina.core.service.IoService service,
Mina2Configuration configuration)
configureDefaultCodecFactory
protected void configureDefaultCodecFactory(String type,
org.apache.mina.core.service.IoService service,
Mina2Configuration configuration)
setupDatagramProtocol
protected void setupDatagramProtocol(String uri,
Mina2Configuration configuration)
configureDataGramCodecFactory
protected void configureDataGramCodecFactory(String type,
org.apache.mina.core.service.IoService service,
Mina2Configuration configuration)
- For datagrams the entire message is available as a single IoBuffer so lets just pass those around by default
and try converting whatever they payload is into IoBuffer unless some custom converter is specified
getEndpoint
public Mina2Endpoint getEndpoint()
- Specified by:
getEndpoint
in interface org.apache.camel.Consumer
- Overrides:
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
getAcceptor
public org.apache.mina.core.service.IoAcceptor getAcceptor()
setAcceptor
public void setAcceptor(org.apache.mina.core.service.IoAcceptor acceptor)
Apache Camel