org.thales.punch.libraries.storm.core.topology

Class SimpleTopologyRegistry

java.lang.Object

org.thales.punch.libraries.storm.core.topology.SimpleTopologyRegistry

All Implemented Interfaces:

org.thales.punch.libraries.storm.core.api.ITopologyRegistry

public class SimpleTopologyRegistry
extends Object
implements org.thales.punch.libraries.storm.core.api.ITopologyRegistry

A simple registry for various configuration artifacts.

Author:

ddidier

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,Class<? extends org.thales.punch.libraries.storm.api.IBoltFactory>>	boltFactories The registered bolt factories by type.
protected Map<String,Class<? extends org.thales.punch.libraries.storm.api.ISpoutFactory>>	spoutFactories The registered spout factories by type.

Constructor Summary

Constructors

Constructor and Description
SimpleTopologyRegistry() Default constructor.

Method Summary

Modifier and Type	Method and Description
org.thales.punch.libraries.storm.api.IBoltFactory	boltFactoryFor(String type)
Class<? extends org.thales.punch.libraries.storm.api.IBoltFactory>	registerBoltFactory(String key, Class<? extends org.thales.punch.libraries.storm.api.IBoltFactory> clazz) Adds a bolt factory to the registry.
Class<? extends org.thales.punch.libraries.storm.api.ISpoutFactory>	registerSpoutFactory(String key, Class<? extends org.thales.punch.libraries.storm.api.ISpoutFactory> clazz) Adds a spout factory to the registry.
org.thales.punch.libraries.storm.api.ISpoutFactory	spoutFactoryFor(String type)

Methods inherited from class java.lang.Object

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

Field Detail

boltFactories

protected final Map<String,Class<? extends org.thales.punch.libraries.storm.api.IBoltFactory>> boltFactories

The registered bolt factories by type.

spoutFactories

protected final Map<String,Class<? extends org.thales.punch.libraries.storm.api.ISpoutFactory>> spoutFactories

The registered spout factories by type.

Constructor Detail

SimpleTopologyRegistry

public SimpleTopologyRegistry()

Default constructor.

Method Detail

boltFactoryFor

public org.thales.punch.libraries.storm.api.IBoltFactory boltFactoryFor(String type)

Specified by:

boltFactoryFor in interface org.thales.punch.libraries.storm.core.api.ITopologyRegistry

spoutFactoryFor

public org.thales.punch.libraries.storm.api.ISpoutFactory spoutFactoryFor(String type)

Specified by:

spoutFactoryFor in interface org.thales.punch.libraries.storm.core.api.ITopologyRegistry

registerBoltFactory

public Class<? extends org.thales.punch.libraries.storm.api.IBoltFactory> registerBoltFactory(String key,
                                                                                              Class<? extends org.thales.punch.libraries.storm.api.IBoltFactory> clazz)

Adds a bolt factory to the registry.

Parameters:

key - the key.

clazz - the class.

Returns:

the previous bolt factory registered with this key.

registerSpoutFactory

public Class<? extends org.thales.punch.libraries.storm.api.ISpoutFactory> registerSpoutFactory(String key,
                                                                                                Class<? extends org.thales.punch.libraries.storm.api.ISpoutFactory> clazz)

Adds a spout factory to the registry.

Parameters:

key - the key.

clazz - the class.

Returns:

the previous spout factory registered with this key.