Skip to content
Snippets Groups Projects
Commit fc161ce8 authored by Richard Alam's avatar Richard Alam
Browse files

- fix compile issue

parent 9e864d4f
No related branches found
No related tags found
No related merge requests found
......@@ -5,7 +5,7 @@ import scala.concurrent.duration._
import scala.concurrent.ExecutionContext.Implicits.global
import akka.actor.ActorSystem
import org.bigbluebutton.SystemConfiguration
import org.bigbluebutton.common.converters.ToJsonEncoder
//import org.bigbluebutton.common.converters.ToJsonEncoder
class RedisPublisher(val system: ActorSystem) extends SystemConfiguration {
......@@ -15,13 +15,13 @@ class RedisPublisher(val system: ActorSystem) extends SystemConfiguration {
// CLIENT LIST on redis-cli
redis.clientSetname("BbbTranscodeAkkaPub")
val encoder = new ToJsonEncoder()
def sendPingMessage() {
val json = encoder.encodePubSubPingMessage("BbbTranscode", System.currentTimeMillis())
redis.publish("bigbluebutton:to-bbb-apps:system", json)
}
//val encoder = new ToJsonEncoder()
//def sendPingMessage() {
// val json = encoder.encodePubSubPingMessage("BbbTranscode", System.currentTimeMillis())
// redis.publish("bigbluebutton:to-bbb-apps:system", json)
//}
system.scheduler.schedule(10 seconds, 10 seconds)(sendPingMessage())
//system.scheduler.schedule(10 seconds, 10 seconds)(sendPingMessage())
def publish(channel: String, data: String) {
//println("PUBLISH TO [" + channel + "]: \n [" + data + "]")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment