From b7b5cf972e0d0213bee6c548d94399534924852a Mon Sep 17 00:00:00 2001 From: Soren Macbeth Date: Wed, 29 Feb 2012 02:12:11 -0800 Subject: [PATCH] bump storm-redis-pubsub to storm 0.7.0 api --- .../src/jvm/yieldbot/storm/spout/RedisPubSubSpout.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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);