org.thales.punch.libraries.storm.bolt.factory

Class LumberjackBoltFactory

java.lang.Object

org.thales.punch.libraries.storm.bolt.factory.LumberjackBoltFactory

All Implemented Interfaces:

org.thales.punch.libraries.storm.api.IBoltFactory

public class LumberjackBoltFactory
extends Object
implements org.thales.punch.libraries.storm.api.IBoltFactory

Setup a Syslog bolt.

Nothing complex, the bolt is forwarding everything to a next Syslog hop. If that server is our SYslogSpout, you can use the acknowledge mode.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPE The key referencing the associated bolt.

Constructor Summary

Constructors

Constructor and Description
LumberjackBoltFactory()

Method Summary

Modifier and Type	Method and Description
LumberjackOutput	createBolt(org.thales.punch.platform.api.IPlatform platform, org.thales.punch.libraries.storm.api.NodeSettings config, org.thales.punch.libraries.storm.api.ITopologySettings topoConfig)
List<org.thales.punch.libraries.storm.api.StreamDeclaration>	getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings boltSettings)

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.libraries.storm.api.IBoltFactory

getStaticResources

Field Detail

TYPE

public static final String TYPE

The key referencing the associated bolt.

See Also:

Constant Field Values

Constructor Detail

LumberjackBoltFactory

public LumberjackBoltFactory()

Method Detail

getPublishedStreamConfig

public List<org.thales.punch.libraries.storm.api.StreamDeclaration> getPublishedStreamConfig(org.thales.punch.libraries.storm.api.NodeSettings boltSettings)

Specified by:

getPublishedStreamConfig in interface org.thales.punch.libraries.storm.api.IBoltFactory

createBolt

public LumberjackOutput createBolt(org.thales.punch.platform.api.IPlatform platform,
                                   org.thales.punch.libraries.storm.api.NodeSettings config,
                                   org.thales.punch.libraries.storm.api.ITopologySettings topoConfig)

Specified by:

createBolt in interface org.thales.punch.libraries.storm.api.IBoltFactory