# encoding: utf-8
subscriber = $events.getSubscriber()
subscriber.subscribeLocally(lambda { |subscription|
  subscription.setChannel("subscription channel")
  subscription.setId("subscription id")
}) { |it|
  $console.log("sub.rb 收到事件", it.getData(), it.getTime(), it.getChannel())
}
subscriber.subscribeGlobally(lambda { |subscription|
  subscription.setChannel("subscription channel")
  subscription.setId("subscription id")
}) { |it|
  $console.log("sub.rb 收到事件", it.getData(), it.getTime(), it.getChannel())
}
mainThread = $script.getThreads().getMain()
timer = mainThread.getTimer()
timer.setTimeout(lambda { |params|
  # 保持脚本3秒钟不结束
}, 3000)