org.apache.flume.source
Class SyslogTcpSource.syslogTcpHandler

java.lang.Object
  extended by org.jboss.netty.channel.SimpleChannelHandler
      extended by org.apache.flume.source.SyslogTcpSource.syslogTcpHandler
All Implemented Interfaces:
org.jboss.netty.channel.ChannelDownstreamHandler, org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler
Enclosing class:
SyslogTcpSource

public class SyslogTcpSource.syslogTcpHandler
extends org.jboss.netty.channel.SimpleChannelHandler


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler
org.jboss.netty.channel.ChannelHandler.Sharable
 
Constructor Summary
SyslogTcpSource.syslogTcpHandler()
           
 
Method Summary
 void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent mEvent)
           
 void setEventSize(int eventSize)
           
 void setFormater(Map<String,String> prop)
           
 
Methods inherited from class org.jboss.netty.channel.SimpleChannelHandler
bindRequested, channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, exceptionCaught, handleDownstream, handleUpstream, setInterestOpsRequested, unbindRequested, writeComplete, writeRequested
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SyslogTcpSource.syslogTcpHandler

public SyslogTcpSource.syslogTcpHandler()
Method Detail

setEventSize

public void setEventSize(int eventSize)

setFormater

public void setFormater(Map<String,String> prop)

messageReceived

public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
                            org.jboss.netty.channel.MessageEvent mEvent)
Overrides:
messageReceived in class org.jboss.netty.channel.SimpleChannelHandler


Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.