eea.rabbitmq.client 1.9

Python RabbitMQ client

Basic RabbitMQ Python connector.

Contents

Contents

• Contents

• Introduction

• API

  • Strings vs. bytes

• Changelog

  • 1.9 - (2020-05-13)

  • 1.8 - (2019-01-28)

  • 1.7 - (2018-09-24)

  • 1.6 - (2018-08-21)

  • 1.5 - (2017-12-12)

  • 1.4 - (2017-04-24)

  • 1.3 - (2016-09-05)

  • 1.2 - (2016-08-29)

  • 1.1 - (2016-05-12)

  • 1.0 - (2016-05-04)

Introduction

eea.rabbitmq.client is a connector for a RabbitMQ server.

API

Usage example:

from eea.rabbitmq.client import RabbitMQConnector

rabbit_config = {
    'rabbit_host': "10.0.0.1",
    'rabbit_port': "8080",
    'rabbit_username': "admin",
    'rabbit_password': "admin"
}
queue_name = "QUEUE_NAME"

rabbit = RabbitMQConnector(**rabbit_config)
rabbit.open_connection()
rabbit.declare_queue(queue_name)
rabbit.send_message(queue_name, "body text")
rabbit.close_connection()

Strings vs. bytes

RabbitMQ messages are bytes, though they may optionally have an encoding flag. When consuming messages, in Python 3, they are received as bytes, and should be decoded:

method, properties, body = rabbit.get_message(queue_name)
message = body.decode(properties.content_encoding or 'ascii')

Changelog

1.9 - (2020-05-13)

• Feature: added Python3 support. [mgax refs #116195]

1.8 - (2019-01-28)

• Jenkins: Add sonarqube step [avoinea refs #101552]

1.7 - (2018-09-24)

• Change: Remove plone utilities for RabbitMQ client. (Moved in https://github.com/eea/eea.rabbitmq.plone) [GhitaB refs #91506]

1.6 - (2018-08-21)

• Feature: add configuration and utilities for RabbitMQ client [GhitaB refs #91506]

• Change: updated URLs pointing to eea.europa.eu with https:// [alecghica refs #95849]

1.5 - (2017-12-12)

• Change: Replace eeacms/zptlint with eeacms/plone-test:4 zptlint [avoinea refs #90415]

1.4 - (2017-04-24)

• Change: updated package information [eduard-fironda]

1.3 - (2016-09-05)

• Bug fix: fixed pylint [chiridra refs #72772]

1.2 - (2016-08-29)

• Change: disabled hearbeat interval to avoid disconnections. [chiridra refs #72772]

1.1 - (2016-05-12)

• Change: turned package into a proper plone package [ichim-david refs #71940]

1.0 - (2016-05-04)

• Feature: added documentation [alecghica refs #69689]

• Bug fix: fixed package structure [alecghica refs #69689]

• Feature: innitial release [szabozo0 refs #69689]