Skip to main content

AMQPStorm connection pooling based on pika-pooling.

Project description

AMQPStorm connection pooling based on pika-pool.

Version Travis Coverage

usage

Get it:

pip install amqpstorm-pool

and use it:

import json

import amqpstorm
import amqpstorm_pool

uri = 'amqp://guest:guest@localhost:5672/%2F?heartbeat=60'
pool = amqpstorm_pool.QueuedPool(
    create=lambda: amqpstorm.UriConnection(uri),
    max_size=10,
    max_overflow=10,
    timeout=10,
    recycle=3600,
    stale=45,
)

with pool.acquire() as cxn:
    cxn.channel.queue.declare('fruits')
    cxn.channel.basic.publish(
        body=json.dumps({
            'type': 'banana',
            'description': 'they are yellow'
        }),
        exchange='',
        routing_key='fruits',
        properties={
            'content_type': 'text/plain',
            'headers': {'key': 'value'}
        }
    )

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

AMQPStorm-Pool-1.0.1.tar.gz (6.2 kB view hashes)

Uploaded Source

Built Distribution

AMQPStorm_Pool-1.0.1-py2.py3-none-any.whl (6.4 kB view hashes)

Uploaded Python 2 Python 3

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page