Merge pull request gearpump#496 from huafengw/fix#493

clockfly · clockfly · commit 66d71b872a6c · 2015-02-16T10:29:59.000+08:00
fix gearpump#493 add implicit sender
diff --git a/examples/sol/src/main/scala/org/apache/gearpump/streaming/examples/sol/SOLStreamProducer.scala b/examples/sol/src/main/scala/org/apache/gearpump/streaming/examples/sol/SOLStreamProducer.scala
@@ -26,7 +26,7 @@ import org.apache.gearpump.streaming.task.{StartTime, Task, TaskContext}
 
 class SOLStreamProducer(taskContext : TaskContext, conf: UserConfig) extends Task(taskContext, conf) {
   import org.apache.gearpump.streaming.examples.sol.SOLStreamProducer._
-  import taskContext.{output, self}
+  import taskContext.output
 
   private val sizeInBytes = conf.getInt(SOLStreamProducer.BYTES_PER_MESSAGE).get
   private var messages : Array[String] = null
diff --git a/streaming/src/main/scala/org/apache/gearpump/streaming/task/Task.scala b/streaming/src/main/scala/org/apache/gearpump/streaming/task/Task.scala
@@ -146,12 +146,14 @@ trait TaskInterface {
 
 abstract class Task(taskContext : TaskContext, userConf : UserConfig) extends TaskInterface{
 
-  import taskContext.{appId, executorId, taskId, self}
+  import taskContext.{appId, executorId, taskId}
 
   val LOG: Logger = LogUtil.getLogger(getClass, app = appId, executor = executorId, task = taskId)
 
   protected implicit val system = taskContext.system
 
+  implicit val self = taskContext.self
+
   def onStart(startTime : StartTime) : Unit
 
   def onNext(msg : Message) : Unit
