override def open()

in tormenta-core/src/main/scala/com/twitter/tormenta/spout/Proxy.scala [22:35]

• 13 lines of code
• 1 McCabe index (conditional complexity)

  override def open(conf: JMap[_, _], topologyContext: TopologyContext, outputCollector: SpoutOutputCollector) =
    self.open(conf, topologyContext, outputCollector)
  override def nextTuple = self.nextTuple
  override def declareOutputFields(declarer: OutputFieldsDeclarer) = self.declareOutputFields(declarer)
  override def close = self.close
  override def ack(msgId: Object) = self.ack(msgId)
  override def fail(msgId: Object) = self.fail(msgId)
  override def deactivate = self.deactivate
  override def getComponentConfiguration = self.getComponentConfiguration
  override def activate = self.activate
}

class RichStormSpout(val self: IRichSpout,
    @transient callOnOpen: (TopologyContext) => Unit) extends SpoutProxy {