forked from bigbluebutton/bigbluebutton
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Moved akka-transcode messages to 2.0 format
- Loading branch information
1 parent
20fe7c2
commit d50f65f
Showing
39 changed files
with
558 additions
and
902 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
12 changes: 0 additions & 12 deletions
12
akka-bbb-transcode/src/main/java/org/bigbluebutton/transcode/core/api/ITranscodingInGW.java
This file was deleted.
Oops, something went wrong.
81 changes: 0 additions & 81 deletions
81
...-bbb-transcode/src/main/java/org/bigbluebutton/transcode/pubsub/RedisMessageReceiver.java
This file was deleted.
Oops, something went wrong.
38 changes: 38 additions & 0 deletions
38
akka-bbb-transcode/src/main/java/org/bigbluebutton/transcode/util/Constants.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,38 @@ | ||
| package org.bigbluebutton.transcode.util; | ||
|
|
||
| public class Constants { | ||
| public static final String WIDTH_RATIO = "width_ratio"; | ||
| public static final String HEIGHT_RATIO = "height_ratio"; | ||
| public static final String CALLERNAME = "callername"; | ||
| public static final String VOICE_CONF = "voice_conf"; | ||
| public static final String LOCAL_IP_ADDRESS = "local_ip_address"; | ||
| public static final String LOCAL_VIDEO_PORT = "local_video_port"; | ||
| public static final String REMOTE_VIDEO_PORT = "remote_video_port"; | ||
| public static final String DESTINATION_IP_ADDRESS = "destination_ip_address"; | ||
| public static final String SIP_HOST = "sip_host"; | ||
| public static final String TRANSCODER_TYPE = "transcoder_type"; | ||
| public static final String INPUT = "input"; | ||
| public static final String OUTPUT = "output"; | ||
| public static final String TRANSCODE_RTP_TO_RTMP = "transcode_rtp_to_rtmp"; | ||
| public static final String TRANSCODE_RTMP_TO_RTP = "transcode_rtmp_to_rtp"; | ||
| public static final String TRANSCODE_FILE_TO_RTP = "transcode_file_to_rtp"; | ||
| public static final String TRANSCODE_FILE_TO_RTMP = "transcode_file_to_rtmp"; | ||
| public static final String TRANSCODE_H264_TO_H263 = "transcode_h264_to_h263"; | ||
| public static final String TRANSCODE_ROTATE_RIGHT = "transcode_rotate_right"; | ||
| public static final String TRANSCODE_ROTATE_LEFT = "transcode_rotate_left"; | ||
| public static final String TRANSCODE_ROTATE_UPSIDE_DOWN = "transcode_rotate_upside_down"; | ||
| public static final String MODULE = "module"; | ||
| public static final String PROBE_RTMP = "probe_rtmp"; | ||
|
|
||
| public static final String HEADER = "header"; | ||
| public static final String CORE = "core"; | ||
| public static final String BODY = "body"; | ||
| public static final String ENVELOPE = "envelope"; | ||
| public static final String ROUTING = "routing"; | ||
| public static final String NAME = "name"; | ||
| public static final String SENDER = "sender"; | ||
| public static final String PARAMS = "params"; | ||
| public static final String TRANSCODER_ID = "transcoderId"; | ||
| public static final String MEETING_ID = "meetingId"; | ||
| public static final String VIDEO = "video"; | ||
| } |
18 changes: 9 additions & 9 deletions
18
akka-bbb-transcode/src/main/scala/org/bigbluebutton/Boot.scala
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,23 +1,23 @@ | ||
| package org.bigbluebutton | ||
|
|
||
| import akka.actor.{ ActorSystem, Props } | ||
| import scala.concurrent.duration._ | ||
| import redis.RedisClient | ||
| import scala.concurrent.{ Future, Await } | ||
| import scala.concurrent.ExecutionContext.Implicits.global | ||
| import akka.actor.ActorSystem | ||
|
|
||
| import org.bigbluebutton.endpoint.redis.{ RedisPublisher, AppsRedisSubscriberActor } | ||
| import org.bigbluebutton.transcode.pubsub.receivers.RedisMessageReceiver | ||
| import org.bigbluebutton.transcode.JsonMsgHdlrActor | ||
| import org.bigbluebutton.transcode.core.TranscodingInGW | ||
| import org.bigbluebutton.transcode.bus.InJsonMsgBus | ||
|
|
||
| object Boot extends App with SystemConfiguration { | ||
|
|
||
| implicit val system = ActorSystem("bigbluebutton-transcode-system") | ||
|
|
||
| val redisPublisher = new RedisPublisher(system) | ||
|
|
||
| var transcodingInGW = new TranscodingInGW(system, redisPublisher); | ||
| var inGW = new TranscodingInGW(system, redisPublisher) | ||
|
|
||
| val redisMsgReceiver = new RedisMessageReceiver(transcodingInGW); | ||
| val inJsonMsgBus = new InJsonMsgBus | ||
| val redisMessageHandlerActor = system.actorOf(JsonMsgHdlrActor.props(inGW)) | ||
| inJsonMsgBus.subscribe(redisMessageHandlerActor, toAkkaTranscodeJsonChannel) | ||
|
|
||
| val redisSubscriberActor = system.actorOf(AppsRedisSubscriberActor.props(system, redisMsgReceiver), "redis-subscriber") | ||
| val redisSubscriberActor = system.actorOf(AppsRedisSubscriberActor.props(system, inJsonMsgBus), "redis-subscriber") | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.