Neon MQ Connector

The Neon MQ Connector is an MQ interface for microservices.

Configuration

By default, this package will use ovos-config to read default configuration. In general, configuration should be passed to the MQConnector object at init.

Legacy Configuration

A global configuration for the MQ Connector may be specified at ~/.config/neon/mq_config.json. This configuration file may contain the following keys:

server: The hostname or IP address of the MQ server to connect to. If left blank, this defaults to "localhost"
port: The port used by the MQ server. If left blank, this defaults to 5672
users: A mapping of service names to credentials. Note that not all users will have permissions required to access each service.

{
  "server": "localhost",
  "port": 5672,
  "users": {
    "<service_name>": {
      "username": "<username>",
      "password": "<password>"
    }
  }
}

Services

The MQConnector class should be extended by a class providing some specific service. Service classes will specify the following parameters.

service_name: Name of the service, used to identify credentials in configuration
vhost: Virtual host to connect to; messages are all constrained to this namespace.
consumers: Dict of names to ConsumerThread objects. A ConsumerThread will accept a connection to a particular connection, a queue, and a callback_func
- connection: MQ connection to the vhost specified above.
- queue: Queue to monitor within the vhost. A vhost may handle multiple queues.
- callback_func: Function to call when a message arrives in the queue

Callback Functions

A callback function should have the following signature:

def handle_api_input(self,
                     channel: pika.channel.Channel,
                     method: pika.spec.Basic.Return,
                     properties: pika.spec.BasicProperties,
                     body: bytes):
    """
        Handles input requests from MQ to Neon API

        :param channel: MQ channel object (pika.channel.Channel)
        :param method: MQ return method (pika.spec.Basic.Return)
        :param properties: MQ properties (pika.spec.BasicProperties)
        :param body: request body (bytes)
    """

Generally, body should be decoded into a dict, and that dict should contain message_id. The message_id should be included in the body of any response to associate the response to the request. A response may be sent via:

 channel.queue_declare(queue='<queue>')

 channel.basic_publish(exchange='',
                       routing_key='<queue>',
                       body=<data>,
                       properties=pika.BasicProperties(expiration='1000')
                       )

Where <queue> is the queue to which the response will be published, and data is a bytes response (generally a base64-encoded dict).

Asynchronous Consumers

By default, async-based consumers handling based on pika.SelectConnection will be used

Override use of async consumers

There are a few methods to disable use of async consumers/subscribers.

To disable async consumers for a particular class/object, set the class-attribute async_consumers_enabled to False:

from neon_mq_connector import MQConnector

class MQConnectorChild(MQConnector):
   async_consumers_enabled = False

To disable the use of async consumers at runtime, set the MQ_ASYNC_CONSUMERS envvar to False
```
export MQ_ASYNC_CONSUMERS=false
```

Metadata

Release files for neon-mq-connector 0.10.1a2

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for neon-mq-connector 0.10.1a2
File	Size	Uploaded
neon_mq_connector-0.10.1a2.tar.gz	32.2 kB	Aug 20, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for neon-mq-connector 0.10.1a2
File	Interpreter	ABI	Platform	Reset
neon_mq_connector-0.10.1a2-py3-none-any.whl 53.6 kB Aug 20, 2026	Python 3	none	any	Details

Total release size: 85.8 kB

Release files / neon_mq_connector-0.10.1a2.tar.gz

Download URL	neon_mq_connector-0.10.1a2.tar.gz
Size	32.2 kB
Tags	Source
SHA-256 checksum How to use checksums	`282735daac5ab2e1d2c5a5ba5a4135e284860fb6ab653c0a79d6cac206687001`
BLAKE2b-256 checksum How to use checksums	`f261addcd2abdabb80acb392116c3a736fa34564eb9d170374c5e7768d271493`
Upload date	Aug 20, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.13.14`

Release files / neon_mq_connector-0.10.1a2-py3-none-any.whl

Download URL	neon_mq_connector-0.10.1a2-py3-none-any.whl
Size	53.6 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`27116838fe187a92b0d749c5bf0a13a3422ad6cf9e74d026bec586f50f833bc3`
BLAKE2b-256 checksum How to use checksums	`b60d5be8afce6c08c3e1e0f7b02d978a5491ec11d2d5b47012acd296d9cdf4a8`
Upload date	Aug 20, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.13.14`