diff --git a/storm-redis-pubsub/src/jvm/yieldbot/storm/spout/RedisPubSubSpout.java b/storm-redis-pubsub/src/jvm/yieldbot/storm/spout/RedisPubSubSpout.java index cb06989..6d15e73 100644 --- a/storm-redis-pubsub/src/jvm/yieldbot/storm/spout/RedisPubSubSpout.java +++ b/storm-redis-pubsub/src/jvm/yieldbot/storm/spout/RedisPubSubSpout.java @@ -14,12 +14,12 @@ import backtype.storm.spout.SpoutOutputCollector; import backtype.storm.task.TopologyContext; -import backtype.storm.topology.IRichSpout; +import backtype.storm.topology.base.BaseRichSpout; import backtype.storm.topology.OutputFieldsDeclarer; import backtype.storm.tuple.Fields; import backtype.storm.utils.Utils; -public class RedisPubSubSpout implements IRichSpout { +public class RedisPubSubSpout extends BaseRichSpout { static final long serialVersionUID = 737015318988609460L; static Logger LOG = Logger.getLogger(RedisPubSubSpout.class);