org.apache.storm.sql.runtime

Class AbstractChannelHandler

java.lang.Object

org.apache.storm.sql.runtime.AbstractChannelHandler

All Implemented Interfaces:

ChannelHandler

public abstract class AbstractChannelHandler
extends Object
implements ChannelHandler

Field Summary

Fields

Modifier and Type	Field and Description
static AbstractChannelHandler	PASS_THROUGH

Constructor Summary

Constructors

Constructor and Description
AbstractChannelHandler()

Method Summary

Modifier and Type	Method and Description
void	channelInactive(ChannelContext ctx) The producer of the data has indicated that the channel is no longer active.
abstract void	dataReceived(ChannelContext ctx, Values data)
void	exceptionCaught(Throwable cause)
void	flush(ChannelContext ctx)
void	setSource(ChannelContext ctx, Object source)

Methods inherited from class java.lang.Object

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

Field Detail

PASS_THROUGH

public static final AbstractChannelHandler PASS_THROUGH

Constructor Detail

AbstractChannelHandler

public AbstractChannelHandler()

Method Detail

dataReceived

public abstract void dataReceived(ChannelContext ctx,
                                  Values data)

Specified by:

dataReceived in interface ChannelHandler

channelInactive

public void channelInactive(ChannelContext ctx)

Description copied from interface: ChannelHandler

The producer of the data has indicated that the channel is no longer active.

Specified by:

channelInactive in interface ChannelHandler

exceptionCaught

public void exceptionCaught(Throwable cause)

Specified by:

exceptionCaught in interface ChannelHandler

flush

public void flush(ChannelContext ctx)

Specified by:

flush in interface ChannelHandler

setSource

public void setSource(ChannelContext ctx,
                      Object source)

Specified by:

setSource in interface ChannelHandler