#!/usr/bin/env python
# ***** BEGIN LICENSE BLOCK *****
# Version: MPL 1.1/GPL 2.0
#
# The contents of this file are subject to the Mozilla Public License
# Version 1.1 (the "License"); you may not use this file except in
# compliance with the License. You may obtain a copy of the License at
# http://www.mozilla.org/MPL/
#
# Software distributed under the License is distributed on an "AS IS"
# basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
# the License for the specific language governing rights and
# limitations under the License.
#
# The Original Code is Pika.
#
# The Initial Developers of the Original Code are LShift Ltd, Cohesive
# Financial Technologies LLC, and Rabbit Technologies Ltd.  Portions
# created before 22-Nov-2008 00:00:00 GMT by LShift Ltd, Cohesive
# Financial Technologies LLC, or Rabbit Technologies Ltd are Copyright
# (C) 2007-2008 LShift Ltd, Cohesive Financial Technologies LLC, and
# Rabbit Technologies Ltd.
#
# Portions created by LShift Ltd are Copyright (C) 2007-2009 LShift
# Ltd. Portions created by Cohesive Financial Technologies LLC are
# Copyright (C) 2007-2009 Cohesive Financial Technologies
# LLC. Portions created by Rabbit Technologies Ltd are Copyright (C)
# 2007-2009 Rabbit Technologies Ltd.
#
# Portions created by Tony Garnock-Jones are Copyright (C) 2009-2010
# LShift Ltd and Tony Garnock-Jones.
#
# All Rights Reserved.
#
# Contributor(s): ______________________________________.
#
# Alternatively, the contents of this file may be used under the terms
# of the GNU General Public License Version 2 or later (the "GPL"), in
# which case the provisions of the GPL are applicable instead of those
# above. If you wish to allow use of your version of this file only
# under the terms of the GPL, and not to allow others to use your
# version of this file under the terms of the MPL, indicate your
# decision by deleting the provisions above and replace them with the
# notice and other provisions required by the GPL. If you do not
# delete the provisions above, a recipient may use your version of
# this file under the terms of any one of the MPL or the GPL.
#
# ***** END LICENSE BLOCK *****

'''
Example of simple producer, creates one message and exits.
'''

import logging
import sys
import pika
import time

from pika.adapters import AsyncoreConnection

logging.basicConfig(level=logging.DEBUG)

connection = None
channel = None

# Import all adapters for easier experimentation
import pika.adapters.tornado_connection as tornado_connection
from pika.adapters import *

def on_connected(connection):

    logging.info("demo_send: Connected to RabbitMQ")
    connection.channel(on_channel_open)


def on_channel_open(channel_):

    global channel
    channel = channel_

    logging.info("demo_send: Received our Channel")
    channel.queue_declare(queue="test", durable=True,
                          exclusive=False, auto_delete=False,
                          callback=on_queue_declared)


def on_queue_declared(frame):

    logging.info("demo_send: Queue Declared")
    for x in xrange(0, 10):
        message = "Hello World #%i: %.8f" %  (x, time.time())
        logging.info("Sending: %s" % message)
        channel.basic_publish(exchange='',
                              routing_key="test",
                              body=message,
                              properties=pika.BasicProperties(
                              content_type="text/plain",
                              delivery_mode=2,  # persistent
                              ))

    # Close our connection
    connection.close()

if __name__ == '__main__':

    host = (len(sys.argv) > 1) and sys.argv[1] or '127.0.0.1'
    parameters = pika.ConnectionParameters(host)
    connection = SelectConnection(parameters, on_connected)
    connection.ioloop.start()

@@ -2288,54 +2288,8 @@
 me%0A%0A
-from pika.adapters import AsyncoreConnection%0A%0A
 logg
@@ -2322,13 +2322,12 @@
 ing.
-DEBUG
+INFO
 )%0A%0Ac
@@ -2412,70 +2412,8 @@
 ion%0A
-import pika.adapters.tornado_connection as tornado_connection%0A
 from
@@ -2437,16 +2437,17 @@
 port *%0A%0A
+%0A
 def on_c
@@ -3011,17 +3011,16 @@
  %25.8f%22 %25
- 
  (x, tim
@@ -3377,17 +3377,18 @@
 y_mode=2
-,
+))
   # pers
@@ -3394,44 +3394,8 @@
 sist
-ent%0A                              ))
 %0A%0A  

Change logging level, remove unused imports and pep8/whitespace cleanup