#!/usr/bin/python
import pika
 
# Use plain credentials for authentication
mq_creds  = pika.PlainCredentials(
    username = "guest",
    password = "guest")
 
# Use localhost
mq_params = pika.ConnectionParameters(
    host         = "localhost",
    credentials  = mq_creds,
    virtual_host = "/")
 
# Anyone subscribing to topic "mymessages" receives our messages
mq_exchange    = "amq.topic"
mq_routing_key = "mymessages"
 
# This a connection object
mq_conn = pika.BlockingConnection(mq_params)
 
# This is one channel inside the connection
mq_chan = mq_conn.channel()
 
import readline
print("Press Ctrl+C to quit.\n")
 
while True:
  text = raw_input("Enter your message: ")
  print("Sending '" + text + "'")
  mq_chan.basic_publish(
      exchange    = mq_exchange,
      routing_key = mq_routing_key,
      body        = text)