org.apache.camel.component.mina2
Class Mina2Producer

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultProducer
          extended by org.apache.camel.component.mina2.Mina2Producer
All Implemented Interfaces:
org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ServicePoolAware, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class Mina2Producer
extends org.apache.camel.impl.DefaultProducer
implements org.apache.camel.ServicePoolAware

A Producer implementation for MINA

Version:

Field Summary
 
Fields inherited from class org.apache.camel.impl.DefaultProducer
log
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
Mina2Producer(Mina2Endpoint endpoint)
           
 
Method Summary
protected  void configureCodecFactory(String type, org.apache.mina.core.service.IoService service)
           
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)
           
protected  void doProcess(org.apache.camel.Exchange exchange)
           
protected  void doShutdown()
           
protected  void doStart()
           
protected  void doStop()
           
 Mina2Endpoint getEndpoint()
           
 org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder getFilterChain()
           
 boolean isSingleton()
           
protected  void maybeDisconnectOnDone(org.apache.camel.Exchange exchange)
           
 void process(org.apache.camel.Exchange exchange)
           
protected  void setupDatagramProtocol(String uri)
           
protected  void setupSocketProtocol(String uri)
           
protected  void setupVmProtocol(String uri)
           
 
Methods inherited from class org.apache.camel.impl.DefaultProducer
createExchange, createExchange, createExchange, 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 class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

Mina2Producer

public Mina2Producer(Mina2Endpoint endpoint)
              throws Exception
Throws:
Exception
Method Detail

getEndpoint

public Mina2Endpoint getEndpoint()
Specified by:
getEndpoint in interface org.apache.camel.Producer
Overrides:
getEndpoint in class org.apache.camel.impl.DefaultProducer

isSingleton

public boolean isSingleton()
Specified by:
isSingleton in interface org.apache.camel.IsSingleton
Overrides:
isSingleton in class org.apache.camel.impl.DefaultProducer

process

public void process(org.apache.camel.Exchange exchange)
             throws Exception
Specified by:
process in interface org.apache.camel.Processor
Throws:
Exception

doProcess

protected void doProcess(org.apache.camel.Exchange exchange)
                  throws Exception
Throws:
Exception

maybeDisconnectOnDone

protected void maybeDisconnectOnDone(org.apache.camel.Exchange exchange)

getFilterChain

public org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder getFilterChain()

doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class org.apache.camel.impl.DefaultProducer
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class org.apache.camel.impl.DefaultProducer
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)

setupSocketProtocol

protected void setupSocketProtocol(String uri)
                            throws Exception
Throws:
Exception

configureCodecFactory

protected void configureCodecFactory(String type,
                                     org.apache.mina.core.service.IoService service)

configureDefaultCodecFactory

protected void configureDefaultCodecFactory(String type,
                                            org.apache.mina.core.service.IoService service)

setupDatagramProtocol

protected void setupDatagramProtocol(String uri)

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



Apache Camel