RabbitMQ

RabbitMQ is a versatile, open-source message broker favored for its support of multiple protocols, scalability in distributed or federated setups, and trusted reliability across global enterprises and startups alike.

Installation

Bash

pip install aio-pika

Overview

To use the RabbitMQ transporter, pass the following options object to the create_microservice() method:

Python

from app_module import AppModule

from nestipy.core import NestipyFactory
from nestipy.microservice import MicroserviceOption, Transport, RabbitMQClientOption

app = NestipyFactory.create_microservice(
    AppModule, [
        MicroserviceOption(
            transport=Transport.RABBITMQ,
            option=RabbitMQClientOption(
                host="localhost",
                port=1883
            )
        )
    ]
)

Client

Python

from nestipy.common import Module
from nestipy.microservice import ClientsModule, ClientsConfig, RabbitMQClientOption, MicroserviceOption, Transport


@Module(
    imports=[
        ClientsModule.register([
            ClientsConfig(
                name="MATH_SERVICE",
                option=MicroserviceOption(
                    transport=Transport.RABBITMQ,
                    option=RabbitMQClientOption(
                        host="localhost",
                        port=1883
                    )
                )
            )
        ]),
    ]
    ...
)
class AppModule:
    ...

Support us

Nestipy is a project released under the MIT license, meaning it's open source and freely available for use and modification. Its development thrives with the generous contributions of these fantastic individuals.