public class SyslogBoltFactory extends Object implements org.thales.punch.libraries.storm.api.IBoltFactory
Nothing complex, the bolt is forwarding everything to a next Syslog hop. If that server is our SYslogSpout, you can use the acknowledge mode.
Modifier and Type | Field and Description |
---|---|
static String |
TYPE
The key referencing the associated bolt.
|
Constructor and Description |
---|
SyslogBoltFactory() |
Modifier and Type | Method and Description |
---|---|
static void |
checkStormStreamWiring(org.thales.punch.settings.api.ISettingsMap boltSettings,
org.thales.punch.libraries.storm.api.StormSettings stormSettings)
This function checks that the storm streams declared in the storm settings of a bolt are inline
with the ones contained in the destination settings.
|
SyslogOutput |
createBolt(org.thales.punch.platform.api.IPlatform platform,
org.thales.punch.libraries.storm.api.NodeSettings config,
org.thales.punch.libraries.storm.api.ITopologySettings topoConfig) |
public static final String TYPE
public SyslogOutput createBolt(org.thales.punch.platform.api.IPlatform platform, org.thales.punch.libraries.storm.api.NodeSettings config, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig)
createBolt
in interface org.thales.punch.libraries.storm.api.IBoltFactory
public static void checkStormStreamWiring(org.thales.punch.settings.api.ISettingsMap boltSettings, org.thales.punch.libraries.storm.api.StormSettings stormSettings)
boltSettings
- boltSettingsstormSettings
- stormSettingsCopyright © 2023. All rights reserved.