* VRFS-19; finishing touches on making session messaging work via jam-web
This commit is contained in:
parent
b829a0cdc3
commit
fd9770f0f3
|
|
@ -47,9 +47,9 @@ class MQRouter
|
|||
# iterate over each person in the session, and send a p2p message
|
||||
client_ids.each do |client_id|
|
||||
|
||||
@@log.debug "publishing to session:client #{music_session_id}:#{client_id} from client_id #{sender_client_id}"
|
||||
# put it on the topic exchange for clients
|
||||
self.class.client_exchange.publish(client_msg, :routing_key => "clients.#{music_session_id}")
|
||||
@@log.debug "publishing to session:#{music_session_id} client:#{client_id} from client:#{sender_client_id}"
|
||||
# put it on the topic exchange3 for clients
|
||||
self.class.client_exchange.publish(client_msg, :routing_key => "client.#{client_id}")
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -36,7 +36,7 @@ describe MQRouter do
|
|||
# mock up exchange
|
||||
MQRouter.client_exchange = double("client_exchange")
|
||||
|
||||
MQRouter.client_exchange.should_receive(:publish).with("a message", :routing_key => "clients.#{music_session.id}")
|
||||
MQRouter.client_exchange.should_receive(:publish).with("a message", :routing_key => "client.#{music_session_member2.client_id}")
|
||||
|
||||
@mq_router.user_publish_to_session(music_session, user1, "a message", :client_id => music_session_member1.client_id)
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue