Class: Weeter::Plugins::Subscription::Http::UpdateServer

Inherits:
EM::Connection
  • Object
show all
Includes:
EM::HttpServer
Defined in:
lib/weeter/plugins/subscription/http.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#tweet_consumer ⇒ Object

Returns the value of attribute tweet_consumer.



34
35
36
 
# File 'lib/weeter/plugins/subscription/http.rb', line 34

def tweet_consumer
  @tweet_consumer
end

Instance Method Details

#process_http_request ⇒ Object 



36
37
38
39
40
41
 
# File 'lib/weeter/plugins/subscription/http.rb', line 36

def process_http_request
  Weeter.logger.info("Reconnecting Twitter stream")
  filter_params = MultiJson.decode(@http_post_content)
  tweet_consumer.reconnect(filter_params)
  EM::DelegatedHttpResponse.new(self).send_response
end