search

mp-co-ru / mpc-peresvet

Data acqusition, GUI, decision making. IoT, SCADA, dispatching and monitoring.
https://mp-co-ru.github.io/mpc-peresvet/
Apache License 2.0
0 stars 0 forks source link

Изменить рассылку сообщений в базовом классе #273

Closed Vovaman closed 5 months ago

Vovaman commented 6 months ago

model_crud_svc.py:

mes = aio_pika.Message(
     body=f'{body}'.encode(),
     content_type='application/json',
     delivery_mode=aio_pika.DeliveryMode.PERSISTENT
 )
for r_k in self._config.publish["main"]["routing_key"]:
                await self._amqp_publish["main"]["exchange"].publish(
                    mes, routing_key=r_k
                )

Надо использовать метод класса _post_message