- cleanup

bbb-apps-common/src/main/scala/org/bigbluebutton/client/endpoint/redis/Red5AppsRedisSubscriberActor.scala

@@ -63,7 +63,6 @@ class Red5AppsRedisSubscriberActor(
     })
   }
 
-  //fromAkkaAppsJsonChannel
   addListener(forwardMsgToChannel)
   subscribe()
 }

bbb-common-message/src/main/java/org/bigbluebutton/common2/redis/RedisStorageService.java

@@ -37,7 +37,7 @@ public class RedisStorageService extends RedisAwareCommunicator {
     StatefulRedisConnection<String, String> connection;
 
     public void start() {
-        log.info("Starting RedisStorageService with client name: clientName={} password={}", clientName, this.password);
+        log.info("Starting RedisStorageService with client name: clientName={}", clientName);
         RedisURI redisUri = RedisURI.Builder.redis(this.host, this.port).withClientName(this.clientName)
                 .withPassword(this.password).build();
 
@@ -112,4 +112,4 @@ public class RedisStorageService extends RedisAwareCommunicator {
         result = commands.hmset(key, info);
         return result;
     }
-}
\ No newline at end of file
+}

bbb-common-web/src/main/scala/org/bigbluebutton/api2/endpoint/redis/WebRedisSubscriberActor.scala

@@ -10,9 +10,6 @@ import io.lettuce.core.pubsub.RedisPubSubListener
 
 object WebRedisSubscriberActor {
 
-  //  val channels = Seq(fromAkkaAppsRedisChannel)
-  //  val patterns = Seq("bigbluebutton:from-bbb-apps:*")
-
   def props(
       system:              ActorSystem,
       jsonMsgBus:          JsonMsgFromAkkaAppsBus,

bbb-screenshare/app/src/main/scala/org/bigbluebutton/app/screenshare/redis/ScreenshareRedisSubscriberActor.scala

@@ -40,26 +40,6 @@ class ScreenshareRedisSubscriberActor(
     jsonMsgBus,
     redisConfig) {
 
-  /**
-   * override def addListener(forwardMsgToChannel: String) {
-   * connection.addListener(new RedisPubSubListener[String, String] {
-   * def message(channel: String, message: String): Unit = {
-   * println("**** RECEIVED MESSASGE FROm CHANNLE " + channel)
-   * if (channelsToSubscribe.contains(channel)) {
-   * val receivedJsonMessage = new ReceivedJsonMessage(channel, message)
-   * jsonMsgBus.publish(IncomingJsonMessage(forwardMsgToChannel, receivedJsonMessage))
-   * }
-   * }
-   * def message(pattern: String, channel: String, message: String): Unit = {
-   * log.debug(s"RECEIVED:\n ${message} \n")
-   * }
-   * def psubscribed(pattern: String, count: Long): Unit = { log.info("Subscribed to pattern {}", pattern) }
-   * def punsubscribed(pattern: String, count: Long): Unit = { log.info("Unsubscribed from pattern {}", pattern) }
-   * def subscribed(channel: String, count: Long): Unit = { log.info("Subscribed to pattern {}", channel) }
-   * def unsubscribed(channel: String, count: Long): Unit = { log.info("Unsubscribed from channel {}", channel) }
-   * })
-   * }
-   */
   addListener(forwardMsgToChannel)
   subscribe()
 }