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