org.apache.camel.component.netty
Class NettyConsumer

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer
          extended by org.apache.camel.component.netty.NettyConsumer
All Implemented Interfaces:
Consumer, Service, ShutdownableService

public class NettyConsumer
extends DefaultConsumer


Field Summary
 
Fields inherited from class org.apache.camel.impl.DefaultConsumer
log
 
Constructor Summary
NettyConsumer(NettyEndpoint nettyEndpoint, Processor processor, NettyConfiguration configuration)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop()
           
 org.jboss.netty.channel.group.ChannelGroup getAllChannels()
           
 org.jboss.netty.channel.ChannelFactory getChannelFactory()
           
 NettyConfiguration getConfiguration()
           
 org.jboss.netty.bootstrap.ConnectionlessBootstrap getConnectionlessServerBootstrap()
           
 CamelContext getContext()
           
 org.jboss.netty.channel.socket.DatagramChannelFactory getDatagramChannelFactory()
           
 NettyEndpoint getEndpoint()
          Gets the endpoint this Consumer consumes from.
 org.jboss.netty.bootstrap.ServerBootstrap getServerBootstrap()
           
protected  boolean isTcp()
           
 void setChannelFactory(org.jboss.netty.channel.ChannelFactory channelFactory)
           
 void setConfiguration(NettyConfiguration configuration)
           
 void setConnectionlessServerBootstrap(org.jboss.netty.bootstrap.ConnectionlessBootstrap connectionlessServerBootstrap)
           
 void setDatagramChannelFactory(org.jboss.netty.channel.socket.DatagramChannelFactory datagramChannelFactory)
           
 void setServerBootstrap(org.jboss.netty.bootstrap.ServerBootstrap serverBootstrap)
           
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
getAsyncProcessor, getExceptionHandler, getProcessor, handleException, setExceptionHandler, toString
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, shutdown, start, stop
 
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

NettyConsumer

public NettyConsumer(NettyEndpoint nettyEndpoint,
                     Processor processor,
                     NettyConfiguration configuration)
Method Detail

getEndpoint

public NettyEndpoint getEndpoint()
Description copied from interface: Consumer
Gets the endpoint this Consumer consumes from.

Specified by:
getEndpoint in interface Consumer
Overrides:
getEndpoint in class DefaultConsumer
Returns:
the endpoint

doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class DefaultConsumer
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class DefaultConsumer
Throws:
Exception

getContext

public CamelContext getContext()

getAllChannels

public org.jboss.netty.channel.group.ChannelGroup getAllChannels()

getConfiguration

public NettyConfiguration getConfiguration()

setConfiguration

public void setConfiguration(NettyConfiguration configuration)

getChannelFactory

public org.jboss.netty.channel.ChannelFactory getChannelFactory()

setChannelFactory

public void setChannelFactory(org.jboss.netty.channel.ChannelFactory channelFactory)

getDatagramChannelFactory

public org.jboss.netty.channel.socket.DatagramChannelFactory getDatagramChannelFactory()

setDatagramChannelFactory

public void setDatagramChannelFactory(org.jboss.netty.channel.socket.DatagramChannelFactory datagramChannelFactory)

getServerBootstrap

public org.jboss.netty.bootstrap.ServerBootstrap getServerBootstrap()

setServerBootstrap

public void setServerBootstrap(org.jboss.netty.bootstrap.ServerBootstrap serverBootstrap)

getConnectionlessServerBootstrap

public org.jboss.netty.bootstrap.ConnectionlessBootstrap getConnectionlessServerBootstrap()

setConnectionlessServerBootstrap

public void setConnectionlessServerBootstrap(org.jboss.netty.bootstrap.ConnectionlessBootstrap connectionlessServerBootstrap)

isTcp

protected boolean isTcp()


Copyright © 2007-2010 IONA Open Source Community. All Rights Reserved.