org.apache.camel.component.mina2

Class Mina2Producer

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultProducer

org.apache.camel.component.mina2.Mina2Producer

All Implemented Interfaces:

EndpointAware, IsSingleton, Processor, Producer, Service, ServicePoolAware, ShutdownableService, StatefulService, SuspendableService

public class Mina2Producer
extends DefaultProducer
implements 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

Constructors

Constructor and Description
Mina2Producer(Mina2Endpoint endpoint)

Method Summary

Methods

Modifier and Type	Method and Description
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(Exchange exchange)
protected void	doShutdown() Implementations override this method to perform customized shutdown.
protected void	doStart() Implementations override this method to support customized start/stop.
protected void	doStop() Implementations override this method to support customized start/stop.
Mina2Endpoint	getEndpoint() Gets the endpoint associated with an object.
org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder	getFilterChain()
boolean	isSingleton() This implementation will delegate to the endpoint IsSingleton.isSingleton()
protected void	maybeDisconnectOnDone(Exchange exchange)
void	process(Exchange exchange) Processes the message 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()

Description copied from interface: EndpointAware

Gets the endpoint associated with an object. It's the endpoint for sending to for components like Producer or for consuming from for components like Consumer or Route

Specified by:

getEndpoint in interface EndpointAware

Overrides:

getEndpoint in class DefaultProducer

Returns:

the endpoint

isSingleton

public boolean isSingleton()

Description copied from class: DefaultProducer

This implementation will delegate to the endpoint IsSingleton.isSingleton()

Specified by:

isSingleton in interface IsSingleton

Overrides:

isSingleton in class DefaultProducer

Returns:

true to be a single shared instance, false to create new instances.

process

public void process(Exchange exchange)
             throws Exception

Description copied from interface: Processor

Processes the message exchange

Specified by:

process in interface Processor

Parameters:

exchange - the message exchange

Throws:

Exception - if an internal processing error has occurred.

doProcess

protected void doProcess(Exchange exchange)
                  throws Exception

Throws:

Exception

maybeDisconnectOnDone

protected void maybeDisconnectOnDone(Exchange exchange)

getFilterChain

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

doStart

protected void doStart()
                throws Exception

Description copied from class: ServiceSupport

Implementations override this method to support customized start/stop.

Important: See ServiceSupport.doStop() for more details.

Overrides:

doStart in class DefaultProducer

Throws:

Exception

See Also:

ServiceSupport.doStop()

doStop

protected void doStop()
               throws Exception

Description copied from class: ServiceSupport

Implementations override this method to support customized start/stop.

Important: Camel will invoke this ServiceSupport.doStop() method when the service is being stopped. This method will also be invoked if the service is still in uninitialized state (eg has not been started). The method is always called to allow the service to do custom logic when the service is being stopped, such as when CamelContext is shutting down.

Overrides:

doStop in class DefaultProducer

Throws:

Exception

See Also:

ServiceSupport.doStart()

doShutdown

protected void doShutdown()
                   throws Exception

Description copied from class: ServiceSupport

Implementations override this method to perform customized shutdown.

Overrides:

doShutdown in class 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