import pika
import sys

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

channel = connection.channel()
channel.tx_select()

channel.queue_declare(queue='hello')

print "try forged message"
try:
  # This does not go through as the user is forged
  channel.basic_publish(exchange='', routing_key='hello',body='Forged Message', 
                        properties=pika.BasicProperties(user_id='fake'))
  channel.tx_commit()
except Exception as e:
  print "Cannot publish forged message"
  print e

#Get new channel and try good message with out forged id
channel = connection.channel()
channel.tx_select()

print "try anonymous message"
try:
  #This should go through as we pass the correct user
  channel.basic_publish(exchange='', routing_key='hello',body='anonymous Message')
  channel.tx_commit()
  print "published anonymous message"
except Exception as e:
  print "Cannot publish anonymous message"
  print e



print "try authenticated message"
try:
  #This should go through as we pass the correct user
  channel.basic_publish(exchange='', routing_key='hello',body='authenticated Message', 
                        properties=pika.BasicProperties(user_id='guest'))
  channel.tx_commit()
  print "published authenticated message"
except Exception as e:
  print "Cannot publish authenticated message"
  print e


print "Listening..."
def on_receive(ch, method, properties, body):
  print "Received: %r" % (body,) 
  if properties.user_id is None:
    print "Ignore anonymous message"
    return
  
  #At this point we can check if we trust this authenticated user... 
  
  print "Received from user: %r" % properties.user_id
  sys.exit()


channel.basic_consume(on_receive, queue='hello',no_ack=True)

channel.start_consuming()


connection.close()

The model training

Trainer training