Гм

moko 29.08 16:58

Ну если хорошо распишите класс, в теории наверное можно сделать. https://packages.debian.org/forky/librabbitmq4 в Debian есть.

$amqp[^rabbitmq::create[user:password@localhost:5672/;
      $.tls[ $.ca[/etc/ssl/ca.crt] $.cert[/etc/ssl/app.crt] $.key[/etc/ssl/app.key] ]
      $.heartbeat[30] $.retry[ $.min_ms[500] $.max_ms[15000] $.factor[2.0] $.jitter(true) ]
]]

^amqp.declare_exchange[ $.name[jobs] $.type[direct] $.durable(true) ]

^amqp.declare_queue[ $.name[jobs.test] $.durable(true) $.dlx[jobs.dlx] $.dlk[rk.dead] ]
^amqp.bind[ $.queue[jobs.test] $.exchange[jobs], $.routing_key[test] ]

^amqp.consume[
  $.queue[jobs.test]
  $.prefetch[16]
  $.concurrency[8]
  $.mode[parallel|threaded|sequental?]
  $.serializer[json] ^rem{ едва ли будет другой }
  $.on_message[$test_worker] ^rem{ имя Parser-функции-хендлера }
]

declare_queue / bind - наверное можно объединить, возможно нужен механизм выхода из consume.

---