receive.py

#!/usr/bin/env python
import pika
import sys

credentials = pika.PlainCredentials('guest', 'guest')
parameters = pika.ConnectionParameters('localhost',
                                       5672,
                                       '/',
                                       credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()

def callback(ch, method, properties, body):
    print(" [x] header %r" % properties.headers)
    print(" [x] Received %r" % body)

channel.basic_consume(callback,
                      queue='rewrite-in',
                      no_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

send.py

#!/usr/bin/env python
import pika
import sys

credentials = pika.PlainCredentials('guest', 'guest')
parameters = pika.ConnectionParameters('localhost',
                                       5672,
                                       '/',
                                       credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()

if len(sys.argv) < 3:
    sys.exit('Usage: %s <from> <to>' % sys.argv[0])

email_from=sys.argv[1]
email_to=sys.argv[2]
fields = {}
fields['from'] = email_from
fields['to'] = email_to

data = ""
for line in sys.stdin:
    data += line

channel.basic_publish(exchange='email-in',
                      routing_key='rewrite',
                      properties=pika.BasicProperties(headers=fields),
                      body=data)

sys.exit(0)