org.apache.camel.component.mina
Class MinaComponent

java.lang.Object
  org.apache.camel.impl.ServiceSupport
      org.apache.camel.impl.DefaultComponent<MinaExchange>
          org.apache.camel.component.mina.MinaComponent

All Implemented Interfaces:

org.apache.camel.Component<MinaExchange>, org.apache.camel.Service

public class MinaComponent
extends org.apache.camel.impl.DefaultComponent<MinaExchange>

Version:

$Revision: 23352 $

Constructor Summary

MinaComponent()

MinaComponent(org.apache.camel.CamelContext context)

Method Summary

protected void	addCodecFactory(org.apache.mina.common.support.BaseIoConnectorConfig config, ProtocolCodecFactory codecFactory)
protected void	configureDataGramCodecFactory(org.apache.mina.common.support.BaseIoConnectorConfig config, Map parameters) For datagrams the entire message is available as a single ByteBuffer so lets just pass those around by default and try converting whatever they payload is into ByteBuffers unless some custom converter is specified
protected void	configureSocketCodecFactory(org.apache.mina.common.support.BaseIoConnectorConfig config, Map parameters)
protected MinaEndpoint	createDatagramEndpoint(String uri, URI connectUri, Map parameters)
protected org.apache.camel.Endpoint<MinaExchange>	createEndpoint(String uri, String remaining, Map parameters)
protected MinaEndpoint	createSocketEndpoint(String uri, URI connectUri, Map parameters)
protected MinaEndpoint	createVmEndpoint(String uri, URI connectUri)
protected ProtocolCodecFactory	getCodecFactory(Map parameters)
protected ByteBuffer	toByteBuffer(Object message)

Methods inherited from class org.apache.camel.impl.DefaultComponent

convertTo, createEndpoint, createExecutorService, doStart, doStop, getCamelContext, getExecutorService, mandatoryConvertTo, newInstance, setCamelContext, setExecutorService, setProperties, useIntrospectionOnEndpoint

Methods inherited from class org.apache.camel.impl.ServiceSupport

addChildService, getThreadName, isRunAllowed, isStarted, isStarting, isStopped, isStopping, nextThreadCounter, removeChildService, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MinaComponent

public MinaComponent()

MinaComponent

public MinaComponent(org.apache.camel.CamelContext context)

Method Detail

createEndpoint

protected org.apache.camel.Endpoint<MinaExchange> createEndpoint(String uri,
                                                                 String remaining,
                                                                 Map parameters)
                                                          throws Exception

Specified by:

createEndpoint in class org.apache.camel.impl.DefaultComponent<MinaExchange>

Throws:

Exception

createVmEndpoint

protected MinaEndpoint createVmEndpoint(String uri,
                                        URI connectUri)

createSocketEndpoint

protected MinaEndpoint createSocketEndpoint(String uri,
                                            URI connectUri,
                                            Map parameters)

configureSocketCodecFactory

protected void configureSocketCodecFactory(org.apache.mina.common.support.BaseIoConnectorConfig config,
                                           Map parameters)

createDatagramEndpoint

protected MinaEndpoint createDatagramEndpoint(String uri,
                                              URI connectUri,
                                              Map parameters)

configureDataGramCodecFactory

protected void configureDataGramCodecFactory(org.apache.mina.common.support.BaseIoConnectorConfig config,
                                             Map parameters)

For datagrams the entire message is available as a single ByteBuffer so lets just pass those around by default and try converting whatever they payload is into ByteBuffers unless some custom converter is specified

toByteBuffer

protected ByteBuffer toByteBuffer(Object message)
                           throws CharacterCodingException

Throws:

CharacterCodingException

getCodecFactory

protected ProtocolCodecFactory getCodecFactory(Map parameters)

addCodecFactory

protected void addCodecFactory(org.apache.mina.common.support.BaseIoConnectorConfig config,
                               ProtocolCodecFactory codecFactory)