package backtype.storm.topology.base;

import backtype.storm.task.TopologyContext;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.transactional.ITransactionalSpout;
import backtype.storm.transactional.TransactionAttempt;
import backtype.storm.transactional.TransactionalOutputCollector;
import java.util.Map;

public abstract class BaseTransactionalSpout implements ITransactionalSpout {
    String _id;
    
    public BaseTransactionalSpout(String id) {
        _id = id;
    }
    
    @Override
    public void open(Map conf, TopologyContext context) {
    }

    @Override
    public void close() {        
    }

    @Override
    public Map<String, Object> getComponentConfiguration() {
        return null;
    }

    @Override
    public String getId() {
        return _id;
    }    
}

@@ -59,259 +59,40 @@
 rm.t
-ask.TopologyContext;%0Aimport backtype.storm.topology.OutputFieldsDeclarer;%0Aimport backtype.storm.transactional.ITransactionalSpout;%0Aimport backtype.storm.transactional.TransactionAttempt;%0Aimport backtype.storm.transactional.TransactionalOutputCollector
+ransactional.ITransactionalSpout
 ;%0Aim
@@ -254,24 +254,24 @@
 tring id) %7B%0A
+
         _id 
@@ -285,146 +285,8 @@
    %7D
-%0A    %0A    @Override%0A    public void open(Map conf, TopologyContext context) %7B%0A    %7D%0A%0A    @Override%0A    public void close() %7B        %0A    %7D
 %0A%0A  

fix BaseTransactionalSpout