public class Mina2Consumer
extends org.apache.camel.impl.DefaultConsumer
Consumer
implementation for Apache MINA.Constructor and Description |
---|
Mina2Consumer(Mina2Endpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
configureCodecFactory(String type,
org.apache.mina.core.service.IoService service,
Mina2Configuration configuration) |
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
|
protected void |
configureDefaultCodecFactory(String type,
org.apache.mina.core.service.IoService service,
Mina2Configuration configuration) |
protected void |
doShutdown() |
protected void |
doStart() |
protected void |
doStop() |
org.apache.mina.core.service.IoAcceptor |
getAcceptor() |
Mina2Endpoint |
getEndpoint() |
void |
setAcceptor(org.apache.mina.core.service.IoAcceptor acceptor) |
protected void |
setupClientSocketProtocol(String uri,
Mina2Configuration configuration) |
protected void |
setupDatagramProtocol(String uri,
Mina2Configuration configuration) |
protected void |
setupSocketProtocol(String uri,
Mina2Configuration configuration) |
protected void |
setupVmProtocol(String uri,
Mina2Configuration configuration) |
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public Mina2Consumer(Mina2Endpoint endpoint, org.apache.camel.Processor processor) throws Exception
Exception
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doShutdown() throws Exception
doShutdown
in class org.apache.camel.support.ServiceSupport
Exception
protected void setupVmProtocol(String uri, Mina2Configuration configuration)
protected void setupSocketProtocol(String uri, Mina2Configuration configuration) throws Exception
Exception
protected void setupClientSocketProtocol(String uri, Mina2Configuration configuration) throws Exception
Exception
protected void configureCodecFactory(String type, org.apache.mina.core.service.IoService service, Mina2Configuration configuration)
protected void configureDefaultCodecFactory(String type, org.apache.mina.core.service.IoService service, Mina2Configuration configuration)
protected void setupDatagramProtocol(String uri, Mina2Configuration configuration)
protected void configureDataGramCodecFactory(String type, org.apache.mina.core.service.IoService service, Mina2Configuration configuration)
public Mina2Endpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
public org.apache.mina.core.service.IoAcceptor getAcceptor()
public void setAcceptor(org.apache.mina.core.service.IoAcceptor acceptor)
Apache Camel