lib/dripdrop/publisher.rb in dripdrop-0.0.2 vs lib/dripdrop/publisher.rb in dripdrop-0.0.3

- old
+ new

@@ -22,11 +22,14 @@ json = message.to_hash.to_json websockets.each {|ws| ws.send(json)} end end + + #WebSocket server that rebroadcasts all DripDrop::Messages it subscribes to as JSON class Publisher attr_reader :sub_address, :sub_collector, :ws_address + def initialize(sub_address='tcp://127.0.0.1:2901',ws_address='ws://127.0.0.1:2902') @sub_address = URI.parse(sub_address) @ws_address = URI.parse(ws_address) @sub_collector = PublisherCollector.new('tcp://127.0.0.1:2901') end