# ***** BEGIN LICENSE BLOCK *****
#
# For copyright and licensing please refer to COPYING.
#
# ***** END LICENSE BLOCK *****
"""
Example of simple publisher, loop and send messages as fast as we can
"""

import sys
import time

from pika.adapters import BlockingConnection
from pika.connection import ConnectionParameters
from pika import BasicProperties

if __name__ == '__main__':
    # Connect to RabbitMQ
    host = (len(sys.argv) > 1) and sys.argv[1] or '127.0.0.1'
    connection = BlockingConnection(ConnectionParameters(host))

    # Open the channel
    channel = connection.channel()

    # Declare the queue
    channel.queue_declare(queue="test", durable=True,
                          exclusive=False, auto_delete=False)

    # Initialize our timers and loop until external influence stops us
    count = 0
    start_time = time.time()
    while True:
        try:
            # Construct a message and send it
            message = "BlockingConnection.channel.basic_publish #%i" % count

            # Create properties with when we sent the message, the app_id
            # user we connected with, a content type and non persisted messages
            properties = BasicProperties(timestamp=time.time(),
                                         app_id=__file__,
                                         user_id='guest',
                                         content_type="text/plain",
                                         delivery_mode=1)

            # Send the message
            channel.basic_publish(exchange='',
                                  routing_key="test",
                                  body=message,
                                  properties=properties)
            count += 1
            if not count % 1000:
                duration = time.time() - start_time
                print "%i Messages Sent: %.8f per second" % (count,
                                                             count / duration)

        # Close when someone presses CTRL-C
        except KeyboardInterrupt:
            break

    print "CTRL-C Received, closing"
    connection.close()