Metadata-Version: 2.0
Name: swarm-bus
Version: 3.5
Summary: AMQP layer for communicating with the ESB.
Home-page: https://bitbucket.org/monalgroup/swarm-bus
Author: The Swarm Team
Author-email: dev@hiventy.com
License: GPL License
Description-Content-Type: UNKNOWN
Keywords: ESB,tools,swarm,bus
Platform: UNKNOWN
Classifier: Intended Audience :: Developers
Classifier: Operating System :: OS Independent
Classifier: Topic :: Software Development
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 2.7
Requires-Dist: boto (==2.49.0)
Requires-Dist: kombu (==4.0.2)

Swarm-Bus
=========

Client side implementation of an ESB via Amazon SQS.

Simple Usage
------------

::

    uri = 'sqs://LOGIN:PASSWORD@'
    transport = {
        'region': 'eu-west-1',
        'exchange': 'swarm',
        'queue_name_prefix': 'dev-%(hostname)s-',
        'office_hours': False,
        'use_priorities': True,
        'priorities': ['low', 'high'],
        'queue_living': 864000,       # Default living message
        'queue_sleeping': 0,          # Default sleep time between messages
        'queue_visibility': 30,       # Default visibility message
        'queue_waiting': 10,          # Default long polling seconds
    }
    queues = {
      'my_queue': {
          'route': 'my.queue.route',  # Specific route
          'sleep': 60,                # Seconds before next call to SQS
          'visibility': 1800,         # Visibility message in queue
          'wait': 20                  # Long polling seconds
      },
      'my_second_queue': {}           # Will be automaticaly filled/completed
    }

    bus = AMQP(uri, transport, queues)
    bus.connect()

    # We purge a known queue
    bus.purge_queue('my_queue')

    # Now we add a new queue on the fly
    bus.register_queue('new_queue', {'wait': 20})

    bus.close()


Using as a producer
-------------------

::

    with AMQP(uri, transport, queues) as producer:
        producer.publish(
            'my_queue',
            {'id': 42},
            1  # Optional, specify 'high' priority queue
        )


Using as a consumer
-------------------

::

    def print_routing_key(body, message):
        id_ = body['id']
        rk = message.delivery_info['routing_key']
        print("[x] %r:%r" % (rk, id_))

    def ack_message(body, message):
        message.ack()

    def error_handler(body, message):
        raise ValueError('Error while processing message')

    with AMQP(uri, transport, queues) as consumer:
        consumer.consume(
            'my_queue',
            [print_routing_key, ack_message],
            error_handler
        )


