org.openkilda.wfm.topology.TestingKafkaBolt Class Reference

Inheritance diagram for org.openkilda.wfm.topology.TestingKafkaBolt:

Public Member Functions
	TestingKafkaBolt ()
void	execute (Tuple tuple)
void	prepare (Map stormConf, TopologyContext context, OutputCollector collector)
void	cleanup ()

Protected Member Functions
void	process (Tuple input)

Detailed Description

Overridden KafkaBolt for testing purposes. It doesn't need any configurations and is easy to integrate with storm junit tests.

Definition at line 29 of file TestingKafkaBolt.java.

Constructor & Destructor Documentation

TestingKafkaBolt()

org.openkilda.wfm.topology.TestingKafkaBolt.TestingKafkaBolt

(

)

Definition at line 31 of file TestingKafkaBolt.java.

Member Function Documentation

cleanup()

void org.openkilda.wfm.topology.TestingKafkaBolt.cleanup

(

)

Definition at line 47 of file TestingKafkaBolt.java.

execute()

void org.openkilda.wfm.topology.TestingKafkaBolt.execute

(

Tuple

tuple

)

Definition at line 39 of file TestingKafkaBolt.java.

prepare()

void org.openkilda.wfm.topology.TestingKafkaBolt.prepare	(	Map	stormConf,
		TopologyContext	context,
		OutputCollector	collector
	)

Definition at line 43 of file TestingKafkaBolt.java.

process()

void org.openkilda.wfm.topology.TestingKafkaBolt.process ( Tuple  input )

protected

Definition at line 35 of file TestingKafkaBolt.java.

---

The documentation for this class was generated from the following file:

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/wfm/src/test/java/org/openkilda/wfm/topology/TestingKafkaBolt.java