override def open()

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

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

  override def open(conf: JMap[_, _], context: TopologyContext, coll: SpoutOutputCollector) {
    lockedFn.get(context)
    self.open(conf, context, coll)
  }