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