Class: Databasedotcom::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/databasedotcom-streaming.rb

Instance Method Summary collapse

Instance Method Details

#subscribe_to_push_topic(push_topic_name, &callback) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
 
# File 'lib/databasedotcom-streaming.rb', line 7

def subscribe_to_push_topic(push_topic_name, &callback)
  raise 'You must run this method inside of an EventMachine loop.' unless EM.reactor_running?
  faye = Faye::Client.new(self.instance_url+'/cometd/25.0')
  puts 'connecting to '+self.instance_url+'/cometd/25.0'
  faye.bind 'transport:down' do
      puts 'trying to refresh token'
      puts list_sobjects # to refresh the access token
      faye.set_header 'Authorization', "OAuth #{self.oauth_token}"
    end
  faye.subscribe('/topic/'+push_topic_name){ |message| callback.call(message) }
end