public class LightTopology extends Object implements org.thales.punch.libraries.storm.api.INextTupleCallback, org.thales.punch.libraries.storm.core.api.ITopology
Constructor and Description |
---|
LightTopology(org.thales.punch.libraries.storm.api.ITopologySettings topoConfig) |
Modifier and Type | Method and Description |
---|---|
void |
addBolt(LightBoltRunner lightBolt)
Register a bolt as part of this topology.
|
void |
addBoltDispatcher(String boltComponentId,
LightBoltDispatcher lightBoltDispatcher) |
void |
addSpout(String spoutComponentId,
org.thales.punch.libraries.storm.api.ISpout spout)
Add a spout to the topology.
|
LightBoltDispatcher |
getBoltDispatcherById(String boltComponentId) |
int |
getBoltRcvQueueSize() |
LightComponent |
getComponentById(String componentId) |
String |
getInstanceId() |
int |
getMaxSpoutPending() |
int |
getMessageTimeoutSec() |
LightSpout |
getSpoutById(String componentId) |
String |
getStormId() |
Object |
getStormTopology() |
List<String> |
getStormTopologyPluginsJarPaths() |
boolean |
isEnabledMessageTimeout() |
boolean |
isSlowRateOnFailures() |
void |
onReceiveTuple() |
void |
run()
Running a light topology never returns.
|
public LightTopology(org.thales.punch.libraries.storm.api.ITopologySettings topoConfig)
public int getBoltRcvQueueSize()
public String getInstanceId()
getInstanceId
in interface org.thales.punch.libraries.storm.core.api.ITopology
public void addSpout(String spoutComponentId, org.thales.punch.libraries.storm.api.ISpout spout)
spoutComponentId
- the spout component idspout
- the spout itselfpublic void run()
public LightSpout getSpoutById(String componentId)
public void addBolt(LightBoltRunner lightBolt)
lightBolt
- ligtboltpublic LightComponent getComponentById(String componentId)
public int getMaxSpoutPending()
public boolean isEnabledMessageTimeout()
public boolean isSlowRateOnFailures()
public int getMessageTimeoutSec()
public String getStormId()
public void onReceiveTuple()
onReceiveTuple
in interface org.thales.punch.libraries.storm.api.INextTupleCallback
public LightBoltDispatcher getBoltDispatcherById(String boltComponentId)
public void addBoltDispatcher(String boltComponentId, LightBoltDispatcher lightBoltDispatcher)
public Object getStormTopology()
getStormTopology
in interface org.thales.punch.libraries.storm.core.api.ITopology
Copyright © 2023. All rights reserved.