1 |
<?php |
<?php |
2 |
|
|
3 |
|
/** |
4 |
|
* Ce fichier permet de créer un consumeur des messages stockées dans la |
5 |
|
* pile de RabbitMQ réservée au ERP. |
6 |
|
* |
7 |
|
* @package openfoncier |
8 |
|
*/ |
9 |
|
|
10 |
include_once('../../core/om_debug.inc.php'); |
include_once('../../core/om_debug.inc.php'); |
11 |
include_once('../../dyn/services.inc.php'); |
include_once('../../dyn/services.inc.php'); |
12 |
|
|
191 |
// declare un exchange qui va diriger les messages |
// declare un exchange qui va diriger les messages |
192 |
$ch->exchange_declare($exchange, 'direct', false, true, false); |
$ch->exchange_declare($exchange, 'direct', false, true, false); |
193 |
|
|
194 |
// relier la pille d'ERP au exchange |
// relier la pile d'ERP au exchange |
195 |
$ch->queue_bind($queue, $exchange); |
$ch->queue_bind($queue, $exchange); |
196 |
|
|
197 |
// registre le callback pour ce consumer aupres de RabbitMQ |
// registre le callback pour ce consumer aupres de RabbitMQ |