Example of a Python rpc server

rpc_server.py

+# -*- coding: iso-8859-15 -*-
+#!/usr/bin/env python
+# 
+# For request like:
+# http://server/rmqplus/?FirstField=for&SecondField=this
+# return value:firstfield + ' ' + secondfield, status:1
+# in the upper request: "for this"
+# Any error: return status:0
+# 
+import pika
+import cjson
+import sys
+from pprint import pprint
+
+host = sys.argv[1]
+user = sys.argv[2]
+pwd = sys.argv[3]
+
+credentials = pika.PlainCredentials(user, pwd)
+connection = pika.BlockingConnection(
+    pika.ConnectionParameters(host=host, credentials=credentials))
+
+channel = connection.channel()
+
+channel.queue_declare(queue='rpc_queue', durable=True)
+
+
+def execute(din, dout):
+    try:
+        dout['value'] = din['FORM_FIRSTFIELD'] + ' ' + din['FORM_SECONDFIELD']
+        dout['status'] = 1
+    except:
+        dout['status'] = 0
+
+
+def on_request(ch, method, props, body):
+
+    # print "\nReceived '%s'" % (body,)
+    response = cjson.decode(body)
+    pprint(response['in'])
+    execute(response['in'], response['out'])
+    ch.basic_publish(exchange='',
+                     routing_key=props.reply_to,
+                     properties=pika.BasicProperties(correlation_id = \
+                                                         props.correlation_id),
+                     body=cjson.encode(response['out']))
+    ch.basic_ack(delivery_tag=method.delivery_tag)
+
+
+channel.basic_qos(prefetch_count=1)
+channel.basic_consume(queue='rpc_queue', on_message_callback=on_request)
+
+print(" [x] Awaiting RPC requests")
+channel.start_consuming()
+