from setuptools import setup, find_packages


setup(
    name="pooled-pika",
    version="0.1.1",
    py_modules=["pooled_pika"],
    install_requires=["twisted>=13.2.0", "pika>=0.10.0"],
    description="a connection pool wrapper about async pika",
    long_description="""
Notice
------
just support twisted connection now

Usage
-----
sample:

.. code :: python

    # with connection
    from pika import URLParameters
    from pooled_pika import PooledConn
    
    AMQP_PARAM = URLParameters('amqp://user:pwd@amqpserver')
    pooled_conn = PooledConn(AMQP_PARAM)
    d = pooled_conn.acquire()
    d.addCallbacks(_on_conn, _on_err_conn) # you will get a TwistedProtocolConnection object
    d.addErrback(_on_err)
    d.addBoth(pooled_conn.release)  # must release what acquired anyway

or:

.. code :: python

    # with channel
    from pika import URLParameters
    from pooled_pika import PooledConn
    
    AMQP_PARAM = URLParameters('amqp://user:pwd@amqpserver')
    pooled_conn = PooledConn(AMQP_PARAM)
    d = pooled_conn.acquire(channel=True)
    d.addCallbacks(_on_channel, _on_err_channel) # you will get a TwistedChannel object
    d.addErrback(_on_err)
    d.addBoth(pooled_conn.release)  # must release what acquired anyway
""",
    author="Zephor",
    author_email="zephor@qq.com",
    url="https://github.com/Zephor5/pooled-pika",
    license="BSD 3-clause",
    packages=find_packages()
)


from setuptools import setup, find_packages


setup(
    name="pooled-pika",
    version="0.1.2",
    py_modules=["pooled_pika"],
    install_requires=["twisted>=13.2.0", "pika>=0.10.0"],
    description="a connection pool wrapper about async pika",
    long_description="""
Notice
------
just support twisted connection now

Usage
-----
sample:

.. code :: python

    # with connection
    from pika import URLParameters
    from pooled_pika import PooledConn
    
    AMQP_PARAM = URLParameters('amqp://user:pwd@amqpserver')
    pooled_conn = PooledConn(AMQP_PARAM)
    d = pooled_conn.acquire()
    d.addCallbacks(_on_conn, _on_err_conn) # you will get a TwistedProtocolConnection object
    d.addErrback(_on_err)
    d.addBoth(pooled_conn.release)  # must release what acquired anyway

or:

.. code :: python

    # with channel
    from pika import URLParameters
    from pooled_pika import PooledConn
    
    AMQP_PARAM = URLParameters('amqp://user:pwd@amqpserver')
    pooled_conn = PooledConn(AMQP_PARAM)
    d = pooled_conn.acquire(channel=True)
    d.addCallbacks(_on_channel, _on_err_channel) # you will get a TwistedChannel object
    d.addErrback(_on_err)
    d.addBoth(pooled_conn.release)  # must release what acquired anyway
""",
    author="Zephor",
    author_email="zephor@qq.com",
    url="https://github.com/Zephor5/pooled-pika",
    license="BSD 3-clause",
    packages=find_packages()
)


set version 0.1.2