org.apache.storm.rocketmq.common.selector

Class DefaultTopicSelector

java.lang.Object

org.apache.storm.rocketmq.common.selector.DefaultTopicSelector

All Implemented Interfaces:

Serializable, TopicSelector

public class DefaultTopicSelector
extends Object
implements TopicSelector

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DefaultTopicSelector(String topicName)
DefaultTopicSelector(String topicName, String tagName)

Method Summary

Modifier and Type	Method and Description
String	getTag(ITuple tuple)
String	getTopic(ITuple tuple)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTopicSelector

public DefaultTopicSelector(String topicName,
                            String tagName)

DefaultTopicSelector

public DefaultTopicSelector(String topicName)

Method Detail

getTopic

public String getTopic(ITuple tuple)

Specified by:

getTopic in interface TopicSelector

getTag

public String getTag(ITuple tuple)

Specified by:

getTag in interface TopicSelector