/[openfoncier]/trunk/services/outgoing/messageenqueuer.php
ViewVC logotype

Diff of /trunk/services/outgoing/messageenqueuer.php

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 826 by mlimic, Fri Nov 23 10:07:15 2012 UTC revision 827 by mlimic, Fri Nov 23 17:23:46 2012 UTC
# Line 1  Line 1 
1  <?php  <?php
2    
 /*  
 define('HOST', 'localhost');  
 define('PORT', 5672);  
 define('USER', 'guest');  
 define('PASS', 'guest');  
 define('VHOST', '/');  
 */  
   
3    
4  require_once('./php/php-amqplib/vendor/autoload.php');  require_once('./php/php-amqplib/vendor/autoload.php');
5  use PhpAmqpLib\Connection\AMQPConnection;  use PhpAmqpLib\Connection\AMQPConnection;
6  use PhpAmqpLib\Message\AMQPMessage;  use PhpAmqpLib\Message\AMQPMessage;
7  //Si le AMQP_DEBUG est defini, on peut utiliser sortie du AMQP sur CLI // ???  
8  define('AMQP_DEBUG', true);  include_once('../core/om_debug.inc.php');
9    (defined("DEBUG") ? "" : define("DEBUG", EXTRA_VERBOSE_MODE));
10    
11    include_once('../core/om_logger.class.php');
12    
13    // pour des besoins de logging il faut setter $_SERVER["REQUEST_URI"]
14    if (!isset($_SERVER["REQUEST_URI"])) {
15        $_SERVER["REQUEST_URI"] = __FILE__;
16    }
17    
18    // Si le AMQP_DEBUG est defini a true, les messages DEBUG sont envoyes aux
19    // stdout
20    if (DEBUG > PRODUCTION_MODE) {
21        define('AMQP_DEBUG', true);
22    }
23    
24    
25  class MessageSender {  class MessageSender {
26            
       
27      public static $ERP_DEMANDE_COMPLETUDE_PC = 'erpDemandeCompletudePc';      public static $ERP_DEMANDE_COMPLETUDE_PC = 'erpDemandeCompletudePc';
28      public static $ERP_QUALIFIE = 'erpQualifie';      public static $ERP_QUALIFIE = 'erpQualifie';
29      public static $ERP_DEMANDE_QUALIFICATION_PC = 'erpDemandeQualificationPc';      public static $ERP_DEMANDE_QUALIFICATION_PC = 'erpDemandeQualificationPc';
# Line 97  class MessageSender { Line 102  class MessageSender {
102          $ch->close();          $ch->close();
103          $conn->close();          $conn->close();
104                    
105            // log le message qui etait mis sur la pile dans RabbitMQ
106            logger::instance()->log("Ajout du message sur pile: ".
107                                json_encode($this->ret_array), EXTRA_VERBOSE_MODE);
108            logger::instance()->writeLogToFile();
109            
110          return 0;          return 0;
111      }      }
112    
Legend:
Removed from v.826  
changed lines
  Added in v.827
[email protected]
 ViewVC Help
Powered by ViewVC 1.1.26