old_contents: # -*- coding: utf-8 -*-
  
  import time
  import json
  import sys
  import pika
  from tweepy.streaming import StreamListener
  
  class Listener(StreamListener):
      def __init__(self):
          #setup rabbitMQ Connection
      	connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
  
      	self.channel = connection.channel()
  
      	#set max queue size
      	args = {"x-max-length": 2000}
  
      	self.channel.queue_declare(queue='social_data', arguments=args)
  
      def on_data(self, data):
          try:
              data = json.loads(data)
              if data["text"]:
                  self.verify(data)
                  time.sleep(5)
                  return True
  
          except BaseException, e:
              print("failed in ondata, ", str(e))
              time.sleep(5)
              pass
  
      def on_error(self, status):
          print(status)
  
      def verify(self, data):
          print "Incoming tweet from " + data["user"]["screen_name"]
          tweet = data["text"]
  
          # enqueue the tweet
          # print "enqueuing tweet " + tweet.encode("utf-8")
          self.channel.basic_publish(exchange='',
                                     routing_key='social_data',
                                     body=data["text"])
  
new_contents: # -*- coding: utf-8 -*-
  
  import time
  import json
  import sys
  import pika
  from tweepy.streaming import StreamListener
  
  class Listener(StreamListener):
      def __init__(self):
          #setup rabbitMQ Connection
      	connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
  
      	self.channel = connection.channel()
  
      	#set max queue size
      	args = {"x-max-length": 2000}
  
      	self.channel.queue_declare(queue='social_data', arguments=args)
  
      def on_data(self, data):
          try:
              data = json.loads(data)
              if data["text"]:
                  self.verify(data)
                  time.sleep(5)
                  return True
  
          except BaseException, e:
              print("failed in ondata, ", str(e))
              time.sleep(5)
              pass
  
      def on_error(self, status):
          print(status)
  
      def verify(self, data):
          print "Incoming tweet from " + data["user"]["screen_name"]
          tweet = data["text"]
  
          # enqueue the tweet
          self.channel.basic_publish(exchange='',
                                     routing_key='social_data',
                                     body=data["text"])
  
subject: Remove commented code