Module: Restforce::Concerns::Streaming
- Included in:
- Data::Client
- Defined in:
- lib/restforce/concerns/streaming.rb
Defined Under Namespace
Classes: ReplayExtension
Instance Method Summary collapse
-
#faye ⇒ Object
Public: Faye client to use for subscribing to PushTopics.
- #replay_handlers ⇒ Object
-
#subscribe(channels, options = {}, &block) ⇒ Object
Public: Subscribe to a PushTopic.
Instance Method Details
#faye ⇒ Object
Public: Faye client to use for subscribing to PushTopics
18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 |
# File 'lib/restforce/concerns/streaming.rb', line 18 def faye unless [:instance_url] raise 'Instance URL missing. Call .authenticate! first.' end url = "#{[:instance_url]}/cometd/#{[:api_version]}" @faye ||= Faye::Client.new(url).tap do |client| client.set_header 'Authorization', "OAuth #{[:oauth_token]}" client.bind 'transport:down' do Restforce.log "[COMETD DOWN]" client.set_header 'Authorization', "OAuth #{authenticate!.access_token}" end client.bind 'transport:up' do Restforce.log "[COMETD UP]" end client.add_extension ReplayExtension.new(replay_handlers) end end |
#replay_handlers ⇒ Object
41 42 43 |
# File 'lib/restforce/concerns/streaming.rb', line 41 def replay_handlers @_replay_handlers ||= {} end |
#subscribe(channels, options = {}, &block) ⇒ Object
Public: Subscribe to a PushTopic
channels - The name of the PushTopic channel(s) to subscribe to. block - A block to run when a new message is received.
Returns a Faye::Subscription
12 13 14 15 |
# File 'lib/restforce/concerns/streaming.rb', line 12 def subscribe(channels, = {}, &block) Array(channels).each { |channel| replay_handlers[channel] = [:replay] } faye.subscribe Array(channels).map { |channel| "/topic/#{channel}" }, &block end |