org.apache.storm.rocketmq.common.selector

Interface TopicSelector

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultTopicSelector, FieldNameBasedTopicSelector

public interface TopicSelector
extends Serializable

Method Summary

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

Method Detail

getTopic

String getTopic(ITuple tuple)

getTag

String getTag(ITuple tuple)