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

- minor changes

parent 307038a6
No related branches found
No related tags found
No related merge requests found
bus = require './messagebus'
log = require './bbblogger'
messageReceiver = null
exports.registerMessageReceiver = (callback) ->
messageReceiver = callback
exports.processLoginMessage = (data, callback) ->
bus.sendMessage(data, (err, result) ->
if (err)
......
......@@ -2,12 +2,12 @@ postal = require('postal')
redisrpc = require './redispubsub'
crypto = require 'crypto'
receiveMessage = (callback) ->
exports.receiveMessage = (callback) ->
postal.subscribe({
channel: replyTo.channel,
topic: replyTo.topic,
channel: "receiveChannel"
topic: "broadcast",
callback: (msg, envelope) ->
callback( msg.err, msg.data )
callback( msg )
})
......
......@@ -81,16 +81,16 @@ subClient.on("message", (channel, jsonMsg) ->
data: response
})
else
if message.meetingId?
postal.publish({
channel: "bigbluebuttonAppChannel"
topic: message.meetingId,
data: message
})
else
console.log("Invalid message: #{jsonMsg}")
sendToController message
)
sendToController = (message) ->
postal.publish({
channel: "receiveChannel"
topic: "broadcast",
data: message
})
initialize()
console.log("RPC: Subscribing message on channel [responseChannel]")
......
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