org.thales.punch.libraries.storm.spout

Class RelpInput

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseRichSpout

org.thales.punch.libraries.storm.api.BaseInputNode

org.thales.punch.libraries.storm.spout.AbstractSocketInput<org.thales.punch.netty.relp.proto.RELPFrame>

org.thales.punch.libraries.storm.spout.RelpInput

All Implemented Interfaces:

Serializable, org.apache.storm.spout.ISpout, org.apache.storm.topology.IComponent, org.apache.storm.topology.IRichSpout, org.thales.punch.netty.api.INettyReaderCallback<org.thales.punch.netty.relp.proto.RELPFrame>

public class RelpInput
extends AbstractSocketInput<org.thales.punch.netty.relp.proto.RELPFrame>
implements org.thales.punch.netty.api.INettyReaderCallback<org.thales.punch.netty.relp.proto.RELPFrame>

The Relp listening spout.

Author:

dimi

See Also:

Serialized Form

Field Summary

Fields inherited from class org.thales.punch.libraries.storm.spout.AbstractSocketInput

charset

Fields inherited from class org.thales.punch.libraries.storm.api.BaseInputNode

collector, exitCondition, latencyRecordSender, loadController, metricContext, myself, nodeSettings

Constructor Summary

Constructors

Constructor and Description
RelpInput(org.thales.punch.libraries.storm.api.NodeSettings spoutSettings, org.thales.punch.libraries.storm.api.ITopologySettings topologySettings) Create a new Relp spout

Method Summary

Modifier and Type	Method and Description
void	close()
Class<?>	getType()
void	nextTuple()
void	onReceive(io.netty.channel.ChannelHandlerContext ctx, org.thales.punch.netty.api.INettyTuple<org.thales.punch.netty.relp.proto.RELPFrame> nettyTuple)
void	open(Map conf, org.apache.storm.task.TopologyContext topologyContext, org.apache.storm.spout.SpoutOutputCollector collector) Setup this spout before it starts receiving data and emitting tuples into the topology.

Methods inherited from class org.thales.punch.libraries.storm.spout.AbstractSocketInput

ack, fail, getSocketHostAddress

Methods inherited from class org.thales.punch.libraries.storm.api.BaseInputNode

deactivate, declareOutputFields, getPublishedStreams, regulate, sendLatencyRecord

Methods inherited from class org.apache.storm.topology.base.BaseRichSpout

activate

Methods inherited from class org.apache.storm.topology.base.BaseComponent

getComponentConfiguration

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.netty.api.INettyReaderCallback

onActive, onInactive, onThrowable

Methods inherited from interface org.thales.punch.libraries.storm.api.ISpout

registerNextTupleCallback

Methods inherited from interface org.apache.storm.spout.ISpout

activate

Methods inherited from interface org.apache.storm.topology.IComponent

getComponentConfiguration

Constructor Detail

RelpInput

public RelpInput(org.thales.punch.libraries.storm.api.NodeSettings spoutSettings,
                 org.thales.punch.libraries.storm.api.ITopologySettings topologySettings)

Create a new Relp spout

Parameters:

spoutSettings - the spout configuration.

topologySettings - the spout configuration subsection

Method Detail

open

public void open(Map conf,
                 org.apache.storm.task.TopologyContext topologyContext,
                 org.apache.storm.spout.SpoutOutputCollector collector)

Description copied from class: AbstractSocketInput

Setup this spout before it starts receiving data and emitting tuples into the topology.

This is called by the Storm runtime at topology activation.

Specified by:

open in interface org.apache.storm.spout.ISpout

Overrides:

open in class AbstractSocketInput<org.thales.punch.netty.relp.proto.RELPFrame>

Parameters:

conf - storm configuration

topologyContext - the storm topology context

collector - the output collector for emitting tuples.

nextTuple

public void nextTuple()

Specified by:

nextTuple in interface org.apache.storm.spout.ISpout

onReceive

public void onReceive(io.netty.channel.ChannelHandlerContext ctx,
                      org.thales.punch.netty.api.INettyTuple<org.thales.punch.netty.relp.proto.RELPFrame> nettyTuple)

Specified by:

onReceive in interface org.thales.punch.netty.api.INettyReaderCallback<org.thales.punch.netty.relp.proto.RELPFrame>

getType

public Class<?> getType()

Specified by:

getType in interface org.thales.punch.netty.api.INettyReaderCallback<org.thales.punch.netty.relp.proto.RELPFrame>

close

public void close()

Specified by:

close in interface org.apache.storm.spout.ISpout

Overrides:

close in class org.thales.punch.libraries.storm.api.BaseInputNode