Feature request: the server should speak HTTP (as well as raw JSON-over-TCP) about zenqueue HOT 5 CLOSED

from eventlet import coros
from zenqueue.queue import Queue
from zenqueue.server import QueueServer

def main():
    queue = Queue(mode='async')
    # QueueServer accepts an optional `queue` parameter which, if provided,
    # will be served by the server.
    http_server = QueueServer(method='http', queue=queue)
    native_server = QueueServer(method='native', queue=queue)
    # Run each of the servers on a pool, so that we can `wait_all()` for them to
    # finish.
    pool = coros.CoroutinePool()
    pool.execute_async(http_server.serve, interface='0.0.0.0', port=3080)
    pool.execute_async(native_server.serve, interface='0.0.0.0', port=3000)
    pool.wait_all()

if __name__ == '__main__':
    try:
        main()
    except KeyboardInterrupt:
        pass

from zenqueue.client import QueueClient
from zenqueue.server import QueueServer

def main():
    client = QueueClient(method='native', host='127.0.0.1', port=3000)
    # Because the client's interface matches exactly that of the `Queue()`, we can
    # pass it to the `QueueServer()` constructor as if it were a queue.
    server = QueueServer(method='http', queue=client)
    server.serve(interface='0.0.0.0', port=3080)

if __name__ == '__main__':
    main()